Struct LeaderLeaseManager 

pub struct LeaderLeaseManager { /* private fields */ }

Acquires and renews leadership while candidacy remains true.

Implementations

impl LeaderLeaseManager

pub fn new( store: Arc<LeaderLeaseStore>, process_lease: &ProcessLease, config: LeaderLeaseConfig, ) -> Result<Self, LeaseError>

Construct a manager bound to this boot’s acquired stable-node process lease.

Errors

Rejects invalid ownership or inconsistent renewal timings.

pub fn owner(&self) -> &LeaderLeaseOwner

Exact process incarnation this manager may publish.

pub fn lease_watch(&self) -> Receiver<Option<LeaderLease>>

Subscribe to the locally authorized leader record.

pub fn deadline(&self) -> Arc<LeaseDeadline>

Snapshot the current local-monotonic deadline generation.

This is useful before the manager starts and in fixed-generation tests. A running manager may replace it after any discontinuous grant; runtime consumers must subscribe through Self::deadline_watch.

pub fn deadline_watch(&self) -> Receiver<Arc<LeaseDeadline>>

Subscribe to generation-scoped local leader deadlines.

A discontinuous grant permanently fences the previous deadline and publishes a fresh inactive one before another durable fencing term can become locally authoritative.

pub fn spawn( self, shutdown: CancellationToken, candidate: Receiver<LeaderCandidacy>, ) -> JoinHandle<()>

Spawn the renewal loop. Loss of candidacy withdraws the current local grant so this manager can contend again later. A missed local deadline withdraws the grant and rotates its fencing token before reacquisition. Shutdown or an invalid lease outcome terminally fences the manager.

pub fn spawn_supervised( self, shutdown: CancellationToken, candidate: Receiver<LeaderCandidacy>, unexpected_exit: CancellationToken, ) -> JoinHandle<()>

Spawn the renewal loop and signal any exit not preceded by intentional shutdown.

The guard lives inside the same task as the manager future, so panic and forced task abort cannot detach a still-running inner lease writer.

Trait Implementations

impl Debug for LeaderLeaseManager

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

Formats the value using the given formatter.