Struct ElectionManager 

pub struct ElectionManager {
    pub node_id: String,
    pub term: u64,
    pub state: ElectionState,
    /* private fields */
}

Manager for a single-node’s view of the cluster election.

Fields

node_id: String

This node’s identifier.

term: u64

Current election term.

state: ElectionState

State of this node in the current term.

Implementations

impl ElectionManager

pub fn new( node_id: impl Into<String>, cluster_size: usize, election_timeout: Duration, ) -> Self

Create a new election manager for node_id in a cluster of cluster_size nodes.

pub fn start_election(&mut self)

Advance to the next term and transition this node to Candidate.

pub fn record_vote(&mut self, vote: NodeVote) -> bool

Record a vote for the current term.

Returns true if the vote was accepted (valid for current term and not a duplicate from the same voter).

pub fn winner(&self) -> Option<&str>

Return the candidate with the most votes, or None if no votes yet.

pub fn quorum(&self) -> usize

Quorum required to win: majority of the cluster.

pub fn vote_count(&self) -> usize

Number of votes received in the current term.

pub fn is_timed_out(&self, now: Instant) -> bool

Return true if the election has timed out.

pub fn become_follower(&mut self)

Transition this node to follower of leader_id, resetting election state.

pub fn become_leader(&mut self)

Force-set this node as leader (called after winning election externally).

Trait Implementations

impl Debug for ElectionManager

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

Formats the value using the given formatter.