Struct DistConfig 

pub struct DistConfig {
    pub rank: u32,
    pub world_size: u32,
    pub mode: ParallelMode,
    pub backend: TransportBackend,
    pub peers: Vec<SocketAddr>,
}

A fully-resolved launch configuration for one process.

Fields

rank: u32

world_size: u32

mode: ParallelMode

backend: TransportBackend

peers: Vec<SocketAddr>

Implementations

impl DistConfig

pub fn from_hostfile( hostfile: &Hostfile, rank: u32, mode: ParallelMode, ) -> Result<Self>

Build a config from a hostfile + this process’s rank.

pub fn load( hostfile_path: impl AsRef<Path>, rank: Option<u32>, mode: ParallelMode, ) -> Result<Self>

Load hosts.json and build the config in one step. rank falls back to the RLX_RANK env var when None.

pub fn connect(&self) -> Result<ProcessGroup>

Establish the network mesh and return the process group. Blocks until every peer has connected.

Trait Implementations

impl Clone for DistConfig

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 DistConfig

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

Formats the value using the given formatter.