Struct DialMailboxRouter

pub struct DialMailboxRouter { /* private fields */ }

A dynamic mailbox router that supports remote delivery.

DialMailboxRouter maintains a runtime address book mapping references to ChannelAddrs. It holds a cache of active connections and forwards messages to the appropriate MailboxClient.

Messages sent to unknown destinations are routed to the default sender, if present.

Implementations

impl DialMailboxRouter

pub fn new() -> Self

Create a new DialMailboxRouter with an empty routing table.

pub fn new_with_default(default: BoxedMailboxSender) -> Self

Create a new DialMailboxRouter with an empty routing table, and a default sender. Any message with an unknown destination is dispatched on this default sender.

pub fn bind(&self, dest: Reference, addr: ChannelAddr)

Binds a Reference to a ChannelAddr, replacing any existing binding.

If the address changes, the old sender is evicted from the cache to ensure fresh routing on next use.

pub fn unbind(&self, dest: &Reference)

Removes all address mappings with the given prefix from the router.

Also evicts any corresponding cached senders to prevent reuse of stale connections.

pub fn lookup_addr(&self, actor_id: &ActorId) -> Option<ChannelAddr>

Lookup an actor’s channel in the router’s address bok.

Trait Implementations

impl Clone for DialMailboxRouter

fn clone(&self) -> DialMailboxRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DialMailboxRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MailboxSender for DialMailboxRouter

fn post( &self, envelope: MessageEnvelope, return_handle: PortHandle<Undeliverable<MessageEnvelope>>, )

TODO: consider making this publicly inaccessible. While the trait itself needs to be public, its only purpose for the end-user API is to provide the typed messaging APIs from (Once)PortRef and ActorRef.