Struct StrictRateLimiter 

pub struct StrictRateLimiter { /* private fields */ }

Strict rate limiter backed entirely by PostgreSQL.

Every check round-trips to PG, so limits are cluster-wide correct at the cost of one query per rate-limited request. Right for billing-grade quotas; for DDoS protection prefer HybridRateLimiter.

Implements token bucket algorithm with atomic updates.

Implementations

impl StrictRateLimiter

pub fn new(pool: PgPool) -> Self

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

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

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

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

Trait Implementations

impl RateLimiterBackend for StrictRateLimiter

fn check<'a>( &'a self, bucket_key: &'a str, config: &'a RateLimitConfig, ) -> Pin<Box<dyn Future<Output = Result<RateLimitResult>> + Send + 'a>>

Check whether a single token is available for the given bucket.

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

Build the bucket key string for a (key kind, action, auth, request) tuple.

fn enforce<'a>( &'a self, bucket_key: &'a str, config: &'a RateLimitConfig, ) -> Pin<Box<dyn Future<Output = Result<RateLimitResult>> + Send + 'a>>

Check and convert a denial into a ForgeError::RateLimitExceeded.