Struct RequestRateAggregator 

pub struct RequestRateAggregator { /* private fields */ }

Aggregator over the most recent window per-request snapshots.

Thread-safe via an internal mutex.

Implementations

impl RequestRateAggregator

pub fn new() -> Self

Create an aggregator with the default window of 256 requests.

pub fn with_window(window: usize) -> Self

Create an aggregator with a custom window size (clamped to >= 1).

pub fn record(&self, snap: RequestRateSnapshot)

Record a completed request’s snapshot.

pub fn snapshot(&self) -> AggregateRateSnapshot

Compute the workload-level snapshot from the current window.

pub fn completed(&self) -> u64

Number of requests recorded since construction (not capped by window).

pub fn clear(&self)

Drop all recorded samples. Counters are not reset.

Trait Implementations

impl Debug for RequestRateAggregator

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

Formats the value using the given formatter.

impl Default for RequestRateAggregator

fn default() -> Self

Returns the “default value” for a type.