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 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.