Struct HeartbeatMonitor 

pub struct HeartbeatMonitor { /* private fields */ }

Tracks last heartbeat timestamps and detects timeout conditions.

The dispatch loop calls check_timeouts once per tick to find actors whose heartbeat has expired.

Implementations

impl HeartbeatMonitor

pub fn new() -> Self

Creates an empty monitor.

pub fn record_registration( &mut self, actor_id: ActorId, policy: HeartbeatPolicy, now: u64, )

Records actor registration with initial heartbeat timestamp.

pub fn record_heartbeat(&mut self, actor_id: ActorId, timestamp: u64)

Records a heartbeat for an active actor.

pub fn remove(&mut self, actor_id: ActorId)

Removes tracking for an actor (called on deregistration).

pub fn check_timeouts(&self, now: u64) -> Vec<ActorId>

Returns actor IDs whose heartbeat has timed out at now.

An actor times out when now >= last_heartbeat_at + timeout_secs.

pub fn is_alive(&self, actor_id: ActorId, now: u64) -> bool

Returns true if the actor’s heartbeat is within the timeout window.

Trait Implementations

impl Default for HeartbeatMonitor

fn default() -> HeartbeatMonitor

Returns the “default value” for a type.