Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity
9,018 Commits 15 Branches 491 Tags 148 MiB
Commit Graph

313 Commits

Author SHA1 Message Date
Gyu-Ho Lee
2fa2c6284e clientv3: add 'prevKV' field to watch request 2016-10-07 14:22:58 -07:00
Gyu-Ho Lee
0544d4bfd0 clientv3: add WithPrevKV OpOption 2016-10-07 10:54:45 -07:00
Gyu-Ho Lee
fe7379f102 clientv3: add Op.prevKV 2016-10-07 10:51:01 -07:00
Xiang Li
3299cad1c3 *: add put prevkv 2016-10-07 10:39:08 -07:00
Anthony Romano
d9ab018c49 integration: test a canceled watch won't return a closing error 2016-10-05 14:19:36 -07:00
Anthony Romano
e853451cd2 clientv3: only return closing error to watcher if context is not canceled 
Fixes #6503
 2016-10-05 14:19:32 -07:00
Anthony Romano
1becf9d2f5 clientv3: fix race on watch initial revision 
The initial revision was being updated in the substream goroutine defer;
this was racing with the resume path fetching the initial revision when
the substream closes during resume. Instead, update the initial revision
whenever the substream processes a new watch response. Since the substream
cannot receive a watch response while it is resuming, the write to the
initial revision is ordered to always happen after the resume read.

Fixes #6586
 2016-10-05 10:56:36 -07:00
Anthony Romano
1a712cf187 clientv3: make IsProgressNotify() false on compact event and closed channel 
Fixes #6549
 2016-10-04 15:13:02 -07:00
Anthony Romano
e8473850a2 integration: test canceling watchers when disconnected 2016-10-04 15:12:37 -07:00
Anthony Romano
b836d187fd clientv3: simplify watch synchronization 
Was more complicated than it needed to be and didn't really work in the
first place. Restructured watcher registation to use a queue.
 2016-10-04 15:12:18 -07:00
Anthony Romano
273b986751 clientv3: process closed watcherStreams in watcherGrpcStream run loop 
Was racing with Watch() when closing the grpc stream on no watchers.

Fixes #6476
 2016-09-21 15:52:20 -07:00
Anthony Romano
4abc381ebe clientv3: drain buffered WatchResponses before resuming 
Otherwise, the watcherStream can receive WatchResponses in the
middle of a resume, corrupting the stream.

Fixes #6364
 2016-09-15 12:38:15 -07:00
Xiang Li
2435eb9ecd clientv3: balancer panics when call up after close 
Fix the issue by adding a simple guard varable.
 2016-09-15 18:46:26 +09:00
Jason E. Aten
4b48876f0e clientv3/concurrency: allow election on prefixes of keys. 
After winning an election or obtaining a lock, we
auto-append a slash after the provided key prefix.
This avoids the previous deadlock due to waiting
on the wrong key.

Fixes #6278

Conflicts:
	clientv3/concurrency/election.go
	clientv3/concurrency/mutex.go
 2016-08-31 09:46:05 -07:00
Anthony Romano
606d79afc4 clientv3: use failfast and retry wrappers for at-most-once rpcs 2016-08-16 12:12:44 -07:00
Anthony Romano
4a841459f1 clientv3: respect up/down notifications from grpc 
Fixes #5842
 2016-08-16 12:09:38 -07:00
Anthony Romano
8ae0f94cd7 clientv3: only block on New() when DialTimeout > 0 
Fixes #6162
 2016-08-12 12:03:33 -07:00
Anthony Romano
69a97863a9 clientv3: handle watchGrpcStream shutdown if prior to goroutine start 
Fixes #6141
 2016-08-09 20:59:09 -07:00
Anthony Romano
12c7e4a9f8 clientv3: close watcher stream once all watchers detach 
Fixes #6134
 2016-08-09 10:44:21 -07:00
Anthony Romano
21092ca715 integration: change timeouts for TestWatchWithProgressNotify 
a) 2 * progress interval was passing with dropped notifies
b) waitResponse was waiting so long that it expected a dropped notify
 2016-07-21 10:59:54 -07:00
Anthony Romano
846883a979 rpctypes, clientv3: retry RPC on EtcdStopped 
Fixes #5983
 2016-07-21 10:59:27 -07:00
Xiang Li
77af59796d clientv3/integration: fix race in TestWatchCompactRevision 2016-07-21 10:50:46 -07:00
Anthony Romano
b732f96e07 integration: drain keepalives in TestLeaseKeepAliveCloseAfterDisconnectRevoke 
Fixes #5900
 2016-07-21 10:50:44 -07:00
Anthony Romano
129b271ff8 clientv3: use grpc.FailFast(false) for all calls 2016-07-14 19:00:46 -07:00
westhood
1292d453c3 clientv3: fix sync base 
It is not correct to use WithPrefix. Range end will change in every
internal batch.
 2016-07-07 14:21:43 -07:00
