raft-rs
raft-rs copied to clipboard
tikv
Raft distributed consensus algorithm implemented in Rust.
https://github.com/pingcap/raft-rs/issues/136 ## New features * Add some new fields in `Message` * New concepts `Group` and `Delegate` in the cluster topology * ~~A message now could be sent to a...
With this, https://github.com/rust-lang/cargo/pull/9508, the dependency can no longer be used. What was picked with 1.53 cargo was ~2.0, so use that instead. **This needs to be a new branch 0.5.1...
Is it possible to provide an example on how to handle a committed ConfChangeV2 Entry? The example in `single_mem_node` is still a TODO and in `five_mem_node` still uses the old...
**Is your feature request related to a problem? Please describe.** In the current API new appended entries and committed entries are fetched into `Ready` synchronously. However In many cases we...
Signed-off-by: linning When there is no pending Readindex, MsgAppend will do the work of MsgHeartbeat, so when we had broadcasted MsgAppend, we can reset heartbeat_elapsed to reduce MsgHeartbeat. close #309
We use `progress.committed_index` to keep track of a peer's known commit index, but in some cases `progress.committed_index` may not accurate and `progress.matched >= progress.committed_index` may not be true, although `raft-rs`...
the code in examples/five_mem_node/main.rs:281 ```rust let mut handle_committed_entries = |rn: &mut RawNode, committed_entries: Vec| { for entry in committed_entries { if entry.data.is_empty() { // From new elected leaders. // -----------------------...
Signed-off-by: Little-Wallace Store heartbeat messages in a independent vector so that we do not need to create a `Ready` struct for raft-group even if there is no entries or propose...
**Is your feature request related to a problem? Please describe.** [Paper](https://www.vldb.org/pvldb/vol11/p1849-cao.pdf) introduces a mechanism that allows applying raft logs out of order. Quotes from the paper: > . As the...
We have developed ours implementation but as discussed in the past, we decided to go with the community and port the implement of etcd instead. There will be several PRs:...