Struct DistributedRateLimiter 

pub struct DistributedRateLimiter { /* private fields */ }

Distributed rate limiter

Uses DistributedBackend to implement cross-instance shared fixed window rate limiting. Suitable for multi-instance deployment scenarios.

Implementations

impl DistributedRateLimiter

pub fn new( backend: Arc<dyn DistributedBackend>, max_requests: u64, window_secs: u64, ) -> DistributedRateLimiter

Creates a distributed rate limiter

• backend: distributed backend (e.g., InMemoryBackend)
• max_requests: maximum number of requests allowed within each window
• window_secs: window size (seconds)

pub fn in_memory(max_requests: u64, window_secs: u64) -> DistributedRateLimiter

Creates a distributed rate limiter using an in-memory backend (convenience method)

Trait Implementations

impl RateLimiter for DistributedRateLimiter

fn acquire(&self, key: &str) -> Result<RateLimitResult, RateLimitError>

fn try_acquire(&self, key: &str) -> Result<RateLimitResult, RateLimitError>

fn reset(&self, key: &str) -> Result<(), RateLimitError>