Struct ConnectionHealthMonitor 

pub struct ConnectionHealthMonitor { /* private fields */ }

Monitors WebSocket connection health with periodic pings.

This can be used to detect stale connections that are not receiving any messages (including pings from the server).

Implementations

impl ConnectionHealthMonitor

pub fn new(max_idle_duration: Duration) -> Self

Create a new connection health monitor.

Arguments

• max_idle_duration - Maximum time without activity before considering unhealthy.

pub async fn record_activity(&self)

Record activity on the connection.

pub async fn is_healthy(&self) -> bool

Check if the connection is healthy.

pub async fn time_since_last_activity(&self) -> Duration

Get the time since last activity.

pub fn start_background_check( self: Arc<Self>, check_interval: Duration, ) -> JoinHandle<()>

Start a background health check task that updates is_healthy periodically.