Struct RequestRateTracker 

pub struct RequestRateTracker { /* private fields */ }

Per-request rate tracker.

Not thread-safe — intended to be owned by a single request handler. Callers needing concurrent access should wrap in a Mutex.

Implementations

impl RequestRateTracker

pub fn new() -> Self

Create a tracker with default settings (window = 128 TBT samples, alpha = 0.20).

pub fn with_params(tbt_capacity: usize, alpha: f64) -> Self

Create a tracker with custom parameters.

tbt_capacity is clamped to at least 1; alpha is clamped to [0.0, 1.0].

pub fn record_admission(&mut self)

Mark the request as admitted (e.g. dequeued from the request queue).

pub fn record_first_token(&mut self)

Mark the first token as emitted. This implicitly counts the token, so callers should not also call record_token for the first token.

pub fn record_token(&mut self)

Mark a subsequent (non-first) token as emitted.

If record_first_token was never called, this also doubles as the first-token marker.

pub fn snapshot(&self) -> RequestRateSnapshot

Take a snapshot of the current state without disturbing the tracker.

pub fn queue_wait_seconds(&self) -> Option<f64>

Queue wait time (admission → first token), if both are recorded.

pub fn tokens_emitted(&self) -> u64

Number of tokens emitted so far.

pub fn tokens_per_second(&self) -> f64

EMA-smoothed tokens per second.

Trait Implementations

impl Clone for RequestRateTracker

fn clone(&self) -> RequestRateTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestRateTracker

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

Formats the value using the given formatter.

impl Default for RequestRateTracker

fn default() -> Self

Returns the “default value” for a type.