Struct ProcMeshRef

pub struct ProcMeshRef { /* private fields */ }

A reference to a ProcMesh, consisting of a set of ranked ProcRefs, arranged into a region. ProcMeshes named, uniquely identifying the ProcMesh from which the reference was derived.

ProcMeshes can be sliced to create new ProcMeshes with a subset of the original ranks.

Implementations

impl ProcMeshRef

pub async fn status(&self, cx: &impl Actor) -> Result<ValueMesh<bool>>

The current statuses of procs in this mesh.

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

The supervision events of procs in this mesh.

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

where A::Params: RemoteMessage,

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.

Trait Implementations

impl Clone for ProcMeshRef

fn clone(&self) -> ProcMeshRef

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcMeshRef

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcMeshRef

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for ProcMeshRef

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 Named for ProcMeshRef

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

The globally unique port for this type. Typed ports are in the range of 1<<63..1<<64-1.

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl PartialEq for ProcMeshRef

fn eq(&self, other: &ProcMeshRef) -> 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 Ranked for ProcMeshRef

type Item = ProcRef

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 RankedSliceable for ProcMeshRef

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 Serialize for ProcMeshRef

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ProcMeshRef

impl StructuralPartialEq for ProcMeshRef