Struct LatencyEstimator 

pub struct LatencyEstimator { /* private fields */ }

Smoothed endpoint RTT estimates.

The estimator intentionally receives dispatch-to-completion measurements; callers should not feed local queue or pacing delay into it.

Implementations

impl LatencyEstimator

pub fn new(config: LatencyEstimatorConfig) -> Self

Creates a latency estimator with the configured initial RTT.

Panics

Panics when the minimum RTT, initial RTT, EWMA weights, or baseline window is invalid.

pub fn observe(&mut self, sample: Duration)

Observes a dispatch-to-completion RTT using the current clock time.

Use Self::observe_at when deterministic timing is required.

pub fn observe_at(&mut self, sample: Duration, now: Instant)

Observes a dispatch-to-completion RTT at an explicit time.

Samples below LatencyEstimatorConfig::min_rtt are clamped. The explicit time controls rotation of the rolling minimum-RTT window.

pub fn expected_rtt(&self) -> Duration

Returns the long-term RTT used for Little’s Law rate derivation.

pub fn short(&self) -> Duration

Returns the short-term exponentially weighted RTT estimate.

pub fn long(&self) -> Duration

Returns the long-term exponentially weighted RTT estimate.

pub fn baseline(&self) -> Duration

Returns the minimum observed RTT, or the initial estimate before the first successful sample arrives.

pub fn samples(&self) -> u64

Returns the number of RTT samples observed.

Trait Implementations

impl Clone for LatencyEstimator

fn clone(&self) -> LatencyEstimator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LatencyEstimator

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

Formats the value using the given formatter.