Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool managing multiple peer connections.

Implementations

impl ConnectionPool

pub fn new(config: NetworkConfig) -> Self

Create a new connection pool.

pub fn config(&self) -> &NetworkConfig

Get the network configuration.

pub async fn connection_count(&self) -> usize

Get the number of active connections.

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

Check if we’re connected to a peer.

pub async fn get_connection(&self, peer_id: &PeerId) -> Option<Connection>

Get connection info for a peer.

pub async fn peer_ids(&self) -> Vec<PeerId>

Get all peer IDs.

pub async fn add_connection( &self, peer_id: PeerId, remote_addr: SocketAddr, outbound: bool, ) -> Result<ConnectionId, TransportError>

Add a connection to the pool.

pub async fn remove_connection(&self, peer_id: &PeerId) -> Option<Connection>

Remove a connection from the pool.

pub async fn update_state(&self, peer_id: &PeerId, state: ConnectionState)

Update connection state.

pub async fn record_sent(&self, peer_id: &PeerId)

Record message sent.

pub async fn record_received(&self, peer_id: &PeerId)

Record message received.

pub async fn update_latency(&self, peer_id: &PeerId, latency: Duration)

Update latency measurement.

pub async fn get_idle_connections(&self, max_idle: Duration) -> Vec<PeerId>

Get connections that have been idle too long.

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.