Struct ThroughputTracker 

pub struct ThroughputTracker { /* private fields */ }

Throughput tracker.

Implementations

impl ThroughputTracker

pub fn new(interval_duration: Duration, max_intervals: usize) -> Self

Create a new throughput tracker.

pub async fn record_elements(&self, count: u64)

Record elements processed.

pub async fn record_bytes(&self, bytes: u64)

Record bytes processed.

pub async fn record(&self, elements: u64, bytes: u64)

Record both elements and bytes.

pub async fn snapshot(&self)

Take an interval snapshot.

pub async fn elements_per_second(&self) -> f64

Get the overall throughput (elements per second).

pub async fn bytes_per_second(&self) -> f64

Get the overall throughput (bytes per second).

pub async fn average_elements_per_second(&self) -> f64

Get the average throughput over recent intervals.

pub fn interval_duration(&self) -> Duration

Get the configured interval duration.

pub async fn peak_elements_per_second(&self) -> f64

Get the peak throughput.

pub async fn clear(&self)

Clear all counters.

pub async fn reset(&self)

Reset the tracker.