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

use super::*;

/// Delete log entries in `[, snapshot_index)`.
pub struct Effect {
    pub state_machine: StateMachine,
}
impl Effect {
    pub async fn exec(self) -> Result<()> {
        let cur_snapshot_index = self.state_machine.snapshot_pointer.load(Ordering::SeqCst);
        self.state_machine
            .storage
            .delete_entries_before(cur_snapshot_index)
            .await?;
        Ok(())
    }
}