Struct Members 

pub struct Members { /* private fields */ }

The sorted, de-duplicated set of a run’s workers, plus this process’s own index. Sorting makes the assignment independent of the order workers happened to join in — the invariant owner_of relies on.

Implementations

impl Members

pub fn solo() -> Self

A single-worker run — the default when there is no --join. Byte-for-byte the pre-Phase-4 behaviour: one worker owns every task, and the fingerprint clause is empty.

pub fn new(workers: Vec<String>, my_addr: &str) -> Result<Self, String>

From a membership list (in any order) and this process’s own address. The list is sorted and de-duplicated; me is this address’s index in the sorted set. Errors if my_addr is not in the set (a worker must be a member of the run it joins).

pub fn len(&self) -> usize

The number of workers in the run.

pub fn is_empty(&self) -> bool

pub fn me(&self) -> WorkerId

This process’s worker id.

pub fn is_solo(&self) -> bool

A run with exactly one worker: every edge is local and there is nothing to coordinate across processes.

pub fn addr(&self, w: WorkerId) -> Option<&str>

The address of worker w (for opening exchange links to peers).

pub fn peers(&self) -> impl Iterator<Item = WorkerId> + '_

Every worker’s id except this one — the peers this worker opens links to.

pub fn fingerprint_clause(&self) -> String

The fingerprint clause for this member set. Empty for a solo run, so a single-worker fingerprint — and every checkpoint written before Phase 4 — is unchanged. For a cluster, the worker count: placement (owner_of) depends only on the number of workers, so a change to it changes every task’s owner and must refuse to restore over the old checkpoint (the D8 fence), while a restart of the same-sized cluster — on whatever addresses/ports — restores cleanly.

Trait Implementations

impl Clone for Members

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Members

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

Formats the value using the given formatter.

impl Eq for Members

impl PartialEq for Members

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Members