Struct DistributedRateLimiterState 

pub struct DistributedRateLimiterState {
    pub key: String,
    pub config: RateLimitConfig,
    pub fallback: Arc<RwLock<TokenBucket>>,
}

Distributed rate limiter state

Stores rate limiting state in a distributed backend (e.g., Redis) for coordination across multiple workers.

Fields

key: String

Redis key for storing rate limit state

config: RateLimitConfig

Rate limit configuration

fallback: Arc<RwLock<TokenBucket>>

Local fallback limiter (used if distributed backend is unavailable)

Implementations

impl DistributedRateLimiterState

pub fn new(key: String, config: RateLimitConfig) -> Self

Create a new distributed rate limiter state

Arguments

• key - Redis key for storing rate limit state
• config - Rate limit configuration

pub fn token_key(&self) -> String

Get the Redis key for token count

Used by backend implementations to store token count.

pub fn refill_key(&self) -> String

Get the Redis key for last refill timestamp

Used by backend implementations to store last refill time.

pub fn window_key(&self) -> String

Get the Redis key for sliding window

Used by backend implementations to store sliding window data.

Trait Implementations

impl Clone for DistributedRateLimiterState

fn clone(&self) -> DistributedRateLimiterState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DistributedRateLimiterState

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

Formats the value using the given formatter.