Struct RateMeter 

pub struct RateMeter { /* private fields */ }

Exponentially weighted moving average of a byte counter’s rate.

Time-based: the weight of each sample depends on how much wall clock it covers, not on how many samples were taken, so the smoothing has the same time constant at 50 Hz and at one sample a second. The estimate starts at zero and is driven by the samples alone; the first call only records where the counter stood.

Implementations

impl RateMeter

pub const ETA_FLOOR: f64 = 1024.0

Below this the rate is startup noise and an ETA built from it counts down from nonsense; eta_secs reports none instead.

pub fn new(tau_secs: f64) -> Self

A meter that forgets about 63% of the past every tau_secs seconds.

pub fn sample(&mut self, now_secs: f64, done: u64) -> f64

Feed the counter’s value at now_secs and get the smoothed rate back.

A sample that does not advance the clock is ignored, and a counter that went backwards (a retried chunk) reads as zero bytes moved, not as a negative rate.

pub fn rate(&self) -> f64

The smoothed rate in bytes per second.

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

Seconds until remaining bytes arrive at the current rate, once the rate has warmed past ETA_FLOOR.

Trait Implementations

impl Clone for RateMeter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RateMeter

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

Formats the value using the given formatter.

impl PartialEq for RateMeter

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RateMeter