| .. |
|
batcher.go
|
8aba4caa72
rafthttp: batch MsgProp
|
%!s(int64=11) %!d(string=hai) anos |
|
batcher_test.go
|
91bfead9e9
rafthttp: add batcher
|
%!s(int64=11) %!d(string=hai) anos |
|
entry_reader.go
|
9d53b94546
rafthttp: add streaming server and client
|
%!s(int64=11) %!d(string=hai) anos |
|
entry_test.go
|
9d53b94546
rafthttp: add streaming server and client
|
%!s(int64=11) %!d(string=hai) anos |
|
entry_writer.go
|
9d53b94546
rafthttp: add streaming server and client
|
%!s(int64=11) %!d(string=hai) anos |
|
http.go
|
fe53ffd74d
rafthttp: streamserver -> streamwriter
|
%!s(int64=11) %!d(string=hai) anos |
|
http_test.go
|
5bb8eeb5cf
rafthttp: transport cleanup
|
%!s(int64=11) %!d(string=hai) anos |
|
peer.go
|
4938e6bff5
rafthttp: a stopped peer does not accept any methods
|
%!s(int64=11) %!d(string=hai) anos |
|
peer_test.go
|
5bb8eeb5cf
rafthttp: transport cleanup
|
%!s(int64=11) %!d(string=hai) anos |
|
streamer.go
|
1aa8f1eee6
rafthttp: clean up reader when failed
|
%!s(int64=11) %!d(string=hai) anos |
|
transport.go
|
d2c7a7e5cb
rafthttp: remove raftPrefix
|
%!s(int64=11) %!d(string=hai) anos |
|
transport_test.go
|
c712dd682a
rafthttp: make Transport private
|
%!s(int64=11) %!d(string=hai) anos |
Xiang Li
1aa8f1eee6
rafthttp: clean up reader when failed