-
Notifications
You must be signed in to change notification settings - Fork 2.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
grpc: update grpc-rs, remove server cpupool, update config. #1865
Conversation
Now ready for review. cc @siddontang @BusyJay |
src/server/raft_send.rs
Outdated
handle.spawn(client.raft() | ||
.sink_map_err(Error::from) | ||
let (sink, _) = client.raft(); | ||
handle.spawn(sink.sink_map_err(Error::from) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we need the raft send worker now? Seem we can send to CQ directly?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You are right. Working on it.
LGTM |
The RaftMessageWorker is removed. PTAL @siddontang @BusyJay |
LGTM |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
* add grpc_service. (#1821) * server: add a SendRunner to send raft messages to other stores. (#1837) * pd: switch to grpc-rs (#1800) * grpc: update kvproto, remove kv/coprocessor from tcp server. (#1844) * grpc: replace tcp server with grpc server. (#1850) * grpc: update grpc-rs, remove server cpupool, update config. (#1865) * *: update grpc-rs. * server: share env and cleanup old rpc. (#1867) * grpc: add metrics. (#1868) * grpc: setup concurrent stream. (#1879)
…ikv#1865) * kvengine: fix Shard::from_change_set & to_change_set with columnar Signed-off-by: Ray Yan <[email protected]> * add columnar and use dfs in test case Signed-off-by: Ray Yan <[email protected]> --------- Signed-off-by: Ray Yan <[email protected]>
No description provided.