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
11,844 Commits 15 Branches 491 Tags 148 MiB
Commit Graph

168 Commits

Author SHA1 Message Date
Igor German
ada4af3b2a grpcproxy: fix memory leak 
use set instead of slice as interval value

fixes #10326
 2018-12-17 18:58:04 -08:00
Rob Day
ceaa55e57e
httpproxy: cancel requests when client closes a connection 2018-03-07 23:01:10 -08:00
Gyu-Ho Lee
91335d01bb proxy/grpcproxy: wait until register before Serve 
It was fatal-ing with:

grpclog.Fatalf("grpc: Server.RegisterService after Server.Serve for %q", sd.ServiceName)

Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-11-16 09:34:11 -08:00
Gyu-Ho Lee
d62e39d5ca *: deprecate "metadata.NewContext" 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-11-16 09:05:06 -08:00
Anthony Romano
01c4f35b30 grpcproxy: respect KeysOnly flag 
Fixes #8478
 2017-09-14 04:41:58 +09:00
Anthony Romano
be8f102efb grpcproxy: forward PrevKv flag in Put 2017-08-04 07:32:17 -07:00
Anthony Romano
19fe4b0cac grpcproxy: return nil on receiving snapshot EOF 
Gets "code = OutOfRange desc = EOF" errors otherwise.
 2017-07-19 08:33:44 -07:00
Anthony Romano
33c375dc44 *: fill out blank package godocs 
Mostly one-liner short descriptions, but also includes some typo fixes
and some examples.
 2017-05-18 09:41:13 -07:00
Anthony Romano
5bd9b9614f tcpproxy: display endpoints, not pointers, in ready to proxy string 
The switch to *net.SRV for endpoints caused the ready string to emit
pointers instead of endpoint strings.

Fixes #7942
 2017-05-17 10:51:35 -07:00
Anthony Romano
713e006bc6 adpater: adapters for lock and election services 2017-05-10 12:51:05 -07:00
Anthony Romano
fd01db9e60 grpcproxy, etcdmain: add lock and election services to proxy 2017-05-10 12:19:09 -07:00
Anthony Romano
c232814003 etcdmain, tcpproxy: srv-priority policy 
Adds DNS SRV weighting and priorities to gateway.

Partially addresses #4378
 2017-05-08 11:35:18 -07:00
Anthony Romano
6dd8fb6f24 Revert "Merge pull request #7732 from heyitsanthony/lease-err-ka" 
This reverts commit fbbc4a4979b256125d2238f6325ad86e7f1b58bd, reversing
changes made to f254e383859a2939d5929346f6595549f424f7c5.

Fixes #7851
 2017-05-02 09:36:16 -07:00
Anthony Romano
b5384ac1c0 grpcproxy: use new lease interface 2017-04-24 23:49:44 -07:00
Gyu-Ho Lee
7adf4d7c94 grpcproxy/adapter: add Cluster API support 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-04-04 08:13:30 -07:00
Gyu-Ho Lee
5c642ae314 grpcproxy/adapter: add maintenance API support 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-03-28 09:09:06 -07:00
Gyu-Ho Lee
caa73c176f proxy/grpcproxy: add chanStream helper 
Prelimiary work for maintenance API in adapter

Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-03-27 11:24:02 -07:00
Anthony Romano
b2a465e354 grpcproxy/cache: only check compaction revision for historical revisions 
Since the current revision is 0, it'll always be less than the compaction
revision. If the proxy sees a compaction, it would always reject the
current revision requests since it's less than the compaction revision.
Instead, check if the revision is historical before trying to reject on
compaction revision.

Fixes #7599
 2017-03-24 13:20:46 -07:00
Anthony Romano
b025cdd097 adapter, integration: split out grpc adapters from grpcproxy package 
Break cyclic dependency:
clientv3/naming <-> integration <-> v3client <-> grpcproxy <-> clientv3/naming
 2017-03-13 15:23:26 -07:00
Gyu-Ho Lee
f862b47e92 grpcproxy: configure register to Cluster API 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-03-09 02:40:13 -08:00
Anthony Romano
28e9ba365a grpcproxy: return closing error when stream is canceled from conn close 
Fixes #6630
 2017-03-01 16:46:13 -08:00
Gyu-Ho Lee
72a531e8b2 grpcproxy: add 'register' address 
For https://github.com/coreos/etcd/issues/6902.
 2017-02-22 16:47:48 -08:00
Anthony Romano
25403970f5 Merge pull request #7361 from heyitsanthony/fix-gateway-goroutine 
tcpproxy: don't use range variable in reactivate goroutine
 2017-02-21 13:26:53 -08:00
Anthony Romano
8b097f279d tcpproxy: don't use range variable in reactivate goroutine 
Ends up trying to reactivate only the last endpoint.
 2017-02-21 12:39:49 -08:00
Anthony Romano
29a6fd65ad grpcproxy: only return ctx error in chan stream if recvc is empty 
Since select{} won't prioritize, ctx.Done() can sometimes override
a pending message on recvc. Loop if recvc has messages instead.

Fixes #7340
 2017-02-21 10:53:58 -08:00
