Struct Gateway 

pub struct Gateway { /* private fields */ }

Connectivity boundary for one or more procs.

Implementations

impl Gateway

pub fn new() -> Self

Create a fresh unserved gateway with dial-based forwarding.

pub fn isolated() -> Self

Create a fresh unserved local-only gateway.

pub fn global() -> &'static Self

Return the process-wide global gateway.

pub fn default_location(&self) -> Location

The gateway’s default advertised location.

pub fn set_default_location(&self, location: Location)

Set the gateway’s default advertised location.

pub fn proc_addr(&self, proc_id: &ProcId) -> ProcAddr

Construct a routeable proc address using this gateway’s default location.

pub fn serve( &self, addr: ChannelAddr, ) -> Result<GatewayServeHandle, ChannelError>

Serve this gateway on the provided channel address.

When serving the first local ChannelAddr::any address, the gateway binds the local address that was reserved when the gateway was created. Local reservation is separate from local binding so a gateway can have a stable location before it has a runtime available to run a server. Later local any serves allocate fresh local ports, so the gateway can have multiple active local servers.

Serving updates the gateway’s default location to the newly served address. When that server stops, the default location falls back to the previous active server, or to the reserved fallback location when no server remains.

Trait Implementations

impl Clone for Gateway

fn clone(&self) -> Gateway

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Gateway

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

Formats the value using the given formatter.

impl MailboxSender for Gateway

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

Raw transport: no policy.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Wait until all messages previously posted through this sender have been delivered (wire-acked) or confirmed undeliverable. The default implementation is a no-op, appropriate for senders whose post is synchronous (e.g. local in-process delivery).

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

Apply hop semantics (TTL decrement; undeliverable on 0), then delegate to transport.