Struct LeadershipHandle 

pub struct LeadershipHandle {
    pub events: Receiver<Option<LeadershipEvent>>,
    /* private fields */
}

Handle returned by LeaderElector::start(). One-shot per LeaderElector instance — create a new instance to restart.

Fields

events: Receiver<Option<LeadershipEvent>>

Subscribe to leadership state changes.

Implementations

impl LeadershipHandle

pub fn new( events: Receiver<Option<LeadershipEvent>>, is_leader: Arc<AtomicBool>, cancel: CancellationToken, terminated: Receiver<()>, ) -> Self

Public constructor — required by camel-platform-kubernetes which lives in a separate crate and cannot use struct literal syntax for fields that are private.

pub fn is_leader(&self) -> bool

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

Signal step-down AND await full teardown: lease release + loop termination + StoppedLeading delivered.