westhood
ec20b381ed clientv3: add public function to get prefix range end 2016-07-07 14:21:41 -07:00
Anthony Romano
4b42ea6cd7 clientv3: only use closeErr on watch when donec is closed 
Fixes #5800
 2016-06-28 17:48:44 -07:00
Anthony Romano
8bbccf1047 clientv3, ctl3, clientv3/integration: add compact response to compact 2016-06-28 12:29:32 -07:00
Gyu-Ho Lee
76e2bf03b8 etcdctl: v3 compact with physical flag 2016-06-27 12:07:46 -07:00
Gyu-Ho Lee
859e336d68 clientv3: configurable physical in compact 2016-06-27 12:04:04 -07:00
Gyu-Ho Lee
2da5bdd4df clientv3: add auth example 2016-06-22 20:06:13 -07:00
James Shubin
6480066054 *: misc typos and go vet fixes 2016-06-22 10:32:13 -07:00
Xiang Li
6496ae005d clientv3: add withCount support 2016-06-21 21:17:35 -07:00
Anthony Romano
1097d63ff7 clientv3/integration: test WithRequireLeader on Watch 2016-06-20 14:26:16 -07:00
Anthony Romano
722f5b2a8c clientv3: watch with arbitrary ctx values 
Sets up a new watch stream for every unique set of ctx values.

Fixes #5354
 2016-06-20 12:44:51 -07:00
Ajit Yagaty
ad5d55dd4c v3api: Add a flag to RangeRequest to return only the keys. 
Currently the user can't list only the keys in a prefix search. In
order to support such operations the filtering will be done on the
server side to reduce the encoding and network transfer costs.
 2016-06-19 14:18:39 -07:00
Hitoshi Mitake
18253e2723 *: support getting all users and roles in auth v3 
This commit expands RPCs for getting user and role and support list up
all users and roles. etcdctl v3 is now support getting all users and
roles with the newly added option --all e.g. etcdctl user get --all
 2016-06-17 16:22:41 +09:00
Gyu-Ho Lee
5225a4e4bc clientv3: fix client for grpc change 
Fix https://github.com/coreos/etcd/issues/5638.
 2016-06-10 20:40:46 -07:00
Anthony Romano
a7c5058953 Merge pull request #5608 from heyitsanthony/clientv3-auth-opts 
clientv3: use separate dialopts for auth dial
 2016-06-09 12:56:59 -07:00
Anthony Romano
349eaf117a clientv3: use separate dialopts for auth dial 
Needs to use a different balancer from the main client connection
because of the way grpc uses the Notify channel.
 2016-06-09 10:38:57 -07:00
Anthony Romano
78c957df41 Merge pull request #5603 from heyitsanthony/clientv3-close-keepalive 
clientv3: close keepalive channel if TTL locally exceeded
 2016-06-09 09:44:32 -07:00
Anthony Romano
0554ef9c39 clientv3/integration: tests for closing lease channel 2016-06-09 09:12:59 -07:00
Anthony Romano
e534532523 clientv3: close keep alive channel if no response within TTL 2016-06-09 09:12:59 -07:00
Gyu-Ho Lee
a548cab828 Merge pull request #5602 from gyuho/get_leader 
clientv3/integration: WaitLeader to follower
 2016-06-08 17:03:25 -07:00
Gyu-Ho Lee
753073198f clientv3/integration: WaitLeader to follower 
Fix https://github.com/coreos/etcd/issues/5601.
 2016-06-08 16:45:32 -07:00
Hitoshi Mitake
253e313c09 *: support granting and revoking range 
This commit adds a feature for granting and revoking range of keys,
not a single key.

Example:
$ ETCDCTL_API=3 bin/etcdctl role grant r1 readwrite k1 k3
Role r1 updated
$ ETCDCTL_API=3 bin/etcdctl role get r1
Role r1
KV Read:
        [a, b)
        [k1, k3)
        [k2, k4)
KV Write:
        [a, b)
        [k1, k3)
        [k2, k4)
$ ETCDCTL_API=3 bin/etcdctl --user u1:p get k1 k4
k1
v1
$ ETCDCTL_API=3 bin/etcdctl --user u1:p get k1 k5
Error:  etcdserver: permission denied
 2016-06-08 14:58:25 -07:00
Anthony Romano
4a13c9f9b3 clientv3: use grpc balancer 2016-06-08 09:24:13 -07:00
Anthony Romano
62f8ec25c0 clientv3: use grpc reconnection logic 2016-06-08 01:04:59 -07:00
Gyu-Ho Lee
1e4d3603db clientv3,ctlv3: following changes for proto change 2016-06-07 13:32:36 -07:00
Xiang Li
83ce1051ff auth: make naming consistent 2016-06-07 10:54:50 -07:00