Struct PeerConnectionLimiter 

pub struct PeerConnectionLimiter { /* private fields */ }

Rate-based connection limiter that enforces per-peer limits, a global cap, and a cooldown period between connections from the same peer.

Implementations

impl PeerConnectionLimiter

pub fn new(config: LimiterConfig) -> Self

Create a new limiter with the given configuration.

pub fn try_connect(&mut self, peer_id: &str) -> Result<(), String>

Attempt to accept a connection from peer_id.

Returns Ok(()) if the connection is accepted, or Err with a human-readable reason if rejected.

pub fn disconnect(&mut self, peer_id: &str) -> Result<(), String>

Record a disconnection for peer_id.

Returns Err if the peer has no active connections or is unknown.

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

Check whether a connection from peer_id would be allowed without modifying any state.

pub fn active_for_peer(&self, peer_id: &str) -> usize

Return the number of active connections for the given peer, or 0 if the peer is not tracked.

pub fn total_active(&self) -> usize

Return the total number of active connections across all peers.

pub fn tick(&mut self)

Advance the internal clock by one tick.

pub fn reset_peer(&mut self, peer_id: &str)

Clear all connection info for the specified peer. The peer is removed from the internal tracking map and the global active count is adjusted.

pub fn stats(&self) -> LimiterStats

Return an aggregate statistics snapshot.

pub fn config(&self) -> &LimiterConfig

Return a reference to the current configuration.

pub fn current_tick(&self) -> u64

Return the current tick value.

pub fn peer_info(&self, peer_id: &str) -> Option<&PeerConnectionInfo>

Return a reference to a peer’s info, if tracked.