Struct simple_raft::core::RaftState

pub struct RaftState<Log, Random, NodeId> { /* fields omitted */ }

The complete state of a Raft node.

Implementations

impl<Log, Random, NodeId> RaftState<Log, Random, NodeId> where
    Log: RaftLog,
    Random: RngCore,
    NodeId: Ord + Clone + Display, 

pub fn new(
    node_id: NodeId,
    peers: BTreeSet<NodeId>,
    log: Log,
    random: Random,
    config: RaftConfig
) -> Self

pub fn commit_idx(&self) -> &LogIndex

pub fn config(&self) -> &RaftConfig

pub fn is_leader(&self) -> bool

pub fn leader(&self) -> (Option<&NodeId>, &TermId)

pub fn log(&self) -> &Log

pub fn log_mut(&mut self) -> &mut Log

pub fn node_id(&self) -> &NodeId

pub fn peers(&self) -> &BTreeSet<NodeId>

pub fn replication_state(
    &self,
    peer_node_id: &NodeId
) -> Option<&ReplicationState>

pub fn set_config(&mut self, config: RaftConfig)

pub fn take_committed(&mut self) -> CommittedIter<'_, Log>

pub fn timer_tick(&mut self) -> Option<SendableRaftMessage<NodeId>>

pub fn reset_peer(
    &mut self,
    peer_node_id: NodeId
) -> Option<SendableRaftMessage<NodeId>>

pub fn timeout(&mut self) -> Option<SendableRaftMessage<NodeId>>

pub fn append_entries(
    &mut self,
    to_node_id: NodeId
) -> Option<SendableRaftMessage<NodeId>>

pub fn client_request(
    &mut self,
    data: Bytes
) -> Result<(), AppendError<Log::Error>>

pub fn receive(
    &mut self,
    msg: RaftMessage,
    from: NodeId
) -> Option<SendableRaftMessage<NodeId>>