Struct ActorMeshRef 

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

A reference to a stable snapshot of an ActorMesh.

Implementations

impl<A: Referable> 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 ActorMeshRef<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Referable> Debug for ActorMeshRef<A>

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

Formats the value using the given formatter.

impl<'de, A: Referable> Deserialize<'de> for ActorMeshRef<A>

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

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

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

Formats the value using the given formatter.

impl<A: Referable> Hash for ActorMeshRef<A>

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<A: Referable> PartialEq for ActorMeshRef<A>

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<A: Referable> Ranked for ActorMeshRef<A>

type Item = ActorRef<A>

The type of item in this view.

fn region(&self) -> &Region

The ranks contained in this view.

fn get(&self, rank: usize) -> Option<&Self::Item>

Return the item at rank

impl<A: Referable> RankedSliceable for ActorMeshRef<A>

fn sliced(&self, region: Region) -> Self

Construct a new Ranked containing the ranks in this view that are part of region. The caller guarantees that region.is_subset(self.region()).

impl<A: Referable> Registrable for ActorMeshRef<A>

fn kind() -> MeshKind

The kind of mesh this type represents.

impl<A: Referable> Serialize for ActorMeshRef<A>

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl<A: Referable> Eq for ActorMeshRef<A>