Struct ElectionManager 

pub struct ElectionManager { /* private fields */ }

Election manager.

Implementations

impl ElectionManager

pub fn new( local_peer_id: PeerId, config: ElectionConfig, event_tx: Sender<ElectionEvent>, ) -> Self

Create a new election manager.

pub fn state(&self) -> ElectionState

Get the current election state.

pub fn current_master(&self) -> Option<PeerId>

Get the current master.

pub fn is_master(&self) -> bool

Check if we are the master.

pub fn is_follower(&self) -> bool

Check if we are a follower.

pub fn seniority(&self) -> Duration

Get our seniority.

pub fn session_id(&self) -> u64

Get the current session ID.

pub fn record_command(&self)

Increment commands seen.

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

Start a new election campaign.

pub fn create_message(&self) -> ElectionMessage

Create an election message to broadcast.

pub async fn process_message( &self, msg: ElectionMessage, ) -> Result<Option<ElectionMessage>>

Process a received election message.

pub async fn check_election_complete( &self, all_peers: &[PeerId], ) -> Result<bool>

Check if election is complete (all candidates agree on winner).

pub async fn handle_master_loss(&self) -> Result<()>

Handle master loss (triggers new election).

pub async fn check_timeout(&self) -> Result<bool>

Check for election timeout.

pub async fn force_master(&self) -> Result<()>

Force become master (for single-node clusters).

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

Step down from master role.

Trait Implementations

impl Debug for ElectionManager

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

Formats the value using the given formatter.