Struct RateLimit 

pub struct RateLimit { /* private fields */ }

Rate limiting middleware

Enforces configurable rate limits per user, IP address, and route. Supports both Redis-backed (distributed) and in-memory (single-instance) storage.

Implementations

impl RateLimit

pub fn new(config: RateLimitConfig, redis_pool: Option<RedisPool>) -> Self

Create a new rate limiting middleware

Arguments

• config - Rate limit configuration
• redis_pool - Optional Redis pool for distributed rate limiting (requires redis feature)

Example

use acton_htmx::middleware::rate_limit::RateLimit;
use acton_htmx::config::RateLimitConfig;

let config = RateLimitConfig::default();

#[cfg(feature = "redis")]
let redis_pool = acton_htmx::database::redis::create_pool("redis://localhost:6379").await?;

#[cfg(feature = "redis")]
let rate_limit = RateLimit::new(config, Some(redis_pool));

#[cfg(not(feature = "redis"))]
let rate_limit = RateLimit::new(config, None);

pub async fn middleware( __arg0: State<Self>, request: Request, next: Next, ) -> Result<Response, RateLimitError>

Middleware function to enforce rate limits

This middleware:

1. Extracts user ID from session (if authenticated) or IP address
2. Checks if request path matches strict route patterns
3. Applies appropriate rate limit (per-user, per-IP, or per-route)
4. Returns 429 Too Many Requests if limit exceeded

Errors

Returns [RateLimitError::TooManyRequests] if the rate limit is exceeded. Returns [RateLimitError::Redis] if Redis operations fail (when using Redis feature).

pub async fn cleanup_expired(&self) -> usize

Cleanup expired entries from in-memory store

Should be called periodically to prevent memory leaks. Returns the number of entries removed.

Trait Implementations

impl Clone for RateLimit

fn clone(&self) -> RateLimit

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.