Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Rate limiting utility for controlling event processing speed.

Implementations

impl RateLimiter

pub fn new(max_rate: u64, window: Duration) -> Self

Create a new rate limiter

pub async fn can_process(&self) -> bool

Check if we can process another event

pub async fn record_event(&self)

Record that an event was processed

pub async fn wait_for_capacity(&self)

Wait until we can process the next event

pub async fn current_rate(&self) -> f64

Get current rate (events per second)

Trait Implementations

impl Debug for RateLimiter

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

Formats the value using the given formatter.