Struct HostMeshRef

pub struct HostMeshRef { /* private fields */ }

A non-owning reference to a mesh of hosts.

Logically, this is a data structure that contains a set of ranked hosts organized into a Region. HostMeshRefs can be sliced to produce new references that contain a subset of the hosts in the original mesh.

HostMeshRefs have a concrete syntax, implemented by its Display and FromStr implementations.

This type does not control lifecycle. It only describes the topology of hosts. To take ownership and perform deterministic teardown, use HostMesh::take, which returns an owned HostMesh that guarantees cleanup on shutdown() or Drop.

Cloning this type does not confer ownership. If a corresponding owned HostMesh shuts down the hosts, operations via a cloned HostMeshRef may fail because the hosts are no longer running.

Implementations

impl HostMeshRef

pub fn from_hosts(hosts: Vec<ChannelAddr>) -> Self

Create a new HostMeshRef from an arbitrary set of hosts. This is meant to enable extrinsic bootstrapping.

pub async fn spawn( &self, cx: &impl Actor, name: &str, per_host: Extent, ) -> Result<ProcMesh>

Spawn a ProcMesh onto this host mesh. The per_host extent specifies the shape of the procs to spawn on each host.

Currently, spawn issues direct calls to each host agent. This will be fixed by maintaining a comm actor on the host service procs themselves.

Trait Implementations

impl Clone for HostMeshRef

fn clone(&self) -> HostMeshRef

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HostMeshRef

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HostMeshRef

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for HostMeshRef

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

Formats the value using the given formatter.

impl FromStr for HostMeshRef

type Err = HostMeshRefParseError

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl Hash for HostMeshRef

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 HostMeshRef

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 HostMeshRef

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

type Item = HostRef

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 HostMeshRef

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 HostMeshRef

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 HostMeshRef

impl StructuralPartialEq for HostMeshRef