Struct ActorMesh 

pub struct ActorMesh<A: Referable> { /* private fields */ }

An ActorMesh is a collection of ranked A-typed actors: the lifecycle owner over an ActorMeshRef, which is the cast/address surface.

The mesh may be managed — created via ProcMesh and backed by a controller — or data-only — spawned through an ActorSpawner and carrying each rank’s local lifecycle handle. Both variants own their actors and can stop them. Monitoring works through the mesh’s members in either case.

Bound note: A: Referable because the mesh stores/returns ActorRef<A>, which is only defined for A: Referable.

Implementations

impl<A: Referable> ActorMesh<A>

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

Stop actors on this mesh across all procs.

A data mesh stops each rank’s local supervisor proxy. The shared stop fence makes this operation one-shot across owner clones.

Methods from Deref<Target = ActorMeshRef<A>>

pub fn as_managed(&self) -> Option<&ManagedActorMeshRef<A>>

Return the legacy dense ref when this is the managed variant.

pub fn id(&self) -> &ActorMeshId

Return the mesh id.

pub fn cast<M>(&self, cx: &impl Actor, message: M) -> Result<()>

where A: RemoteHandles<M>, M: RemoteMessage + Clone,

Cast a message to all the actors in this mesh.

This initiates delivery without waiting for it; use Self::monitor to observe actors that stop or fail.

pub fn cast_with_headers<M>( &self, cx: &impl Actor, caller_headers: &Flattrs, message: M, ) -> Result<()>

where A: RemoteHandles<M>, M: RemoteMessage + Clone,

pub fn cast_with_return_undeliverable<M>( &self, cx: &impl Actor, caller_headers: &Flattrs, message: M, return_undeliverable: bool, ) -> Result<()>

where A: RemoteHandles<M>, M: RemoteMessage + Clone,

Cast message with explicit undeliverable-return behavior.

pub async fn next_supervision_event( &self, cx: &impl Actor, ) -> Result<MeshFailure, Error>

Return the next supervision event observed on this mesh.

pub fn clone_with_supervision_receiver(&self) -> Self

See ManagedActorMeshRef::clone_with_supervision_receiver.

pub fn monitor(&self, cx: &impl Actor) -> MeshMonitor

Create a new, independent monitor over every rank.

Trait Implementations

impl<A: Referable> Clone for ActorMesh<A>

Manual implementation of Clone because A doesn’t need to implement Clone but we still want to be able to clone the ActorMesh.

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Referable> Debug for ActorMesh<A>

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

Formats the value using the given formatter.

impl<A: Referable> Deref for ActorMesh<A>

type Target = ActorMeshRef<A>

The resulting type after dereferencing.

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

Dereferences the value.

impl<A: Referable> Display for ActorMesh<A>

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

Formats the value using the given formatter.

impl<A: Referable> Drop for ActorMesh<A>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.