 Xiang Li
|
94da4b9ee5
rafthttp: log before receiving snapshot
|
10 лет назад |
|
Xiang Li
|
23bd60ccce
*: rewrite snapshot sending
|
10 лет назад |
 Yicheng Qin
|
f725f6a552
rafthttp: deprecate streamTypeMsgApp
|
10 лет назад |
|
Xiang Li
|
427a154aae
rafthttp: various clean up
|
10 лет назад |
|
Xiang Li
|
e87cd0c17b
rafthttp: move new funcs to right place
|
10 лет назад |
|
Xiang Li
|
478fab6aca
rafthttp: rename NewHandler to newPipelineHandler
|
10 лет назад |
|
Xiang Li
|
080c11d14e
rafthttp: make ConnReadLimitByte private and add comment
|
10 лет назад |
|
Yicheng Qin
|
1f21ccf166
rafthttp: support sending v3 snapshot message
|
10 лет назад |
 Dmitry Smirnov
|
b2f4a5f587
*: fix spelling issues (codespell).
|
10 лет назад |
|
Xiang Li
|
0fc764200d
rafthttp: monitor connection
|
10 лет назад |
|
Yicheng Qin
|
f1e995b070
rafthttp: use leveled logger
|
10 лет назад |
|
Yicheng Qin
|
c371d8c65c
rafthttp: version enforcement on rafthttp messages
|
10 лет назад |
|
Xiang Li
|
0d3d4c5b01
rafthttp: print out log when clusterID mismatch instead of exiting
|
10 лет назад |
|
Yicheng Qin
|
38b8e848ac
rafthttp: try stream msgappV1 handler if msgappV2 is unsupported
|
10 лет назад |
|
Yicheng Qin
|
1c1cccd236
rafthttp: stop etcd if it is found removed when stream dial
|
10 лет назад |
|
Yicheng Qin
|
0d88e0d111
rafthttp: introduce msgappv2 stream format
|
10 лет назад |
|
Yicheng Qin
|
399e3cdf81
rafthttp: add stream http tests
|
11 лет назад |
|
Yicheng Qin
|
b4b9b9118a
rafthttp: report MsgSnap status
|
10 лет назад |
|
Yicheng Qin
|
1c5a507761
rafthttp: refactor peer and add general stream
|
11 лет назад |
|
Yicheng Qin
|
55cd03ff4b
rafthttp: add run loop for peer
|
11 лет назад |
 Xiang Li
|
99840c9697
*: cleanup import
|
11 лет назад |
 Jonathan Boulle
|
f1ed69e883
*: switch to line comments for copyright
|
11 лет назад |
 Brian Waldon
|
2120af8cfc
pkg: ioutils -> ioutil
|
11 лет назад |
|
Yicheng Qin
|
84ceefbffc
rafthttp: write StatusOK before start streaming
|
11 лет назад |
|
Xiang Li
|
fe53ffd74d
rafthttp: streamserver -> streamwriter
|
11 лет назад |
|
Xiang Li
|
2193b70fb3
rafthttp: add stream
|
11 лет назад |
|
Xiang Li
|
c712dd682a
rafthttp: make Transport private
|
11 лет назад |
|
Yicheng Qin
|
5bb8eeb5cf
rafthttp: transport cleanup
|
11 лет назад |
|
Yicheng Qin
|
08f839e32c
rafthttp: set the API boundary of the package
|
11 лет назад |
|
Yicheng Qin
|
61ce494386
rafthttp: limit the buffer for every read correctly
|
11 лет назад |
