Struct EgressMeter 

pub struct EgressMeter { /* private fields */ }

Cumulative delivered bytes plus the last computed EWMA rate. All state is atomic, so record stays off any lock on the hot delivery path.

Implementations

impl EgressMeter

pub fn new() -> Self

An unseeded meter. The first Self::sample seeds the EWMA rather than reporting a rate against an unknown baseline.

pub fn record(&self, bytes: u64)

Add bytes of delivered content to the running total. Called per chunk with the same length billed as delivered (bao content plus proof).

pub fn sample(&self, interval_secs: u64) -> u64

Fold the bytes delivered since the last call into the EWMA and return the new bytes/sec. interval_secs is the fixed tick period; 0 is a no-op that returns the prior rate.

pub fn current_bps(&self) -> u64

The most recently computed bytes/sec, read on the admission hot path.

Trait Implementations

impl Debug for EgressMeter

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

Formats the value using the given formatter.

impl Default for EgressMeter

fn default() -> Self

Returns the “default value” for a type.