Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Rate limiter for intake events

Implementations

impl RateLimiter

pub fn new( max_per_minute: usize, max_concurrent: usize, backoff_seconds: u64, ) -> Self

Create a new rate limiter

pub fn try_acquire(&self) -> Result<(), u64>

Try to acquire permission to process an event Returns Ok(()) if allowed, Err(backoff_seconds) if rate limited

pub fn release(&self)

Release the permission

pub fn stats(&self) -> RateLimiterStats

Get current stats

Trait Implementations

impl Default for RateLimiter

fn default() -> Self

Returns the “default value” for a type.