Struct Host 

pub struct Host<M> { /* private fields */ }

A host, managing the lifecycle of several procs, and their backend routing, as described in this module’s documentation.

Implementations

impl<M: ProcManager> Host<M>

pub async fn new(manager: M, addr: ChannelAddr) -> Result<Self, HostError>

Serve a host using the provided ProcManager, on the provided addr. On success, the host will multiplex messages for procs on the host on the address of the host.

pub async fn new_with_default( manager: M, addr: ChannelAddr, default_sender: Option<BoxedMailboxSender>, ) -> Result<Self, HostError>

Like [new], serves a host using the provided ProcManager, on the provided addr. Unknown destinations are forwarded to the default sender.

pub fn serve(&mut self) -> Option<MailboxServerHandle>

Start serving this host’s mailbox on its frontend address. Returns the server handle on first invocation; afterwards None.

pub fn manager(&self) -> &M

The underlying proc manager.

pub fn addr(&self) -> &ChannelAddr

The address which accepts messages destined for this host.

pub fn system_proc(&self) -> &Proc

The system proc associated with this host. This is used to run host-level system services like host managers.

pub fn local_proc(&self) -> &Proc

The local proc associated with this host. This is the local proc used in processes that are also hosts.

pub async fn spawn( &mut self, name: String, config: M::Config, ) -> Result<(ProcId, ActorRef<ManagerAgent<M>>), HostError>

Spawn a new process with the given name. On success, the proc has been spawned, and is reachable through the returned, direct-addressed ProcId, which will be ProcId::Direct(self.addr(), name).

impl<M: ProcManager + BulkTerminate> Host<M>

pub async fn terminate_children( &self, cx: &impl Actor, timeout: Duration, max_in_flight: usize, ) -> TerminateSummary

Gracefully terminate all procs spawned by this host.

Delegates to the underlying manager’s BulkTerminate::terminate_all implementation. Use this to perform orderly teardown during scale-down or shutdown.

Parameters

• timeout: Per-child grace period before escalation.
• max_in_flight: Upper bound on concurrent terminations.

Returns

A TerminateSummary with counts of attempted/ok/failed terminations.

Trait Implementations

impl<M: ProcManager + SingleTerminate> SingleTerminate for Host<M>

fn terminate_proc<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, cx: &'life1 (impl 'async_trait + Actor), proc: &'life2 ProcId, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<(Vec<ActorId>, Vec<ActorId>), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Gracefully terminate the given proc.