Struct RendezvousState 

pub struct RendezvousState { /* private fields */ }

The agreed rendezvous view shared by every worker at a given epoch.

Holds the canonical, sorted membership, the agreed world size and a monotonically increasing version (epoch) that bumps on every membership change. Two coordinators that have accepted the same multiset of events end up with identical membership and world size (the version reflects how many changes were accepted).

Implementations

impl RendezvousState

pub fn new() -> Self

Create the initial, empty rendezvous (version 0, no members).

pub fn version(&self) -> u64

The current rendezvous version (epoch).

pub fn members(&self) -> &[usize]

The current sorted membership (worker ranks).

pub fn world_size(&self) -> usize

The current world size (== members().len()).

pub fn contains(&self, worker_id: usize) -> bool

Whether the given worker rank is currently a member.

Trait Implementations

impl Clone for RendezvousState

fn clone(&self) -> RendezvousState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RendezvousState

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

Formats the value using the given formatter.

impl Default for RendezvousState

fn default() -> RendezvousState

Returns the “default value” for a type.

impl Eq for RendezvousState

impl PartialEq for RendezvousState

fn eq(&self, other: &RendezvousState) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RendezvousState