raftify 0.1.82

Experimental High level Raft framework
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

#[cfg(feature = "heed_storage")]
pub mod heed_storage;

#[cfg(feature = "inmemory_storage")]
pub mod inmemory_storage;

#[cfg(feature = "rocksdb_storage")]
pub mod rocksdb_storage;

pub mod utils;

use crate::{
    error::Result,
    raft::{self, prelude::*},
};

pub enum StorageType {
    InMemory,
    Heed,
    RocksDB,
    Custom,
}

pub trait StableStorage: Storage {
    const STORAGE_TYPE: StorageType;

    fn append(&mut self, entries: &[Entry]) -> Result<()>;
    fn hard_state(&self) -> Result<HardState>;
    fn set_hard_state(&mut self, hard_state: &HardState) -> Result<()>;
    fn set_hard_state_commit(&mut self, commit: u64) -> Result<()>;
    fn conf_state(&self) -> Result<ConfState>;
    fn set_conf_state(&mut self, conf_state: &ConfState) -> Result<()>;
    fn create_snapshot(&mut self, data: Vec<u8>, index: u64, term: u64) -> Result<()>;
    fn apply_snapshot(&mut self, snapshot: Snapshot) -> Result<()>;
    fn compact(&mut self, index: u64) -> Result<()>;
    fn all_entries(&self) -> raft::Result<Vec<Entry>>;
}