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 serve( manager: M, addr: ChannelAddr, ) -> Result<(Self, MailboxServerHandle), 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 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.

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: Debug> Debug for Host<M>

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

Formats the value using the given formatter.

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.