Struct ClusterCfg 

pub struct ClusterCfg {
    pub join: Option<String>,
    pub n_workers: usize,
    pub exchange_bind: String,
    pub control_bind: String,
    pub flows: usize,
    pub window: usize,
}

How this process participates in a run: solo (no clustering), or one worker of a cluster — either the leader (waits for n_workers to register) or a joiner (registers with a leader).

Fields

join: Option<String>

The leader’s control address to join, or None if this process is the leader.

n_workers: usize

The leader’s expected total worker count (the leader waits for this many).

exchange_bind: String

This worker’s exchange listen address (peers connect here). 127.0.0.1:0 (ephemeral) for a same-box run; a routable host:port for multi-node.

control_bind: String

The leader’s control listen address.

flows: usize

Flows per worker pair, and the per-channel credit window in bytes.

window: usize

Implementations

impl ClusterCfg

pub fn parse( join: &str, n_workers: usize, exchange_bind: &str, control_bind: &str, flows: usize, window: usize, ) -> Option<ClusterCfg>

Parse a cluster config from the runner’s settings; None is a solo run (no --join and at most one worker) — the pre-Phase-4 single-process path. A worker (join set) or a leader (n_workers > 1) is clustered.

Trait Implementations

impl Clone for ClusterCfg

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 ClusterCfg

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

Formats the value using the given formatter.

impl Eq for ClusterCfg

impl PartialEq for ClusterCfg

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ClusterCfg