Struct Elector 

pub struct Elector { /* private fields */ }

Top-level state machine for a single kevy node in the v3-cluster Phase 1.5 election. One per process (election is per-node, not per-shard).

Implementations

impl Elector

pub fn new( node_id: impl Into<String>, peer_ids: Vec<String>, my_advertised_addr: impl Into<String>, start_role: Role, config: ElectConfig, jitter: ElectJitter, ) -> Self

Build an elector for a node with the given stable id, peer membership (the full list including self), advertised host:port, and config tunables.

start_role is Primary for the bootstrap node (operator- declared at first start) and Replica for the rest.

pub fn set_repl_offset(&mut self, offset: u64)

Update this node’s repl_offset (called by the kevy-server adapter when the replication source / runner advances).

pub fn role(&self) -> Role

Current self-perceived role.

pub fn epoch(&self) -> u64

Current epoch.

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

Last-known primary id (None until first ANNOUNCE / boot declaration).

pub fn tick(&mut self, now: Instant) -> Vec<Outbound>

Drive the elector forward by now. Schedules outbound HB per peer, detects DOWN, transitions Candidate → Primary on quorum, and runs the candidate’s election-timeout fallback. Returns a fresh batch of outbound messages — callers should drain in one pass.

pub fn on_message( &mut self, from_node_id: &str, msg: Message, now: Instant, ) -> Vec<Outbound>

Process one inbound message (from from_node_id) at now. Updates per-peer view, applies the state machine transitions the spec defines, returns any outbound messages the transition produced.