Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Rate limiter using PostgreSQL for state storage.

Implements token bucket algorithm with atomic updates.

Implementations

impl RateLimiter

pub fn new(pool: PgPool) -> Self

Create a new rate limiter.

pub async fn check( &self, bucket_key: &str, config: &RateLimitConfig, ) -> Result<RateLimitResult>

Check rate limit for a bucket key.

pub fn build_key( &self, key_type: RateLimitKey, action_name: &str, auth: &AuthContext, request: &RequestMetadata, ) -> String

Build a bucket key for the given parameters.

pub async fn enforce( &self, bucket_key: &str, config: &RateLimitConfig, ) -> Result<RateLimitResult>

Check rate limit and return an error if exceeded.

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

Reset a rate limit bucket.

pub async fn cleanup(&self, older_than: DateTime<Utc>) -> Result<u64>

Clean up old rate limit entries.