Struct HeartbeatScheduler 

pub struct HeartbeatScheduler { /* private fields */ }

Manages heartbeat schedules for multiple agents.

Call [tick] with the elapsed wall-clock delta. Agents whose accumulated elapsed time exceeds their configured interval will be returned as needing a wake-up.

Implementations

impl HeartbeatScheduler

pub fn new() -> Self

Create an empty scheduler.

pub fn register(&mut self, config: HeartbeatConfig)

Register an agent heartbeat. Replaces any existing entry.

pub fn unregister(&mut self, agent_id: &str) -> bool

Remove an agent from the scheduler. Returns true if it existed.

pub fn tick(&mut self, delta: Duration) -> Vec<HeartbeatTickResult>

Advance all heartbeats by delta time.

Returns a list of agents that need to wake up (their interval has elapsed). Agents that are disabled are skipped.

pub fn phase(&self, agent_id: &str) -> Option<HeartbeatPhase>

Return the current phase of a given agent.

pub fn advance_phase(&mut self, agent_id: &str) -> Option<HeartbeatPhase>

Advance a specific agent to its next phase.

pub fn len(&self) -> usize

Number of registered agents.

pub fn is_empty(&self) -> bool

Whether the scheduler has no registered agents.

pub fn agent_ids(&self) -> Vec<&str>

Return all registered agent IDs.

pub fn tick_count(&self, agent_id: &str) -> Option<u64>

Get the tick count for a given agent.

Trait Implementations

impl Debug for HeartbeatScheduler

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

Formats the value using the given formatter.

impl Default for HeartbeatScheduler

fn default() -> Self

Returns the “default value” for a type.