Struct AggregationEngine 

pub struct AggregationEngine {
    pub strategy: AggregationStrategy,
    pub parameters: HashMap<String, f64>,
    pub weighting_scheme: WeightingScheme,
    pub outlier_detection: OutlierDetection,
}

Aggregation engine for combining local updates

Fields

strategy: AggregationStrategy

Aggregation strategy

parameters: HashMap<String, f64>

Aggregation parameters

weighting_scheme: WeightingScheme

Weighting scheme

outlier_detection: OutlierDetection

Outlier detection

Implementations

impl AggregationEngine

pub fn new(strategy: AggregationStrategy) -> Self

Create new aggregation engine

pub fn with_weighting_scheme(self, scheme: WeightingScheme) -> Self

Configure weighting scheme

pub fn with_outlier_detection(self, detection: OutlierDetection) -> Self

Configure outlier detection

pub fn aggregate_updates( &self, updates: &[LocalUpdate], ) -> Result<HashMap<String, Array2<f32>>>

Aggregate local updates from participants

Trait Implementations

impl Clone for AggregationEngine

fn clone(&self) -> AggregationEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggregationEngine

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AggregationEngine

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AggregationEngine

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.