Struct DataActorMesh 

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

The data-only variant of ActorMeshRef: a cheap, detached cast/address surface built directly from actor refs.

Membership is a Region paired with exactly one actor ref per rank. The mesh is identified by the ActorMeshId it was constructed with, which slices and serialized copies keep. It has no remote supervision stream; a caller monitors it on demand via ActorMeshRef::monitor. Multi-member casting uses a bounded-fanout cast domain.

Implementations

impl<A: Referable> DataActorMesh<A>

pub fn try_new( id: ActorMeshId, region: Region, members: Vec<ActorRef<A>>, ) -> Result<Self>

Create a data-only actor mesh named id from a region and its actor refs.

members must hold one ref per rank, in region order. The mesh does not own, stop, or supervise the actors; it is a plain view over the refs.

pub fn id(&self) -> &ActorMeshId

Return the mesh id.

pub fn members(&self) -> &ValueMesh<ActorRef<A>>

Return the dense actor-ref mesh.

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

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

Cast message to every member through a bounded-fanout cast domain.

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

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

Cast message to every member, merging caller_headers into each envelope.

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.

Trait Implementations

impl<A: Referable> Clone for DataActorMesh<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 DataActorMesh<A>

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

Formats the value using the given formatter.

impl<'de, A: Referable> Deserialize<'de> for DataActorMesh<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> Eq for DataActorMesh<A>

impl<A: Referable> Hash for DataActorMesh<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 DataActorMesh<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 DataActorMesh<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 DataActorMesh<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> Serialize for DataActorMesh<A>

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

where S: Serializer,

Serialize this value into the given Serde serializer.