Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Main rate limiter

Implementations

impl RateLimiter

pub fn new(config: RateLimitConfig) -> Self

Create a new rate limiter

pub fn with_cost_estimator( config: RateLimitConfig, estimator: QueryCostEstimator, ) -> Self

Create with custom cost estimator

pub fn check(&self, key: &LimiterKey, cost: u32) -> RateLimitResult

Check rate limit for a key

pub fn check_with_priority( &self, key: &LimiterKey, cost: u32, priority: PriorityLevel, ) -> RateLimitResult

Check rate limit with priority

pub fn check_concurrency( &self, key: &LimiterKey, ) -> Result<Arc<ConcurrencyLimiter>, RateLimitExceeded>

Check and acquire concurrency slot

pub fn check_query(&self, key: &LimiterKey, query: &str) -> RateLimitResult

Check for a query with automatic cost estimation

pub fn check_query_with_priority( &self, key: &LimiterKey, query: &str, priority: PriorityLevel, ) -> RateLimitResult

Check query with priority

pub fn check_all(&self, keys: &[LimiterKey], cost: u32) -> RateLimitResult

Check multiple keys (returns first failure)

pub fn reset(&self, key: &LimiterKey)

Reset limits for a key

pub fn get_key_stats(&self, key: &LimiterKey) -> HashMap<String, u64>

Get current stats for a key

pub fn metrics(&self) -> Arc<RateLimitMetrics>

Get metrics

pub fn uptime(&self) -> Duration

Get uptime

pub fn update_config(&self, config: RateLimitConfig)

Update configuration

pub fn config(&self) -> RateLimitConfig

Get current configuration (cloned)

pub fn cleanup(&self)

Clean up expired entries

Trait Implementations

impl Debug for RateLimiter

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

Formats the value using the given formatter.