Struct WebSocketRateLimiter 

pub struct WebSocketRateLimiter { /* private fields */ }

Multi-tenant rate limiter with per-key tracking

Implementations

impl WebSocketRateLimiter

pub fn new(config: RateLimiterConfig) -> Self

Create a new rate limiter with the given configuration

pub async fn check_handshake(&self, addr: SocketAddr) -> RateLimitResult

Check if handshake is allowed from the given IP

pub async fn check_connection_for_subject( &self, subject: &str, ) -> RateLimitResult

Check if connection is allowed for the given subject

pub async fn check_connection_for_metering_key( &self, metering_key: &str, ) -> RateLimitResult

Check if connection is allowed for the given metering key

pub async fn check_subscription(&self, client_id: Uuid) -> RateLimitResult

Check if subscription is allowed for the given connection

pub async fn check_message(&self, client_id: Uuid) -> RateLimitResult

Check if message is allowed for the given connection

pub async fn check_snapshot(&self, client_id: Uuid) -> RateLimitResult

Check if snapshot is allowed for the given connection

pub async fn cleanup_stale_buckets(&self)

Clean up stale buckets to prevent memory growth

pub async fn remove_client_buckets(&self, client_id: Uuid)

Remove all rate limit buckets for a disconnected client

pub fn start_cleanup_task(&self)

Start a background task to periodically clean up stale buckets

Trait Implementations

impl Clone for WebSocketRateLimiter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocketRateLimiter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.