Struct WorkspaceShape 

pub struct WorkspaceShape {
    pub shape: Shape,
    pub dimension: Option<String>,
}

Describe the shape of the workspace.

Fields

shape: Shape

All actors accessing the workspace.

dimension: Option<String>

Starting dimension in the shape denoting all ranks that share the same workspace.

Implementations

impl WorkspaceShape

pub fn owners(&self) -> Result<Shape, ShapeError>

Reduce the shape to contain only the “owners” of the remote workspace

This is relevant when e.g. multiple worker on the same host share a workspace, in which case, we’ll reduce the share to only contain one worker per workspace, so that we don’t have multiple workers trying to sync to the same workspace at the same time.

pub fn downstream(&self, rank: usize) -> Result<Shape>

Return a new shape that contains all ranks that share the same workspace with the given “owning” rank.

Errors

Returns an error if the given rank’s coordinates aren’t all zero starting at the specified dimension and continuing until the end. For example, if the dimension is Some(“host”), then the coordinates for the rank must be 0 in the host dimension and all subsequent dimensions.

Trait Implementations

impl Clone for WorkspaceShape

fn clone(&self) -> WorkspaceShape

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkspaceShape

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkspaceShape

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkspaceShape

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

where __S: Serializer,

Serialize this value into the given Serde serializer.