Struct ProcMesh 

pub struct ProcMesh { /* private fields */ }

A mesh of processes.

Implementations

impl ProcMesh

pub async fn stop(&mut self, cx: &impl Actor, reason: String) -> Result<()>

Stop this mesh gracefully.

If a ProcMeshController is present (owned meshes spawned from a host mesh), the stop is delegated to the controller via resource::Stop; the controller’s handler awaits HostMeshRef::stop_proc_mesh, which casts Stop + WaitRankStatus{min_status: Stopped} to the HostAgents and waits up to PROC_STOP_MAX_IDLE for every proc to reach Stopped. We then serialize behind that handler with a GetState to read the final statuses out of the controller’s health_state.

Methods from Deref<Target = ProcMeshRef>

pub fn id(&self) -> &ProcMeshId

pub fn host_mesh_id(&self) -> Option<&HostMeshId>

pub fn hosts(&self) -> Option<&HostMeshRef>

Returns the HostMeshRef that owns this ProcMeshRef, if any.

pub async fn actor_states( &self, cx: &impl Actor, id: ActorMeshId, ) -> Result<ValueMesh<State<ActorState>>>

Query the state of all actors in this mesh matching the given id.

pub async fn proc_states( &self, cx: &impl Actor, keepalive: Option<SystemTime>, ) -> Result<Option<ValueMesh<State<ProcState>>>>

pub async fn spawn<A: RemoteSpawn, C: Actor>( &self, cx: &C, name: &str, params: &A::Params, ) -> Result<ActorMesh<A>>

where A::Params: RemoteMessage, C::A: Handler<MeshFailure>,

Spawn an actor on all of the procs in this mesh, returning a new ActorMesh.

Bounds:

• A: Actor - the actor actually runs inside each proc.
• A: Referable - so we can return typed ActorRef<A>s inside the ActorMesh.
• A::Params: RemoteMessage - spawn parameters must be serializable and routable.

pub async fn spawn_service<A: RemoteSpawn, C: Actor>( &self, cx: &C, name: &str, params: &A::Params, ) -> Result<ActorMesh<A>>

where A::Params: RemoteMessage, C::A: Handler<MeshFailure>,

Spawn a ‘service’ actor. Service actors are singletons, using reserved names. The provided name is used verbatim as the actor’s name, and thus it may be persistently looked up by constructing the appropriate name.

Note: avoid using service actors if possible; the mechanism will be replaced by an actor registry.

pub async fn spawn_with_name<A: RemoteSpawn, C: Actor>( &self, cx: &C, name: ActorMeshId, params: &A::Params, supervision_display_name: Option<String>, is_system_actor: bool, ) -> Result<ActorMesh<A>>

where A::Params: RemoteMessage, C::A: Handler<MeshFailure>,

Spawn an actor on all procs in this mesh under the given ActorMeshId, returning a new ActorMesh.

This is the underlying implementation used by [spawn]; it differs only in that the actor mesh id is passed explicitly rather than as a &str.

Bounds:

• A: Actor - the actor actually runs inside each proc.
• A: Referable - so we can return typed ActorRef<A>s inside the ActorMesh.
• A::Params: RemoteMessage - spawn parameters must be serializable and routable.
• C::A: Handler<MeshFailure> - in order to spawn actors, the actor must accept messages of type MeshFailure. This is delivered when the actors spawned in the mesh have a failure that isn’t handled.

Trait Implementations

impl Debug for ProcMesh

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

Formats the value using the given formatter.

impl Deref for ProcMesh

type Target = ProcMeshRef

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Display for ProcMesh

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

Formats the value using the given formatter.

impl Drop for ProcMesh

fn drop(&mut self)

Executes the destructor for this type.