Struct PeerLatencyPredictor 

pub struct PeerLatencyPredictor {
    pub states: HashMap<String, PeerLatencyState>,
    pub config: PredictorConfig,
    pub total_samples: u64,
}

Tracks per-peer RTT samples and provides latency predictions.

Fields

states: HashMap<String, PeerLatencyState>

Per-peer state keyed by peer ID string.

config: PredictorConfig

Predictor configuration.

total_samples: u64

Cumulative sample count across all peers.

Implementations

impl PeerLatencyPredictor

pub fn new(config: PredictorConfig) -> Self

Creates a new predictor with the given configuration.

pub fn record_sample(&mut self, sample: LatencySample)

Records a latency sample for a peer, updating EWMA and variance.

On the first sample for a peer the EWMA is initialised to the observed RTT and the variance to 0.0. Subsequent samples update via:

ewma      = alpha * rtt + (1 - alpha) * ewma
deviation = rtt - ewma          (post-update deviation)
variance  = beta * deviation^2 + (1 - beta) * variance

pub fn predict(&self, peer_id: &str) -> Option<f64>

Returns the predicted RTT for peer_id, or None if unknown.

pub fn evict_stale(&mut self, now_secs: u64) -> usize

Removes peers whose last sample is older than now_secs - stale_threshold_secs.

Returns the number of peers evicted.

pub fn best_peers(&self, n: usize) -> Vec<&str>

Returns peer IDs of the n peers with the lowest predicted RTT, in ascending order (best first).

If n exceeds the number of tracked peers, all are returned.

pub fn stats(&self) -> PredictorStats

Returns a snapshot of predictor statistics.

Trait Implementations

impl Debug for PeerLatencyPredictor

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

Formats the value using the given formatter.