Struct RateLimiterPool 

pub struct RateLimiterPool { /* private fields */ }

Thread-safe rate limiter pool managing multiple rate limiters by key

Implementations

impl RateLimiterPool

pub fn new(config: RateLimitConfig) -> Self

Create a new rate limiter pool with the given configuration (local backend)

pub fn check(&self, key: &str) -> RateLimitCheckInfo

Check if a request should be rate limited (synchronous, local only)

Returns detailed rate limit information including remaining quota. For distributed backends, this falls back to local limiting.

pub fn is_distributed(&self) -> bool

Check if this pool uses a distributed backend

pub fn extract_key( &self, client_ip: &str, path: &str, route_id: &str, headers: Option<&impl HeaderAccessor>, ) -> String

Get the rate limit key from request context

pub fn action(&self) -> RateLimitAction

Get the action to take when rate limited

pub fn status_code(&self) -> u16

Get the HTTP status code for rate limit responses

pub fn message(&self) -> Option<String>

Get the custom message for rate limit responses

pub fn max_delay_ms(&self) -> u64

Get the maximum delay in milliseconds for Delay action

pub fn update_config(&self, config: RateLimitConfig)

Update the configuration

pub fn cleanup(&self)

Clean up expired entries (call periodically)