Struct RateLimitManager 

pub struct RateLimitManager { /* private fields */ }

Main rate limit manager

Implementations

impl RateLimitManager

pub fn new(config: &RateLimitConfig) -> Self

Create a new rate limit manager

pub fn with_pow_config(config: &RateLimitConfig, pow_config: PowConfig) -> Self

Create with custom PoW config

pub fn check(&self, addr: &IpAddr, category: &str) -> Result<(), RateLimitError>

Check if a request should be rate limited

pub fn check_skip_ban( &self, addr: &IpAddr, category: &str, ) -> Result<(), RateLimitError>

Check rate limits for a request WITHOUT consulting the global ban list.

Behaves exactly like Self::check minus the ban gate. Used by routes that must remain reachable from a banned IP (e.g. the password-recovery flow) while still being subject to the normal per-category rate limit.

Trait Implementations

impl Default for RateLimitManager

fn default() -> Self

Returns the “default value” for a type.

impl RateLimitApi for RateLimitManager

fn get_status( &self, addr: &IpAddr, category: &str, ) -> ClResult<Vec<(AddressKey, RateLimitStatus)>>

Query current limit status for an address at all hierarchical levels

fn penalize( &self, addr: &IpAddr, reason: PenaltyReason, amount: u32, ) -> ClResult<()>

Manually consume quota (increase usage) - e.g., after auth failure

fn grant(&self, addr: &IpAddr, amount: u32) -> ClResult<()>

Decrease penalty count (grant extra quota) - e.g., after successful CAPTCHA

fn reset(&self, addr: &IpAddr) -> ClResult<()>

Reset limits for an address at all levels

fn ban( &self, addr: &IpAddr, duration: Duration, reason: PenaltyReason, ) -> ClResult<()>

Temporarily ban an address (all hierarchical levels)

fn unban(&self, addr: &IpAddr) -> ClResult<()>

Unban an address

fn is_banned(&self, addr: &IpAddr) -> bool

Check if an address is banned

fn list_bans(&self) -> Vec<BanEntry>

List all currently banned addresses

fn stats(&self) -> RateLimiterStats

Get statistics about rate limiter state

fn get_pow_requirement(&self, addr: &IpAddr) -> u32

Get current PoW requirement for address (max of individual + network level)

fn increment_pow_counter( &self, addr: &IpAddr, reason: PowPenaltyReason, ) -> ClResult<()>

Increment PoW counter for address

fn decrement_pow_counter(&self, addr: &IpAddr, amount: u32) -> ClResult<()>

Decrement PoW counter (after successful CONN, with decay over time)

fn verify_pow(&self, addr: &IpAddr, token: &str) -> Result<(), PowError>

Verify proof-of-work on action token