Struct Group 

pub struct Group { /* private fields */ }

A group of processes (MLX’s Group): cheap to clone.

Implementations

impl Group

pub fn single() -> Group

The group of this process alone: every collective is the identity.

pub fn new(comm: Arc<dyn Communicator>) -> Group

A group over comm (a backend’s transport).

pub fn rank(&self) -> usize

This process’s rank in the group.

pub fn size(&self) -> usize

The number of processes in the group.

pub fn close(&self)

Closes the group: its transport (connections, buffers) is released once operations in progress finish, and every later operation on it fails with an error saying it was closed. A group of size 1 is unaffected.

pub fn health(&self) -> Result<(), Error>

Whether every peer is still reachable, checked without running a collective: an error names a lost peer (and the group is then failed), or says the group was closed. It waits for a collective in progress on another thread, never interleaving with it.

pub fn split(&self, color: i32, key: i32) -> Result<Group, Error>

The ranks with the same color as a new group, ordered by key (then by rank), as MLX’s Group.split. Backends may not support it (MLX’s ring does not).

Trait Implementations

impl Clone for Group

fn clone(&self) -> Group

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Group

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

Formats the value using the given formatter.

impl Static for Group

fn hash_static(&self, h: &mut dyn Hasher)

Feeds the value to h.