Struct AggregatorSlot 

pub struct AggregatorSlot;

Generic Aggregator slot placeholder. Bind a concrete AggregatorRuntime at compile time via Compiler::new().bind_aggregator::<T>("slot"). Exposes Contribute + Aggregate.

Both ops carry an opaque metadata channel alongside the tensor: Contribute takes (contribution, metadata); Aggregate returns (params, metadata). This is the channel hierarchical aggregation rides on — a child aggregator emits its summed num_samples (or whatever schema the impl uses) so the parent layer’s reduction can weight the child’s contribution correctly.

Implementations

impl AggregatorSlot

pub fn contribute( &self, g: &mut Graph, contribution: Output, metadata: Output, ) -> Output

Contribute(contribution, metadata) -> cmd - Shape 2 (buffer write). metadata is impl-defined bytes (e.g. a sample count for FedAvg); pass an empty Output when the impl has no metadata channel.

pub fn aggregate(&self, g: &mut Graph, trigger: Output) -> (Output, Output)

Aggregate(trigger) -> (params, metadata) - Shape 1 (mean / weighted sum / replace expressible as ai.onnx). The output edge fires only when the reduction completes; downstream consumers read params AND the aggregation’s accompanying metadata (e.g. summed num_samples for hierarchical FedAvg) directly off the op’s two outputs — no separate current_tensor read needed.

Trait Implementations

impl Clone for AggregatorSlot

fn clone(&self) -> AggregatorSlot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for AggregatorSlot

impl Debug for AggregatorSlot

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

Formats the value using the given formatter.

impl Default for AggregatorSlot

fn default() -> AggregatorSlot

Returns the “default value” for a type.