Struct ActorMesh 

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

An ActorMesh is a collection of ranked A-typed actors.

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

Implementations

impl<A: Referable> ActorMesh<A>

pub fn name(&self) -> &Name

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

Stop actors on this mesh across all procs.

Methods from Deref<Target = ActorMeshRef<A>>

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

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

Cast a message to all the actors in this mesh

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

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

Cast a message to the actors in this mesh according to the provided selection. This should only be used for temporary support for selections in the tensor engine. If you use this for anything else, you will be fired (you too, OSS contributor).

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

Query the state of all actors in this mesh. If keepalive is Some, use a message that indicates to the recipient that the owner of the mesh is still alive, along with the expiry time after which the actor should be considered orphaned. Else, use a normal state query.

pub fn name(&self) -> &Name

pub fn proc_mesh(&self) -> &ProcMeshRef

pub fn controller(&self) -> &Option<ActorRef<ActorMeshController<A>>>

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

Returns the next supervision event occurring on this mesh. Await this simultaneously with the return result of a message (such as awaiting a reply after a cast) to get back a message that indicates the actor that failed, instead of waiting forever for a reply. If there are multiple simultaneous awaits of next_supervision_event, all of them will receive the same event.

pub fn clone_with_supervision_receiver(&self) -> Self

Same as Clone, but includes a shared supervision receiver. This copy will share the same health state and get the same supervision events. Will have a separate cache.

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.