Struct FederatedAveragingState 

pub struct FederatedAveragingState {
    pub peer_gradients: HashMap<usize, Array1<f64>>,
    pub peer_weights: HashMap<usize, f64>,
    pub peer_data_counts: HashMap<usize, usize>,
    pub last_updates: HashMap<usize, Instant>,
    pub federated_round: usize,
    pub staleness_tolerance: Duration,
}

Federated averaging state

Fields

peer_gradients: HashMap<usize, Array1<f64>>

Accumulated gradients from peers

peer_weights: HashMap<usize, f64>

Weights for federated averaging

peer_data_counts: HashMap<usize, usize>

Data counts from peers

last_updates: HashMap<usize, Instant>

Last update timestamps

federated_round: usize

Federated round number

staleness_tolerance: Duration

Staleness tolerance

Implementations

impl FederatedAveragingState

pub fn new() -> Self

pub fn add_peer_gradient( &mut self, peer_id: usize, gradient: Array1<f64>, datacount: usize, )

Add gradient from a peer node

pub fn compute_federated_gradient( &self, currenttime: Instant, ) -> Option<Array1<f64>>

Compute federated average gradient

Trait Implementations

impl Clone for FederatedAveragingState

fn clone(&self) -> FederatedAveragingState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FederatedAveragingState

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

Formats the value using the given formatter.

impl Default for FederatedAveragingState

fn default() -> Self

Returns the “default value” for a type.