Struct ConnectionHealthChecker 

pub struct ConnectionHealthChecker {
    pub connections: HashMap<u64, ConnectionRecord>,
    pub config: HealthCheckerConfig,
    pub next_conn_id: u64,
}

Tracks and evaluates the health of a set of TCP/QUIC connections.

Call open_connection to begin monitoring a connection, feed events via record_event, and query health through alive_connections, dead_connections, or stats.

Fields

connections: HashMap<u64, ConnectionRecord>

All tracked connections, keyed by connection ID.

config: HealthCheckerConfig

Configuration governing threshold behaviour.

next_conn_id: u64

Monotonically increasing counter used to assign connection IDs.

Implementations

impl ConnectionHealthChecker

pub fn new(config: HealthCheckerConfig) -> Self

Create a new checker with the supplied configuration.

pub fn open_connection(&mut self, peer_id: String) -> u64

Begin monitoring a connection to peer_id.

Returns the stable connection ID that must be supplied to subsequent calls.

pub fn record_event(&mut self, conn_id: u64, event: ConnectionEvent)

Feed an event into the connection record identified by conn_id.

Unknown conn_id values are silently ignored so that callers do not need to guard against race conditions between close and event delivery.

pub fn close_connection(&mut self, conn_id: u64) -> bool

Remove a connection from tracking.

Returns true when the connection was present and has been removed, false when no record with conn_id existed.

pub fn alive_connections(&self) -> Vec<&ConnectionRecord>

Returns references to all connections that are not in the Dead state, in unspecified order.

pub fn dead_connections(&self) -> Vec<&ConnectionRecord>

Returns references to all connections that are in the Dead state, in unspecified order.

pub fn stats(&self) -> (usize, usize, usize)

Returns a triple of (total, alive, dead) connection counts.