fanmin shi
ba52bd07ba grpcproxy: add lease coalescing support 2017-02-16 11:50:50 -08:00
fanmin shi
05b82f2022 grpcproxy: refactor chan stream out of watch_client_adapter 2017-02-16 11:41:21 -08:00
Anthony Romano
80de75431e grpcproxy: support forcing leader as available 
Leadership timeout can sometimes take too long, such as in test cases.
However, it is possible to infer a leader is available based on RPCs
that must go through consensus. Therefore, have a way to update the
leadership status off the watch path.
 2017-02-15 16:49:41 -08:00
Anthony Romano
36f5b713bf grpcproxy: don't wait for ctx.Done() to close kv donec 
Causes a goroutine leak in ActiveConnection.Close() tests. Channel is
vestigial since removing ccache; revisit if kv ever needs goroutines.
 2017-02-15 00:16:25 -08:00
Anthony Romano
49a0a63fc3 grpcproxy: split out leadership detection code 
Move out of watch code since will be shared with lease code. Also assumes
leader does not exist unless watch can be successfully created.
 2017-02-15 00:16:25 -08:00
Anthony Romano
853f68071b grpcproxy: respect CompactRevision in watcher 
CompactRevision wasn't sent over watch stream, causing TestKVCompact to hang.
 2017-02-13 15:43:41 -08:00
Anthony Romano
c22ba766d5 grpcproxy: support CountOnly 
TestKVRange from client integration tests was failing.
 2017-02-10 16:06:24 -08:00
Anthony Romano
1fe2a9b124 Revert "Merge pull request #7139 from heyitsanthony/proxy-rlock" 
This reverts commit 304606ab0bb009169b442dec6f9af76e4cd1e887, reversing
changes made to 7dfe503f1c86de755ca379e95922e43afacee923.
 2017-02-10 14:37:48 -08:00
Anthony Romano
d159353d51 Merge pull request #7268 from heyitsanthony/proxy-test-clientv3 
test: add proxy tests for clientv3 integration tests
 2017-02-02 20:31:05 -08:00
Anthony Romano
e42fa18ccf grpcproxy: don't use WithRequireLeader for watch event stream 
Ohterwise leader loss will reject all stream creation.
 2017-02-02 09:32:25 -08:00
sharat
9def4cb9fe *: Use http.Request.WithContext instead of Cancel 2017-02-02 22:50:07 +05:30
sharat
2fce80e4c0 grpcproxy: handle 'IgnoreLease' field in PutRequest 2017-01-25 03:14:31 +05:30
Anthony Romano
8c0282ab24 grpcproxy, etcdmain, integration: add close channel to kv proxy 
ccache launches goroutines that need to be explicitly stopped.

Fixes #7158
 2017-01-18 11:51:16 -08:00
Gyu-Ho Lee
0f8060bede grpcproxy: handle 'IgnoreValue' field in PutRequest 2017-01-13 15:13:18 -08:00
Anthony Romano
9fa6c95054 grpcproxy: use ccache for key cache 
groupcache needs a write lock and has no way to expire keys; ccache can
do this, though.

Also removes the key count metric, since there's no way to efficiently
calculate it using ccache.
 2017-01-13 10:00:57 -08:00
Anthony Romano
e179225f28 grpcproxy: tear down watch when client context is done 
If client closes but all watch streams are not canceled, the outstanding
watch will wait until it is canceled, causing watch server to potentially
wait forever to close.

Fixes #7102
 2017-01-04 16:23:27 -08:00
Anthony Romano
9b5eb1ae5a grpcproxy, etcdmain, integration: return done channel with WatchServer 
Makes it possible to synchronously close the watch server.

Fixes #7078
 2016-12-30 12:09:48 -08:00
Gyu-Ho Lee
7e74b3f846 grpcproxy: remove unused field 'wbs *watchBroadcasts' 2016-12-12 10:07:14 -08:00
Gyu-Ho Lee
a98de7efa7
grpcproxy: fix minor typo 2016-12-07 17:08:46 -08:00
Anthony Romano
91ff6f30b5 grpcproxy: fix deadlock in watchbroadcast 
Calling empty() in watchbroadcast methods was trying to
lock the rwmutex when it was already held.

Fixes #6937
 2016-12-05 15:06:44 -08:00
Anthony Romano
62398954e4 grpcproxy: lock store when getting size 
Fixes data race in proxy integration tests.
 2016-12-05 13:29:57 -08:00
Xiang Li
0cb680800e grpcproxy: add cache related metrics 2016-12-02 15:29:42 -08:00
Xiang Li
1f954dc9f4 Merge pull request #6926 from xiang90/metrics 
grpcproxy: add richer metrics for watch
 2016-12-02 14:13:43 -08:00
Xiang Li
a686c994cd grpcproxy: add richer metrics for watch 2016-12-02 11:13:30 -08:00
Anthony Romano
60908c64a6 grpcproxy: fix race between coalesce and bcast on nextrev 
coalesce was locking the target coalesce broadcast object but not the source
broadcast object resulting in a data race on the source's nextrev.
 2016-11-30 16:50:29 -08:00