Struct DistributedCoordinator 

pub struct DistributedCoordinator { /* private fields */ }

Coordinator for all distributed ML operations

Implementations

impl DistributedCoordinator

pub fn new(config: DistributedConfig) -> Self

Create a new coordinator

pub fn initialize(&mut self) -> DistributedResult<()>

Initialize the coordinator

pub fn is_enabled(&self) -> bool

Check if distributed mode is enabled

pub fn moe(&self) -> Option<&DistributedMoE>

Get the MoE layer

pub fn moe_mut(&mut self) -> Option<&mut DistributedMoE>

Get the MoE layer mutably

pub fn averager(&self) -> Option<&DecentralizedAverager>

Get the averager

pub fn averager_mut(&mut self) -> Option<&mut DecentralizedAverager>

Get the averager mutably

pub fn is_running(&self) -> bool

Check if coordinator is running

pub fn stop(&mut self)

Stop the coordinator

Trait Implementations

impl Default for DistributedCoordinator

fn default() -> Self

Returns the “default value” for a type.