Struct HealthMonitor 

pub struct HealthMonitor<T: HealthReportSender> { /* private fields */ }

A runtime health monitoring service.

The HealthMonitor tracks client health statuses by processing events such as connections, disconnections, and connection losses. It periodically checks client states and sends health reports using the configured HealthReportSender.

Implementations

impl<T: HealthReportSender> HealthMonitor<T>

pub async fn listen(&mut self)

Starts the health monitoring event loop.

This async method continuously listens for incoming events, periodic checks, and reminders. It processes client health updates based on received events and predefined timing intervals.

The loop will run until the event stream is closed or an exit condition is met.

Behavior

• Sends the initial health report immediately upon start.
• Periodically checks client health status every check_interval.
• Sends reminder reports every reminder_interval if any clients are not healthy.
• Processes events received from the event receiver to update client states.

Trait Implementations

impl<T: Debug + HealthReportSender> Debug for HealthMonitor<T>

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

Formats the value using the given formatter.

impl<T: HealthReportSender + Send + Sync + 'static> IntoSubsystem<NeverError> for HealthMonitor<T>

Available on crate feature tokio-graceful-shutdown only.

async fn run(self, subsys: &mut SubsystemHandle) -> Result<(), NeverError>

The logic of the subsystem.

fn into_subsystem( self, ) -> impl FnOnce(&mut SubsystemHandle<ErrWrapper>) -> Pin<Box<dyn Future<Output = Result<(), Err>> + Send + '_>>

Converts the object into a type that can be passed into SubsystemHandle::start().