Struct almost_raft::election::RaftElectionState

pub struct RaftElectionState<T> { /* fields omitted */ }

Current state of the Raft

Implementations

impl<T: Node> RaftElectionState<T>

pub fn init(
    self_id: String,
    election_timeout: u64,
    heartbeat_interval: u64,
    message_timeout: u64,
    peers: Vec<T>,
    tx: Sender<Message<T>>,
    max_node: usize,
    min_node: usize
) -> (Self, Sender<Message<T>>)

Initiate Raft election. This method doesn’t start the election.

Arguments

• self_id - Identifier of this node
• election_timeout - Time between the elections if no heartbeat is received. Will use a randomized value in range [election_timeout..election_timeout*2]
• heartbeat_interval - Interval between heartbeat message
• message_timeout - Timout before treating message sending as failure
• peers - other nodes
• tx - MPSC Sender to communicate with outside. Control messages will use this channel
• max_node - Maximum number of allowed node in the cluster
• min_node - Minimum node required. Election will not start until number of node reach min_node

Returns

Tuple - the initialized RaftElectionState & a Sender of mpsc channel for incoming control messages

Trait Implementations

impl<T: Debug> Debug for RaftElectionState<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.