Struct ClusterRemoteAdapter 

pub struct ClusterRemoteAdapter { /* private fields */ }

Implementations

impl ClusterRemoteAdapter

pub async fn start( system: ActorSystem, bind: SocketAddr, settings: RemoteSettings, ) -> Result<Self, TransportError>

pub fn self_address(&self) -> &Address

pub fn cluster_ref(&self) -> &ActorRef<Gossip>

pub async fn send_gossip(&self, peer: &Address) -> Result<(), TransportError>

Push our current gossip state at peer.

pub fn update_local<F>(&self, f: F)

where F: FnOnce(&mut Gossip),

Update the local gossip — typically a tick of the local clock and a member-status change.

pub fn snapshot(&self) -> Gossip

pub fn mark_unreachable(&self, observer: &Address, peer: &Address)

Mark peer unreachable in our local membership state. Driven by the failure detector registry inside the underlying EndpointManager.

pub fn refresh_reachability(&self)

Periodic heartbeat: poll the remote failure detector registry and flag any peer that has gone unavailable as unreachable.

pub async fn shutdown(&self)

Trait Implementations

impl Clone for ClusterRemoteAdapter

fn clone(&self) -> ClusterRemoteAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.