Struct EndpointManager 

pub struct EndpointManager { /* private fields */ }

Implementations

impl EndpointManager

pub fn new( protocol: Arc<AkkaProtocolTransport>, settings: RemoteSettings, ) -> Self

pub fn metrics(&self) -> RemoteMetrics

pub fn failure_detectors(&self) -> FailureDetectorRegistry

pub fn settings(&self) -> &RemoteSettings

pub fn protocol(&self) -> Arc<AkkaProtocolTransport>

pub fn local_address(&self) -> Option<Address>

pub async fn start(&self) -> Result<Address, TransportError>

Bind the underlying transport, store the local address, and start the dispatcher pump.

pub async fn endpoint_for( &self, target: &Address, ) -> Result<EndpointHandle, TransportError>

Get (or create) an outbound endpoint to target. Initiates the handshake if we are not yet associated.

pub async fn quarantine(&self, target: &Address)

Quarantine a peer for the configured duration. Drops any current endpoint and refuses reconnect attempts until the window expires.

pub fn tombstone(&self, target: &Address)

Permanent gate — peer will never be readmitted.

pub fn purge_tombstones(&self, older_than: Duration) -> usize

Drop tombstoned peers whose Tombstoned-since age exceeds older_than, so the peer table doesn’t grow unbounded across long-running clusters. Returns the number of entries removed. Phase 5 — quarantine lifecycle.

pub fn peer_state(&self, target: &Address) -> Option<AssociationState>

Current state for a single peer (None if no association has ever been attempted).

pub fn take_inbound(&self) -> UnboundedReceiver<InboundEnvelope>

Take the inbound stream of decoded user/system envelopes. Calling more than once returns an empty channel — the first taker is responsible for fan-out (typically the provider::InboundDispatcher).

pub fn peer_states(&self) -> Vec<(String, &'static str, u32)>

Snapshot of all known peers and their states (for telemetry).

pub async fn shutdown(&self) -> Result<(), TransportError>

Trait Implementations

impl Clone for EndpointManager

fn clone(&self) -> EndpointManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.