Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Token bucket rate limiter.

Prevents thundering herd by limiting the rate of operations. Thread-safe and async-aware.

Example

use replication_engine::resilience::{RateLimiter, RateLimitConfig};
let limiter = RateLimiter::new(RateLimitConfig::default());

// In hot path loop:
let events = vec![1, 2, 3];
for event in events {
    limiter.acquire().await; // Blocks if over limit
    // process(event);
}

Implementations

impl RateLimiter

pub fn new(config: RateLimitConfig) -> Self

Create a new rate limiter with the given configuration.

pub async fn acquire(&self)

Acquire a permit, blocking until one is available.

This method is cancel-safe.

pub fn try_acquire(&self) -> bool

Try to acquire a permit without blocking.

Returns true if acquired, false if rate limit exceeded.

pub async fn acquire_many(&self, n: u32)

Acquire multiple permits at once.

Useful for batched operations where you want to rate limit the batch as a whole rather than each item.

pub fn config(&self) -> &RateLimitConfig

Get the current configuration.