Struct RedisRateLimiter 

pub struct RedisRateLimiter { /* private fields */ }

Available on crate features resilience and resilience-redis only.

Redis-backed sliding window rate limiter.

Uses Redis sorted sets to implement a sliding window rate limiter that works across distributed deployments.

Algorithm

Uses the sliding window log algorithm:

1. Remove timestamps older than the window
2. Count remaining timestamps
3. If under limit, add current timestamp
4. Return allow/deny

Features

• Distributed: Works across multiple instances
• Sliding window: More accurate than fixed windows
• Auto-cleanup: Old entries are automatically removed

Implementations

impl RedisRateLimiter

pub async fn new( redis_url: &str, max_requests: u32, window_seconds: u64, ) -> Result<Self, RedisRateLimiterError>

Create a new Redis rate limiter.

Arguments

• redis_url - Redis connection URL (e.g., “redis://localhost:6379”)
• max_requests - Maximum requests per window
• window_seconds - Window duration in seconds

pub async fn with_config( redis_url: &str, config: RedisRateLimiterConfig, ) -> Result<Self, RedisRateLimiterError>

Create a new Redis rate limiter with custom configuration.

pub fn from_connection( conn: ConnectionManager, config: RedisRateLimiterConfig, ) -> Self

Create from an existing Redis connection manager.

pub async fn check(&self, key: &str) -> Result<u32, RateLimitError>

Check if a request for the given key is allowed.

Returns Ok(remaining) with the number of remaining requests if allowed, or Err(RateLimitError) if rate limited.

pub async fn get_count(&self, key: &str) -> Result<u32, RedisRateLimiterError>

Get the current count for a key without incrementing.

pub async fn get_remaining( &self, key: &str, ) -> Result<u32, RedisRateLimiterError>

Get remaining requests for a key.

pub async fn reset(&self, key: &str) -> Result<(), RedisRateLimiterError>

Reset the rate limit for a key.

pub fn config(&self) -> &RedisRateLimiterConfig

Get the configuration.