Struct HealthMonitor 

pub struct HealthMonitor { /* private fields */ }

Health monitor for tracking stream status and connectivity

Implementations

impl HealthMonitor

pub fn new(config: HealthConfig) -> Self

pub async fn start(&self) -> JoinHandle<()>

Start the health monitoring background task

pub async fn record_event(&self)

Record that an event was received from the stream

pub async fn record_connection(&self)

Record that the stream connection was established

pub async fn record_disconnection(&self)

Record that the stream disconnected

pub async fn record_reconnecting(&self)

Record that the stream is attempting to reconnect

pub async fn record_error(&self, error: String)

Record an error from the stream

pub async fn is_healthy(&self) -> bool

Check if the stream is currently healthy

pub async fn status(&self) -> StreamStatus

Get the current stream status

pub async fn error_count(&self) -> u32

Get the current error count

Trait Implementations

impl Clone for HealthMonitor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.