Struct LeaderElection 

pub struct LeaderElection { /* private fields */ }

Leader election coordinator

Implementations

impl LeaderElection

pub fn new( node_id: String, group_id: String, config: ElectionConfig, event_tx: Option<Sender<ElectionEvent>>, ) -> Self

Create a new leader election coordinator

pub fn register_member(&self, node_id: String, priority: u32)

Register a cluster member

pub fn update_member_liveness(&self, node_id: &str, is_alive: bool)

Update member liveness

pub fn remove_member(&self, node_id: &str)

Remove a member

pub fn state(&self) -> ElectionState

Get current election state

pub fn is_leader(&self) -> bool

Check if this node is the leader

pub fn leader(&self) -> Option<LeaderInfo>

Get current leader info

pub fn current_term(&self) -> u64

Get current term

pub fn fencing_token(&self) -> u64

Get fencing token (for write operations)

pub async fn start_election(&self) -> Result<bool, ElectionError>

Start an election

pub fn handle_vote_request(&self, request: &VoteRequest) -> Vote

Process a vote request from another candidate

pub async fn handle_vote(&self, vote: Vote) -> Result<bool, ElectionError>

Process a vote response

pub async fn accept_leader( &self, leader_info: LeaderInfo, ) -> Result<(), ElectionError>

Accept a new leader (for followers)

pub async fn renew_lease(&self) -> Result<(), ElectionError>

Renew leadership lease (call periodically when leader)

pub async fn step_down(&self) -> Result<(), ElectionError>

Step down from leadership

pub fn needs_election(&self) -> bool

Check if election is needed (leader lease expired)

pub async fn check_lease(&self)

Check lease and update state if expired

pub fn validate_fencing_token(&self, token: u64) -> bool

Validate a fencing token for write operations

pub fn stats(&self) -> ElectionStats

Get election statistics