Struct RateLimitMiddleware 

pub struct RateLimitMiddleware { /* private fields */ }

Rate limiting middleware for PJS endpoints

Uses token bucket algorithm from security::rate_limit module Returns 429 Too Many Requests when limit exceeded Adds X-RateLimit-* headers per RFC 6585

Implementations

impl RateLimitMiddleware

pub fn new(config: RateLimitConfig) -> Self

Build a fresh middleware with its own internal WebSocketRateLimiter.

Spawns a background task that periodically prunes expired per-IP entries (see crate::security::rate_limit::WebSocketRateLimiter::spawn_cleanup_task) if called from within a Tokio runtime; otherwise construction still succeeds, but periodic pruning is skipped with a logged warning.

pub fn from_limiter(limiter: Arc<WebSocketRateLimiter>) -> Self

Wrap an externally constructed WebSocketRateLimiter (lets several middlewares share state).

Spawns a background cleanup task via crate::security::rate_limit::WebSocketRateLimiter::spawn_cleanup_task, which is a no-op if one is already running for this limiter (e.g. because another RateLimitMiddleware already wraps the same Arc).

pub fn with_trusted_proxies(self, config: TrustedProxyConfig) -> Self

Opt in to trusting X-Forwarded-For/X-Real-IP from the given proxy allowlist.

Trait Implementations

impl Clone for RateLimitMiddleware

fn clone(&self) -> RateLimitMiddleware

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Layer<S> for RateLimitMiddleware

type Service = RateLimitService<S>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.