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
34
35
36
37
38
39
40
41

use super::*;

pub struct Effect {
    pub peers: Peers,
    pub state_machine: StateMachine,
    pub voter: Read<Voter>,
    pub driver: RaftHandle,
}

impl Effect {
    /// Restore the membership from the state of the log.
    pub async fn exec(self) -> Result<()> {
        let log_last_index = self.state_machine.get_log_last_index().await?;
        let last_membership_index = self
            .state_machine
            .find_last_membership_index(log_last_index)
            .await?;

        if let Some(last_membership_index) = last_membership_index {
            let last_membership = {
                let entry = self.state_machine.get_entry(last_membership_index).await?;
                match Command::deserialize(&entry.command) {
                    Command::Snapshot { membership } => membership,
                    Command::ClusterConfiguration { membership } => membership,
                    _ => unreachable!(),
                }
            };

            effect::set_membership::Effect {
                peers: self.peers.clone(),
                state_machine: self.state_machine.clone(),
                voter: self.voter.clone(),
                driver: self.driver.clone(),
            }
            .exec(last_membership, last_membership_index)
            .await?;
        };

        Ok(())
    }
}