19fc1a7137
rafthttp: update streamReader term in time
...
Because etcd 2.1 will build stream to any existing peers and etcd 2.0
requires the remote to provide most updated term, it is
necessary for streamReader to know the latest term.
2015-05-26 14:52:42 -07:00
1c1cccd236
rafthttp: stop etcd if it is found removed when stream dial
...
The original process is stopping etcd only when pipeline message finds itself
has been removed. After this PR, stream dial has this functionality too.
It helps fast etcd stop, which doesn't need to wait for stream break to
fall back to pipeline, and wait for election timeout to send out message
to detect self removal.
2015-04-27 15:10:00 -07:00
9f19b5660f
rafthttp: add AddRemote
...
Add remotes to rafthttp, who help newly joined members catch up the
progress of the cluster. It supports basic message sending to remote, and
has no stream connection for simplicity. remotes will not be used
after the latest peers have been added into rafthttp.
2015-04-24 11:49:23 -07:00
88224f6f4e
Revert "etcdserver: not apply stale conf change in cluster and transport"
...
This reverts commit 40197f0698
2015-04-19 11:08:03 -07:00
40197f0698
etcdserver: not apply stale conf change in cluster and transport
2015-03-27 12:53:34 -07:00
0fe9861197
rafthttp: support multiple peer urls
2015-03-04 15:00:07 -08:00
44e53953c9
rafthttp: add comments for Transporter interface
2015-03-03 22:34:47 -08:00
9d445d2fcf
rafthttp: add transport tests
2015-03-02 13:25:30 -08:00
399e3cdf81
rafthttp: add stream http tests
2015-03-02 13:24:50 -08:00
b4b9b9118a
rafthttp: report MsgSnap status
2015-03-02 09:38:11 -08:00
9b986fb4c1
rafthttp: report unreachable status of the peer
...
When it failed to send message to the remote peer, it reports unreachable
to raft.
2015-03-01 16:48:26 -08:00
1c5a507761
rafthttp: refactor peer and add general stream
2015-02-28 11:35:16 -08:00
99840c9697
*: cleanup import
2015-02-28 10:12:35 -08:00
c16cc3a6a3
etcdserver: recover transport when recovering from a snapshot
2015-02-13 10:16:28 -08:00
317e57a8a8
rafthttp: Panic informatively when removing unknown peer ID
2015-02-12 14:43:44 -08:00
58112c4d2d
rafthttp: remove follower from leaderstats when it is removed from the cluster
2015-02-10 11:22:33 -08:00
f1ed69e883
*: switch to line comments for copyright
...
Build tags are not compatible with block comments.
Also adds copyright header to a few places it was missing.
2015-01-26 09:53:30 -08:00
15be030aaa
etcdserver: collect error from errorc
2015-01-02 20:13:46 -08:00
d2c7a7e5cb
rafthttp: remove raftPrefix
2014-12-30 13:48:07 -08:00
c712dd682a
rafthttp: make Transport private
2014-12-29 12:20:52 -08:00
a14d13f724
rafthttp: make fields in Transport private
2014-12-29 12:08:13 -08:00
5bb8eeb5cf
rafthttp: transport cleanup
2014-12-29 11:21:40 -08:00
08f839e32c
rafthttp: set the API boundary of the package
2014-12-28 15:50:27 -08:00
Yicheng Qin