Struct PhaseEstimator 

pub struct PhaseEstimator { /* private fields */ }

Tracks the producer’s arrival cadence from the consumer side.

Implementations

impl PhaseEstimator

pub fn new(cfg: PhaseConfig) -> Self

pub fn record(&mut self, now: Instant)

Record an arrival observed at now. O(1); updates the period EWMA, the CV, the sample count, and the engaged state (with hysteresis).

pub fn predict_next(&self) -> Option<Instant>

Predicted timestamp of the next arrival, or None if no period is known yet.

pub fn engaged(&self) -> bool

Whether prediction is currently engaged (regular enough cadence, enough samples).

pub fn period(&self) -> Option<Duration>

Current EWMA period estimate.

pub fn cv(&self) -> f64

Current coefficient-of-variation estimate.

pub fn samples(&self) -> u64

Number of inter-arrivals observed.