Struct KernelWatchdog 

pub struct KernelWatchdog { /* private fields */ }

Watchdog for monitoring kernel health.

Implementations

impl KernelWatchdog

pub fn new() -> Arc<KernelWatchdog>

Create a new kernel watchdog.

pub fn with_heartbeat_timeout( self: Arc<KernelWatchdog>, timeout: Duration, ) -> Arc<KernelWatchdog>

Set heartbeat timeout.

pub fn watch(&self, kernel_id: KernelId)

Register a kernel to watch.

pub fn unwatch(&self, kernel_id: &KernelId)

Unregister a kernel.

pub fn heartbeat(&self, kernel_id: &KernelId)

Record heartbeat from kernel.

pub fn update_metrics( &self, kernel_id: &KernelId, messages_per_sec: f64, queue_depth: usize, )

Update kernel metrics.

pub fn check_all(&self) -> Vec<KernelHealth>

Check all kernel health.

pub fn on_unhealthy<F>(&self, callback: F)

where F: Fn(&KernelHealth) + Send + Sync + 'static,

Register unhealthy kernel callback.

pub fn get_health(&self, kernel_id: &KernelId) -> Option<KernelHealth>

Get health for specific kernel.

pub fn unhealthy_kernels(&self) -> Vec<KernelHealth>

Get all unhealthy kernels.

pub fn watched_count(&self) -> usize

Get watched kernel count.

Trait Implementations

impl Default for KernelWatchdog

fn default() -> KernelWatchdog

Returns the “default value” for a type.