Enum AggregationStrategy 

pub enum AggregationStrategy {
    Synchronous,
    Asynchronous {
        staleness_threshold: u64,
    },
    FederatedAverage {
        rounds: u32,
    },
    GossipAverage {
        fanout: usize,
    },
}

Determines how and when pending updates are aggregated.

Variants

Synchronous

Classic barrier: all active workers must submit at the current step before any aggregation can proceed.

Asynchronous

Asynchronous aggregation: updates within staleness_threshold steps of the current step are accepted; older updates are rejected.

Fields

staleness_threshold: u64

Maximum number of steps behind the global step that a worker may be.

FederatedAverage

Aggregate every time at least rounds worker updates have accumulated for a layer (federated learning style).

Fields

rounds: u32

Minimum number of updates needed before aggregation.

GossipAverage

Aggregate when at least fanout updates are available (gossip style).

Fields

fanout: usize

Minimum number of updates needed before aggregation.

Trait Implementations

impl Clone for AggregationStrategy

fn clone(&self) -> AggregationStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggregationStrategy

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

Formats the value using the given formatter.