Struct ProcMesh

pub struct ProcMesh { /* private fields */ }

A ProcMesh maintains a mesh of procs whose lifecycles are managed by an allocator.

Implementations

impl ProcMesh

pub async fn allocate( alloc: impl Alloc + Send + Sync + 'static, ) -> Result<Self, AllocatorError>

pub async fn allocate_boxed( alloc: Box<dyn Alloc + Send + Sync>, ) -> Result<Self, AllocatorError>

Allocate a new ProcMesh from the provided allocator. Allocate returns after the mesh has been successfully (and fully) allocated, returning early on any allocation failure.

pub async fn spawn<A: Actor + RemoteActor>( &self, actor_name: &str, params: &A::Params, ) -> Result<RootActorMesh<'_, A>, Error>

where A::Params: RemoteMessage,

Spawn an ActorMesh by launching the same actor type on all agents, using the same parameters instance for every actor.

• actor_name: Name for all spawned actors.
• params: Reference to the parameter struct, reused for all actors.

pub fn client(&self) -> &Mailbox

A client used to communicate with any member of this mesh.

pub fn client_proc(&self) -> &Proc

pub fn proc_id(&self) -> &ProcId

pub fn world_id(&self) -> &WorldId

pub fn events(&mut self) -> Option<ProcEvents>

An event stream of proc events. Each ProcMesh can produce only one such stream, returning None after the first call.

pub fn shape(&self) -> &Shape

pub async fn stop_actor_by_name(&self, mesh_name: &str) -> Result<(), Error>

Send stop actors message to all mesh agents for a specific mesh name

Trait Implementations

impl Debug for ProcMesh

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

Formats the value using the given formatter.

impl Display for ProcMesh

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

Formats the value using the given formatter.

impl Mesh for ProcMesh

type Node = ProcId

The type of the node contained in the mesh.

type Id = ProcMeshId

The type of identifiers for this mesh.

type Sliced<'a> = SlicedProcMesh<'a>

The type of a slice of this mesh. Slices should not outlive their parent mesh.

fn shape(&self) -> &Shape

The shape of this mesh.

fn select<R: Into<Range>>( &self, label: &str, range: R, ) -> Result<Self::Sliced<'_>, ShapeError>

Sub-slice this mesh, specifying the included ranges for the dimension with the labeled name.

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

Retrieve contained node at the provided index. The index is relative to the shape of the mesh.

fn id(&self) -> Self::Id

The global identifier for this mesh.

fn iter(&self) -> MeshIter<'_, Self>

Iterate over all the nodes in this mesh.