Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Sorted timer heap.

Implementations

impl Scheduler

pub fn new() -> Self

Construct a fresh scheduler with now_ns = 0.

pub fn set_cap(&mut self, cap: usize)

Override the timer heap cap. Production paths size from NodeConfig if the host advertises a different bound.

pub fn dropped(&self) -> u64

Number of timers dropped on overflow since construction.

pub fn set_now(&mut self, now_ns: u64)

Advance the scheduler’s notion of current time.

pub fn now_ns(&self) -> u64

Read the current time.

pub fn schedule(&mut self, maturity_ns: u64, kind: TimerKind)

Schedule a timer. Drops with a tracing::warn once the heap reaches its cap so a runaway Interval/After loop can’t grow the heap to OOM.

pub fn has_matured(&self, now_ns: u64) -> bool

Whether any timer has matured by now_ns.

pub fn poll_matured(&mut self, now_ns: u64) -> Vec<TimerKind>

Drain every timer whose maturity_ns <= now_ns in age order.

pub fn len(&self) -> usize

Number of pending (un-matured + matured) timers.

pub fn is_empty(&self) -> bool

Whether the heap is empty.

Trait Implementations

impl Default for Scheduler

fn default() -> Self

Returns the “default value” for a type.