Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Rate limiter for backpressure handling.

Implementations

impl RateLimiter

pub fn new(max_messages: usize, window: Duration) -> Self

Create a new rate limiter.

pub fn check(&mut self, now: u64) -> bool

Check if a message is allowed and record it.

pub fn current_count(&self) -> usize

Get the number of messages in the current window.

pub fn reset(&mut self)

Reset the rate limiter.

pub fn is_at_capacity(&self) -> bool

Check if the limiter is at capacity.

Trait Implementations

impl Debug for RateLimiter

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

Formats the value using the given formatter.

impl Default for RateLimiter

fn default() -> Self

Returns the “default value” for a type.