Struct RollingRate 

pub struct RollingRate { /* private fields */ }

Rolling-window rate tracker.

The producer records completion counts (typically 1 per ItemIndexed / ItemSkipped / ItemFailed) and queries Self::rate_per_sec or Self::eta_secs when emitting a IndexEvent::StatsTick. The window is purely time-based: samples older than window_size are evicted on every observation.

Implementations

impl RollingRate

pub fn new(window_size: Duration) -> Self

Create a new tracker with the given rolling window.

pub fn record(&mut self, count: usize)

Record count completions at the current instant.

pub fn rate_per_sec(&self) -> f64

Current rate in items/sec over the rolling window.

Returns 0.0 if there is fewer than two observations or the window spans less than 1ms (avoids division-by-near-zero blow-ups).

pub fn eta_secs(&self, remaining: usize) -> Option<f64>

ETA in seconds for remaining items at the current rate.

Returns None if the rate is zero (cannot extrapolate) or remaining is zero (nothing to wait for).

Trait Implementations

impl Clone for RollingRate

fn clone(&self) -> RollingRate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RollingRate

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

Formats the value using the given formatter.