Struct RateLimit 

pub struct RateLimit { /* private fields */ }

A per-callsite token bucket: up to capacity events per window, then suppression with a count carried into the first event of the next window.

const-constructible for use in statics. Under a poison storm every pinned pipeline thread hits the same limiter once per failing record, so the exact-accounting mutex is contended. To keep steady-state suppression off the shared lock, a relaxed-atomic fast path short-circuits while the window stays saturated: a single relaxed load of saturated plus a deadline compare, no mutex. The mutex path remains the source of truth for allow decisions and window rolls; suppressed events counted on the fast path are folded back in at the next roll, so the carried suppressed count is exact in practice (best-effort under concurrent rolls).

Implementations

impl RateLimit

pub const fn new(capacity: u32, window: Duration) -> Self

A limiter allowing capacity events per window.

pub fn check(&self) -> Decision

Decide whether to log an event happening now.

pub fn check_at(&self, now: Instant) -> Decision

Decide for an event at now (injectable for tests).

Trait Implementations

impl Debug for RateLimit

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

Formats the value using the given formatter.