Struct PeerLatencyState 

pub struct PeerLatencyState {
    pub peer_id: String,
    pub ewma_ms: f64,
    pub ewma_variance: f64,
    pub sample_count: u64,
    pub recent_ewmas: Vec<f64>,
    pub last_updated_secs: u64,
}

Per-peer latency tracking state.

Fields

peer_id: String

Identifier of the tracked peer.

ewma_ms: f64

Current EWMA of RTT (milliseconds).

ewma_variance: f64

EWMA of squared deviation from the EWMA (variance proxy for jitter).

sample_count: u64

Number of samples recorded so far.

recent_ewmas: Vec<f64>

Rolling window of the last 5 EWMA values (oldest → newest).

last_updated_secs: u64

Unix timestamp (seconds) of the most recent sample.

Implementations

impl PeerLatencyState

pub fn jitter_ms(&self) -> f64

Returns the estimated jitter in milliseconds (sqrt of EWMA variance).

pub fn predicted_rtt_ms(&self) -> f64

Returns a conservative predicted RTT: EWMA + 0.5 * jitter.

pub fn trend(&self) -> TrendDirection

Infers the latency trend from the rolling EWMA window.

Requires at least 2 values. Splits recent_ewmas into first-half and second-half, comparing their means:

• second > first × 1.05 → Degrading
• second < first × 0.95 → Improving
• otherwise → Stable

Trait Implementations

impl Clone for PeerLatencyState

fn clone(&self) -> PeerLatencyState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeerLatencyState

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

Formats the value using the given formatter.