Struct SecureAggregator 

pub struct SecureAggregator { /* private fields */ }

Server-side aggregator state for a single round.

The aggregator owns no cryptographic key material – every pairwise mask can be recomputed on demand from round_seed. It keeps track of which clients have successfully submitted, which clients are known to have dropped, and cached pairwise masks used during dropout reconstruction.

Implementations

impl SecureAggregator

pub fn new(config: SecureAggregationConfig) -> Result<Self>

Build a new aggregator for one round.

Validates the configuration up front so that downstream operations can assume well-formed values. The dropout safety check requires that the modulus is at least one order of magnitude larger than the nominal quantised value range, which guarantees that the partial masked sum cannot silently wrap.

pub fn receive(&mut self, submission: MaskedGradient) -> Result<()>

Accept a client submission.

Re-submissions from the same client_id overwrite the previous value (later submissions are considered more authoritative). A submission whose vector length does not match the configured dimension is rejected with OptimError::DimensionMismatch.

pub fn mark_dropped(&mut self, client_id: ClientId) -> Result<()>

Mark a client as having dropped out of this round.

Dropped clients are excluded from the aggregated sum but the masks they would have used are still cancelled by the dropout-reconstruction phase of Self::aggregate.

pub fn aggregate(&self) -> Result<Array1<f64>>

Aggregate the received submissions, cancelling any masks belonging to dropped clients.

Returns the dequantised real-valued sum of the received clients’ gradients. Dropped clients contribute nothing to the sum (their gradient is, by definition, never uploaded) but their pairwise masks are still removed so the remaining clients’ uploads telescope correctly.

pub fn reset(&mut self)

Reset the per-round state so the same aggregator can be reused.

pub fn received_count(&self) -> usize

Number of client submissions currently held.

pub fn dropped_count(&self) -> usize

Number of clients currently marked as dropped.

pub fn config(&self) -> &SecureAggregationConfig

Read-only access to the aggregator’s configuration.

Trait Implementations

impl Clone for SecureAggregator

fn clone(&self) -> SecureAggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SecureAggregator

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

Formats the value using the given formatter.