Struct WebSocketRateLimiter 

pub struct WebSocketRateLimiter { /* private fields */ }

Rate limiter for WebSocket connections

Implementations

impl WebSocketRateLimiter

pub fn new(config: RateLimitConfig) -> Self

Create new rate limiter with configuration

pub fn check_request(&self, ip: IpAddr) -> Result<(), RateLimitError>

Check if request is allowed (HTTP upgrade to WebSocket)

pub fn check_connection(&self, ip: IpAddr) -> Result<(), RateLimitError>

Check if new connection is allowed

pub fn close_connection(&self, ip: IpAddr)

Register connection close

pub fn check_message( &self, ip: IpAddr, frame_size: usize, ) -> Result<(), RateLimitError>

Check if WebSocket message is allowed

pub fn get_stats(&self) -> RateLimitStats

Get current statistics for monitoring

pub fn cleanup_expired(&self)

Clean up expired entries (call periodically)

Trait Implementations

impl Debug for WebSocketRateLimiter

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

Formats the value using the given formatter.

impl Default for WebSocketRateLimiter

fn default() -> Self

Returns the “default value” for a type.