Struct RaftNodeCore 

pub struct RaftNodeCore<LogEntry: AbstractLogEntry + Send + 'static, LogStorage: StableStorage + Send + Clone + 'static, FSM: AbstractStateMachine + Clone + 'static> {
    pub raw_node: RawNode<LogStorage>,
    pub fsm: FSM,
    pub peers: Arc<Mutex<Peers>>,
    /* private fields */
}

Fields

raw_node: RawNode<LogStorage>

fsm: FSM

peers: Arc<Mutex<Peers>>

Implementations

impl<LogEntry: AbstractLogEntry + Send + 'static, LogStorage: StableStorage + Send + Clone + 'static, FSM: AbstractStateMachine + Clone + Send + 'static> RaftNodeCore<LogEntry, LogStorage, FSM>

pub fn bootstrap( node_id: u64, should_be_leader: bool, log_storage: LogStorage, fsm: FSM, config: Config, raft_addr: SocketAddr, logger: Arc<dyn Logger>, tx_server: Sender<ServerRequestMsg<LogEntry, LogStorage, FSM>>, rx_server: Receiver<ServerRequestMsg<LogEntry, LogStorage, FSM>>, tx_local: Sender<LocalRequestMsg<LogEntry, LogStorage, FSM>>, rx_local: Receiver<LocalRequestMsg<LogEntry, LogStorage, FSM>>, ) -> Result<Self>

pub fn is_leader(&self) -> bool

pub fn get_id(&self) -> u64

pub fn get_leader_id(&self) -> u64

pub async fn get_peers(&self) -> Peers

pub async fn add_peer<A: ToSocketAddrs>( &mut self, id: u64, addr: A, role: Option<InitialRole>, ) -> Result<()>

pub async fn add_peers(&mut self, peers: HashMap<u64, SocketAddr>) -> Result<()>

pub async fn make_snapshot(&mut self, index: u64, term: u64) -> Result<()>

pub async fn inspect(&self) -> Result<String>

pub async fn run(self) -> Result<()>