Struct StreamHealthMonitor 

pub struct StreamHealthMonitor { /* private fields */ }

Stream health monitor

Tracks stream activity and provides health status updates.

Implementations

impl StreamHealthMonitor

pub fn new(config: StreamHealthConfig) -> Self

Create a new stream health monitor

pub fn with_events( config: StreamHealthConfig, tx: Sender<StreamHealthEvent>, ) -> Self

Create with event channel for notifications

pub fn record_activity(&self)

Record activity on the stream

pub fn status(&self) -> StreamHealthStatus

Get current stream status

pub fn cancel(&self)

Mark stream as cancelled

pub fn is_cancelled(&self) -> bool

Check if stream is cancelled

pub fn complete(&self)

Mark stream as completed

pub fn fail(&self)

Mark stream as failed

pub fn idle_time_ms(&self) -> u64

Get time since last activity in milliseconds

pub fn check_health(&self) -> bool

Check stream health and update status

Returns true if stream is still healthy/recoverable

pub fn config(&self) -> &StreamHealthConfig

Get configuration

pub fn handle(&self) -> StreamHealthHandle

Create a handle for sharing across tasks