Struct ClusterDaemonHandle 

pub struct ClusterDaemonHandle { /* private fields */ }

Public handle to a running ClusterDaemon.

Implementations

impl ClusterDaemonHandle

pub fn join(&self, m: Member)

pub fn leave(&self, addr: Address)

pub fn down(&self, addr: Address)

Operator-initiated terminal-down for addr. Transitions the member to MemberStatus::Down (publishes MemberDowned); the daemon’s regular convergence flow then promotes Down → Removed on the next leader tick.

pub fn apply_gossip(&self, pdu: GossipPdu)

pub fn tick(&self)

pub fn snapshot(&self) -> DaemonSnapshot

pub fn events(&self) -> &ClusterEventBus

pub fn address(&self) -> &Address

pub fn gossip_inbox(&self) -> UnboundedSender<GossipPdu>

Cheaply-cloneable inbox that delivers GossipPdus into this daemon. Used by transport adapters that need to fan inbound PDUs into the daemon without holding the ClusterDaemonHandle itself (which is consume-on-shutdown).

pub async fn shutdown(self)

Stop and join.

Trait Implementations

impl Drop for ClusterDaemonHandle

fn drop(&mut self)

Executes the destructor for this type.