6e5eb03544
storage: move watcherGauge to watchable_store
...
watcherGauge should be increased everytime we creates Watcher, not per watch
method call.
2015-11-04 13:17:47 -08:00
319b77b051
Merge pull request #3810 from gyuho/storage_metrics_add_watcher_gauge
...
storage: add metrics to watcher
2015-11-04 13:09:07 -08:00
4ebf28aa2e
storage: add metrics to watcher
...
This adds metrics to watcher, and changes some order in MustRegister function
calls in init (same order that we define the gauges).
2015-11-04 13:01:52 -08:00
33fe6f41fb
Merge pull request #3808 from yichengq/fix-wait-test
...
pkg/wait: extend wait timeout in TestWaitTime
2015-11-04 11:39:24 -08:00
3d15526c35
Merge pull request #3796 from yichengq/fix-get-version
...
etcdserver: not reuse connections for peer transport
2015-11-04 11:39:14 -08:00
c37bd2385a
*: refactor kv rpc implementation
2015-11-04 11:36:17 -08:00
3b8349c06e
pkg/wait: extend wait timeout in TestWaitTime
...
Fix this error happening on travis:
```
--- FAIL: TestWaitTime-2 (0.01s)
wait_time_test.go:46: cannot receive from ch as expected
```
2015-11-04 11:18:17 -08:00
4ccbcb91c8
rafthttp: add functions to create listener and roundTripper
...
This moves the code to create listener and roundTripper for raft communication
to the same place, and use explicit functions to build them. This prevents
possible development errors in the future.
2015-11-04 11:12:46 -08:00
32819f6b3f
etcdserver: use roundTripper to request peerURL
...
It uses roundTripper instead of Transport because roundTripper is
sufficient for its requirements.
2015-11-04 10:49:42 -08:00
5272ee99b5
Merge pull request #3804 from xiang90/ctl_watch
...
etcdctlv3: support watch
2015-11-04 10:21:05 -08:00
616078dc1b
Merge pull request #3807 from xiang90/kv
...
*: rename etcd service to kv service in gRPC
2015-11-04 10:11:02 -08:00
1a3f7f7fa4
*: rename etcd service to kv service in gRPC
2015-11-04 10:05:49 -08:00
65d153db73
Merge pull request #3783 from yichengq/merge-logger
...
rafthttp: use MergeLogger for rafthttp logging
2015-11-04 09:48:43 -08:00
6040d57106
rafthttp: use MergeLogger to merge message-drop log
...
rafthttp logs repeated messages when amounts of message-drop logs
happen, and it becomes log spamming.
Use MergeLogger to merge log lines in this case.
2015-11-04 07:26:58 -08:00
5329159b5e
rafthttp: remove failureMap from peerStatus
...
The logging mechanism is verbose, so it is removed from peerStatus.
We would like to see the status change
of connection with peers, and one error that leads to deactivation.
There is no need to print out all non-repeated errors.
2015-11-04 07:26:33 -08:00
5c1b833232
etcdctlv3: support watch
...
A draft impl for demo.
2015-11-03 19:28:57 -08:00
c8e622f517
storage: make putm/delm a set with empty value
...
This cleans the code, and reduces the allocation space.
2015-11-03 19:10:45 -08:00
6dbfc21846
storage: delete key instead of setting it to false
...
When getting the watched events, it iterate all keys in putm and delm
to generate the events. If we don't delete the key from putm/delm,
it would range on the key that is not actually put or deleted. This is
incorrect.
Fix the panic that happens when single put/delete is watched.
2015-11-03 19:00:39 -08:00
94c6b6a93d
Merge pull request #3801 from yichengq/fix-raft-timeout
...
raft: extend wait timeout in TestNodeAdvance
2015-11-03 18:29:47 -08:00
0de52414cd
raft: extend wait timeout in TestNodeAdvance
...
This fixes the failure met in semaphore CI.
2015-11-03 16:57:18 -08:00
1f1d8e9282
Merge pull request #3800 from xiang90/watch_server
...
*: serve watch service
2015-11-03 16:32:29 -08:00
10de2e6dbe
*: serve watch service
...
Implement watch service and hook it up
with grpc server in etcdmain.
2015-11-03 15:58:34 -08:00
70cb8b8391
Merge pull request #3799 from gyuho/nameing_in_metrics_watching
...
storage: apply same naming in metrics.go
2015-11-03 15:23:39 -08:00
bdc280c4a7
storage: apply same naming in metrics.go
...
This is PR following up with Xiang's https://github.com/coreos/etcd/pull/3795 ,
and to make the naming consistent with its interface change.
2015-11-03 15:19:18 -08:00
f6b097c0cc
Merge pull request #3798 from xiang90/watch_new
...
*: add v3 watch service
2015-11-03 14:39:20 -08:00
c160085f44
*: add v3 watch service
2015-11-03 14:21:24 -08:00
154fc8e19c
Merge pull request #3795 from xiang90/watch_stream
...
storage: add watchChan
2015-11-03 13:32:49 -08:00
a1129dd5a5
storage: support multiple watching per watcher
...
We want to support multiple watchings per one watcher chan. Then
we can have one single go routine to watch multiple keys/prefixs.
2015-11-03 12:36:11 -08:00
34e7611093
Merge pull request #3797 from gyuho/procfile_20151103
...
Procfile: delay proxy waiting for initial cluster
2015-11-03 10:24:48 -08:00
5e29449d61
Procfile: delay proxy waiting for initial cluster
...
This fixes #3647 by delaying proxy start by 3 seconds. Without this, proxy
starts at the same time as initial cluster and since the default proxy director
refresh interval is 30-second, if cluster is not ready at first trial, the
proxy misses to discover them and has to wait another 30-seconds, which delays
the proxying for first 30-second.
2015-11-03 10:22:48 -08:00
0eee88a3d9
etcdserver: use timeout transport as peer transport
...
This pairs with remote timeout listeners.
etcd uses timeout listener, and times out the accepted connections
if there is no activity. So the idle connections may time out easily.
Becaus timeout transport doesn't reuse connections, it prevents using
timeouted connection.
This fixes the problem that etcd fail to get version of peers.
2015-11-03 07:58:03 -08:00
fe165de1d1
Merge pull request #3794 from yichengq/fix-proxy-term
...
etcdmain: fix parsing discovery error
2015-11-02 17:33:47 -08:00
9757dcd3a2
etcdmain: fix parsing discovery error
...
The discovery error is wrapped into a struct now, and cannot be compared
to predefined errors. Correct the comparison behavior to fix the
problem.
2015-11-02 17:23:06 -08:00
4fd65ecd4c
Merge pull request #3785 from yichengq/fix-block-test
...
storage: extend wait timeout for execution
2015-11-02 12:53:18 -08:00
a74dd4c47a
Merge pull request #3790 from xiang90/etcd-top
...
add etcdtop
2015-11-02 12:02:05 -08:00
8f9d237d21
Merge pull request #3792 from wojtek-t/update_ugorji
...
Update dependency on ugorji/go/codec
2015-11-02 07:43:48 -08:00
65ae8784fb
client: regenerate code to unmarshal key response
...
Regenerate code for unmarshaling key response with a new version of
ugorji/go/codec.
2015-11-02 12:06:32 +01:00
02eec7763d
Godeps: update ugorji/go/codec dependency
...
Update ugorji/go/codec dependency to the newer version.
2015-11-02 12:03:49 +01:00
e1b2e7245b
tools/etcd-top: add copyright header
2015-11-01 18:19:32 -08:00
c4f8fe96e8
travis: install libpcap
2015-11-01 18:16:20 -08:00
2bfe995fb8
Godeps: add dependency for etcd-top
2015-11-01 18:07:27 -08:00
00557e96af
tools: add etcd-top
2015-11-01 18:07:27 -08:00
59b5dabc66
storage: extend wait timeout for execution
...
Extend timeout to pass always in traivs.
2015-10-30 17:44:31 -07:00
f787e7904b
Merge pull request #3762 from jonboulle/auth
...
etcdserver: restructure auth.Store and auth.User
2015-10-30 16:49:28 -07:00
ee522025b3
etcdserver: restructure auth.Store and auth.User
...
This attempts to decouple password-related functions, which previously
existed both in the Store and User structs, by splitting them out into a
separate interface, PasswordStore. This means that they can be more
easily swapped out during testing.
This also changes the relevant tests to use mock password functions
instead of the bcrypt-backed implementations; as a result, the tests are
much faster.
Before:
```
github.com/coreos/etcd/etcdserver/auth 31.495s
github.com/coreos/etcd/etcdserver/etcdhttp 91.205s
```
After:
```
github.com/coreos/etcd/etcdserver/auth 1.207s
github.com/coreos/etcd/etcdserver/etcdhttp 1.207s
```
2015-10-30 16:33:40 -07:00
2840260b3b
Merge pull request #3781 from gyuho/doc_typo_20151029
...
Documentation: fix typo in proxy.md
2015-10-29 20:34:16 -07:00
294f03f85f
Documentation: fix typo in proxy.md
...
This fixes some typos in proxy.md.
Thanks,
2015-10-29 20:30:50 -07:00
00b4880494
Update ROADMAP.md
2015-10-29 16:05:40 -07:00
42255748cd
Update ROADMAP.md
2015-10-29 16:03:14 -07:00
1b3d9130c9
Merge pull request #3759 from yichengq/rafthttp-unreachable
...
rafthttp: mark unreachable on unexpected response
2015-10-29 15:12:23 -07:00
Gyu-Ho Lee