Struct HeartbeatMonitor

pub struct HeartbeatMonitor { /* private fields */ }

Heartbeat monitor for WebSocket connections

Implementations

impl HeartbeatMonitor

pub fn new( heartbeat_interval_milliseconds: u64, heartbeat_timeout_milliseconds: u64, max_missed_heartbeats: u32, connection_status: Arc<RwLock<ConnectionState>>, stats: Arc<RwLock<ConnectionStats>>, ) -> Self

Create a new heartbeat monitor

pub fn update_last_message_time(&self)

Update the last message time

pub fn check_heartbeat(&self) -> HeartbeatStatus

Check the heartbeat status

pub fn reset(&self)

Reset the heartbeat monitor

pub fn missed_heartbeats(&self) -> u32

Get the number of consecutive missed heartbeats

pub fn time_since_last_message(&self) -> Duration

Get the time elapsed since the last message

Trait Implementations

impl Clone for HeartbeatMonitor

fn clone(&self) -> HeartbeatMonitor

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HeartbeatMonitor

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

Formats the value using the given formatter.