Struct LeaderGuard 

pub struct LeaderGuard { /* private fields */ }

Implementations

impl LeaderGuard

pub fn new(role_rx: Receiver<NodeRole>) -> Self

pub fn is_leader(&self) -> bool

pub fn current_role(&self) -> NodeRole

pub async fn wait_for_leadership(&mut self) -> NodeRole

pub async fn wait_for_leadership_with_timeout( &mut self, timeout: Duration, ) -> Option<NodeRole>

pub fn check(&self) -> Result<(), ReconcileError>

Trait Implementations

impl Clone for LeaderGuard

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.