Struct ProcMeshRef

pub struct ProcMeshRef { /* private fields */ }

A reference to a ProcMesh, consisting of a set of ranked ProcRefs, arranged into a region. ProcMeshes are 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 fn name(&self) -> &Name

pub fn host_mesh_name(&self) -> Option<&Name>

pub fn hosts(&self) -> Option<&HostMeshRef>

Returns the HostMeshRef that this ProcMeshRef might be backed by. Returns None if this ProcMeshRef is backed by an Alloc instead of a host mesh.

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 proc_states( &self, cx: &impl Actor, ) -> Result<Option<ValueMesh<State<ProcState>>>>

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.

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

where A::Params: RemoteMessage,

Spawn a ‘service’ actor. Service actors are singletons, using reserved names. The provided name is used verbatim as the actor’s name, and thus it may be persistently looked up by constructing the appropriate name.

Note: avoid using service actors if possible; the mechanism will be replaced by an actor registry.

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

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

Formats the value using the given formatter.

impl From<ProcMeshRef> for ProcMesh

fn from(proc_mesh: ProcMeshRef) -> Self

Converts to this type from the input type.

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