Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Connection manager

Implementations

impl ConnectionManager

pub fn new(config: ConnectionLimitsConfig) -> Self

Create a new connection manager

pub fn should_accept( &self, peer_id: &PeerId, direction: ConnectionDirection, ) -> bool

Check if a new connection should be accepted

pub fn connection_established( &self, peer_id: PeerId, direction: ConnectionDirection, )

Register a new connection

pub fn connection_closed(&self, peer_id: &PeerId)

Unregister a connection

pub fn record_activity(&self, peer_id: &PeerId, sent: bool)

Record activity on a connection

pub fn update_score(&self, peer_id: &PeerId, delta: i16)

Update connection score

pub fn update_latency(&self, peer_id: &PeerId, latency_ms: u64)

Update connection latency

pub fn add_reserved(&self, peer_id: PeerId)

Add a peer to reserved list

pub fn remove_reserved(&self, peer_id: &PeerId)

Remove a peer from reserved list

pub fn ban_peer(&self, peer_id: PeerId)

Ban a peer

pub fn unban_peer(&self, peer_id: &PeerId)

Unban a peer

pub fn is_banned(&self, peer_id: &PeerId) -> bool

Check if a peer is banned

pub fn get_prune_candidates(&self, count: usize) -> Vec<PeerId>

Get peers that should be disconnected (pruning candidates)

pub fn get_idle_connections(&self) -> Vec<PeerId>

Get idle connections that should be closed

pub fn prune_to_limit(&self) -> Vec<PeerId>

Prune connections to make room for new ones

Returns peer IDs that should be disconnected

pub fn connected_peers(&self) -> Vec<PeerId>

Get all connected peer IDs

pub fn connection_count(&self) -> usize

Get connection count

pub fn is_connected(&self, peer_id: &PeerId) -> bool

Check if connected to a peer

pub fn stats(&self) -> ConnectionManagerStats

Get connection statistics

Trait Implementations

impl Default for ConnectionManager

fn default() -> Self

Returns the “default value” for a type.