Struct ConnectionRateLimiter 

pub struct ConnectionRateLimiter { /* private fields */ }

Connection rate limiter

Implementations

impl ConnectionRateLimiter

pub fn new(config: RateLimiterConfig) -> Self

Create a new connection rate limiter

pub async fn allow_connection(&self, peer_id: &str) -> bool

Check if a connection is allowed

pub async fn allow_connection_with_priority( &self, peer_id: &str, priority: ConnectionPriority, ) -> bool

Check if a connection is allowed with specific priority

pub fn record_success(&self, peer_id: &str)

Record a successful connection

pub fn record_failure(&self, peer_id: &str)

Record a failed connection

pub async fn process_queue(&self) -> Vec<String>

Process queued connections

pub fn stats(&self) -> RateLimiterStats

Get current statistics

pub fn peer_stats(&self, peer_id: &str) -> Option<(u64, u64, f64)>

Get per-peer statistics

pub fn reset(&self)

Reset rate limiter state