Trait WeightCompute

pub trait WeightCompute: Send + Sync {
    type Source;

    // Required method
    fn compute(&self, stat_kvs: &Self::Source) -> Vec<WeightedItem<Peer>>;
}

The WeightCompute trait is used to compute the weight array by heartbeats.

Required Associated Types

type Source

Required Methods

fn compute(&self, stat_kvs: &Self::Source) -> Vec<WeightedItem<Peer>>

Implementors

impl WeightCompute for RegionNumsBasedWeightCompute

type Source = HashMap<DatanodeStatKey, DatanodeStatValue>