Trait TlDistributedExecutor 

pub trait TlDistributedExecutor {
    // Required methods
    fn distributed_executor(&self) -> Option<&DistributedExecutor>;
    fn enable_distributed(
        &mut self,
        config: DistributedConfig,
    ) -> Result<(), ExecutorError>;
    fn disable_distributed(&mut self);
    fn is_distributed(&self) -> bool;

    // Provided methods
    fn rank(&self) -> usize { ... }
    fn world_size(&self) -> usize { ... }
}

Trait for executors that support distributed execution.

Required Methods

fn distributed_executor(&self) -> Option<&DistributedExecutor>

Get the distributed executor.

fn enable_distributed( &mut self, config: DistributedConfig, ) -> Result<(), ExecutorError>

Enable distributed execution.

fn disable_distributed(&mut self)

Disable distributed execution.

fn is_distributed(&self) -> bool

Check if distributed execution is enabled.

Provided Methods

fn rank(&self) -> usize

Get the current rank.

fn world_size(&self) -> usize

Get the world size.

Implementors