a5b32ba941
etcdserver/api/v3rpc: add "etcd_network_server_stream_failures_total"
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-05-23 08:05:43 -07:00
294b5745d6
etcdserver/api/v3rpc: support watch fragmentation with max request bytes
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-05-14 12:35:50 -07:00
7088d2bf52
etcdserver/api/v3rpc: clean up, read lock on "prevKV"
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-05-14 12:35:50 -07:00
e1df2156c7
etcdserver/api/v3rpc: clean up godoc
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-05-14 12:35:50 -07:00
6cf3dae93e
etcdserver/api/v3rpc: fix race in stream error logging
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-05-01 16:19:55 -07:00
bdbed26f64
etcdserver: support structured logging
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-04-16 17:36:00 -07:00
4f754c1850
etcdserver: clean up with "RaftStatusGetter"
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-03-15 19:30:08 -04:00
8a518b01c4
*: revert "internal/mvcc" change
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-02-26 17:11:40 -08:00
bb95d190c1
*: revert "internal/auth" change
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-02-26 17:11:40 -08:00
142bff89f4
v3rpc: add jitter to progress notification
2018-02-05 10:37:12 -08:00
6c91766490
*: move "auth" to "internal/auth"
2018-01-29 14:57:35 +09:00
80d15948bc
*: move "mvcc" to "internal/mvcc"
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-01-26 11:14:41 -08:00
44e1f6f019
Merge pull request #9105 from spzala/getrevision
...
etcdserver/api/v3rpc: debug user cancellation and log warning for rest
2018-01-08 10:07:57 -08:00
a66d7c3ba5
etcdserver/api/v3rpc: debug user cancellation and log warning for rest
...
The context error with cancel code is typically for user cancellation which
should be at debug level. For other error codes we should display a warning.
Fixes #9085
2018-01-08 11:03:13 -05:00
65464838ba
Merge pull request #9065 from gyuho/watch-id-2
...
*: allow user-provided watch ID to mvcc
2018-01-05 15:08:10 -08:00
9a50255515
etcdserver/api/v3rpc: log stream error with debug level
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2018-01-02 07:44:07 -08:00
33c732b97c
api/v3rpc: add watch ID to "watchStream.Watch"
...
Signed-off-by: Gyuho Lee <gyuhox@gmail.com >
2017-12-31 13:20:41 -08:00
6bd41f36ff
api/v3rpc: log grpc stream send/recv errors in server-side
...
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com >
2017-11-29 17:34:05 -08:00
f65aee0759
*: replace 'golang.org/x/net/context' with 'context'
...
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com >
2017-09-07 13:39:42 -07:00
6fb08672d8
v3rpc: set canceled=true when stream is compacted
...
Fixes #8231
2017-07-25 12:36:01 -07:00
939912c425
clientv3, etcdserver: support auth in Watch()
2017-05-20 11:34:45 +09:00
135a40751e
v3rpc: force RangeEnd=nil if length is 0
...
gRPC will replace empty strings with nil, but for the embedded case it's
possible for []byte{} to slip in and confuse the single key / >= key
watch logic.
2017-04-07 16:36:38 -07:00
9a20743190
v3rpc: don't close watcher if client closes send
...
grpc-gateway will CloseSend but still want to receive updates.
2016-11-17 15:33:37 -08:00
4d3b281369
etcdserver: fix spell errors
2016-08-13 20:54:48 -07:00
299ebc6137
v3rpc: don't elide next progress notification on progress notification
...
Fixes #5878
2016-07-20 11:37:20 -07:00
58aa3483c3
grpcproxy: add filter to watcher
2016-07-18 13:02:34 -07:00
427496ebb8
v3rpc: lock progress and prevKV map correctly
2016-07-07 15:01:05 -07:00
929d6ab62c
Merge pull request #5850 from xiang90/get_o_kv
...
*: support get-old-kv in watch
2016-07-05 16:37:24 -07:00
c853704ac9
*: support get-old-kv in watch
2016-07-05 16:17:09 -07:00
13a4056327
v3rpc: do not panic on user error for watch
2016-07-03 08:57:48 -07:00
dced92f8bd
*: support watch with filters
...
Now user can filter events with types. The API is also extensible.
It might make sense for the proxy to filter out events based on
more expensive/customized filter.
2016-06-28 13:46:57 -07:00
6f28b43806
*: fix pending events metrics
2016-06-19 23:00:39 -07:00
09e8f5782e
v3rpc: fix race on closing watcher stream ctrl channel
...
Sometimes close would race with the recvLoop, leading the
recvLoop to write to a close channel.
2016-05-31 11:07:31 -07:00
c438310634
v3rpc: make watcher wait for its send goroutine to finish
2016-05-27 16:54:26 -07:00
abb4cd5646
etcdserver: update LICENSE header
2016-05-12 20:49:40 -07:00
9c103dd0de
*: cancel required leader streams when memeber lost its leader
2016-05-12 19:42:21 -07:00
b7ac758969
*: rename storage package to mvcc
2016-04-25 15:25:51 -07:00
88306c9fa7
etcdserver, clientv3: let progressReportIntervalMilliseconds be private
...
progressReportIntervalMilliseconds (old
ProgressReportIntervalMilliseconds) is accessed by multiple goroutines
and it is reported as race.
For avoiding this report, this commit wraps the variable with
functions. They access the variable with atomic operations so the race
won't be reported.
2016-04-05 09:12:17 +09:00
5ee85bea7c
v3rpc: fix race on watch progress map
...
Found in TestElectionWait
2016-03-28 16:08:18 -07:00
91dc6b29a6
clientv3/integration: fix race when setting progress report interval
2016-03-28 16:08:18 -07:00
036ed87c6d
*: support watch from future revision
2016-03-07 10:57:30 -08:00
d84811aecf
*: fix watch full key range
2016-03-05 14:45:43 -08:00
b1521570b6
v3api: support progress
2016-03-03 13:58:15 -08:00
c0eac7ab72
storage: support watch on ranges
2016-02-29 15:20:41 -08:00
8dbc6cfd43
etcdserver: ranges in watcher rpc protocol
...
protocol change so watch requests are ranges; server rejects non-prefix ranges
2016-02-29 14:03:27 -08:00
4a0a83380e
*: return -1 for canceled watch request
2016-02-26 14:26:46 -08:00
a78604dacb
*: watch true cancel, created for wrong rev
...
This sets Created and Cancel true in pb.WatchResponse
when it has received wrong start revision instead of
panic. So that clientv3 can set 'Canceled' in WatchResponse
as well.
Fix https://github.com/coreos/etcd/issues/4610 .
2016-02-24 20:56:17 -08:00
af225e7433
v3rpc: don't race on current watcher header revision
2016-02-17 14:03:52 -08:00
59e7be4a2a
v3api: send watch events only after sending watchid creation
...
If events show up before the watch id, the client won't be able
to match the event with the requested watcher.
2016-02-17 01:06:55 -08:00
ee1a03167d
storage, v3: pass compaction revision through watchresponse
2016-02-12 14:06:59 -08:00
