Struct LeaderElectionManager 

pub struct LeaderElectionManager {
    pub state: Rc<RefCell<LeaderElectionState>>,
    pub heartbeat_interval: Option<i32>,
    pub heartbeat_closure: Option<Closure<dyn FnMut()>>,
    /* private fields */
}

Manager for multi-tab leader election

Fields

state: Rc<RefCell<LeaderElectionState>>

heartbeat_interval: Option<i32>

heartbeat_closure: Option<Closure<dyn FnMut()>>

Implementations

impl LeaderElectionManager

pub fn new(db_name: String) -> Self

Create new leader election manager with deterministic instance ID

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

Start leader election process using localStorage coordination

pub async fn try_become_leader_internal( &mut self, force: bool, ) -> Result<(), DatabaseError>

Try to become leader using localStorage-based atomic coordination

Arguments

• force - If true, ignores existing leader’s valid lease and forces takeover

pub async fn try_become_leader(&mut self) -> Result<(), DatabaseError>

Try to become leader (respects existing leader’s lease)

pub async fn force_become_leader(&mut self) -> Result<(), DatabaseError>

Force leadership takeover (ignores existing leader’s lease)

pub fn start_heartbeat(&mut self) -> Result<(), DatabaseError>

Start sending heartbeats as leader using localStorage

pub async fn stop_election(&mut self) -> Result<(), DatabaseError>

Stop leader election (e.g., when tab is closing)

pub async fn is_leader(&self) -> bool

Check if this instance is the leader (with localStorage validation and re-election)

pub async fn send_heartbeat(&self) -> Result<(), DatabaseError>

Send a heartbeat (for testing)

pub async fn get_last_heartbeat(&self) -> u64

Get timestamp of last received leader heartbeat from localStorage