sorock 0.12.0

A Multi-Raft implementation in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use super::*;

#[derive(Serialize, Deserialize)]
pub enum Command<'a> {
    /// Any append entry from a client shouldn't be processed unless consensus is reached
    /// up to the barrier entry which is queued by the current leader.
    /// This ensures the current leader has common log entries with the majority.
    Barrier(Term),
    ClusterConfiguration {
        membership: HashSet<NodeAddress>,
    },
    Snapshot {
        membership: HashSet<NodeAddress>,
    },
    ExecuteRequest {
        #[serde(with = "serde_bytes")]
        message: &'a [u8],
        request_id: String,
    },
    CompleteRequest {
        request_id: String,
    },
}

impl<'a> Command<'a> {
    pub fn serialize(self) -> Bytes {
        bincode::serialize(&self).unwrap().into()
    }

    pub fn deserialize(x: &[u8]) -> Command<'_> {
        bincode::deserialize(x).unwrap()
    }
}