Struct Scheduler 

pub struct Scheduler<C: Clock = WallClock> { /* private fields */ }

The deterministic event loop scheduler state.

Implementations

impl Scheduler<WallClock>

pub fn new() -> Self

Create a new scheduler with the default wall clock.

impl<C: Clock> Scheduler<C>

pub fn with_clock(clock: C) -> Self

Create a new scheduler with a custom clock.

pub const fn current_seq(&self) -> Seq

Get the current sequence number.

pub fn now_ms(&self) -> u64

Get the current time from the clock.

pub fn has_pending(&self) -> bool

Check if there are pending tasks.

pub fn macrotask_count(&self) -> usize

Get the number of pending macrotasks.

pub fn timer_count(&self) -> usize

Get the number of pending timers.

pub fn set_timeout(&mut self, delay_ms: u64) -> u64

Schedule a timer to fire at the given deadline.

Returns the timer ID for cancellation.

pub fn clear_timeout(&mut self, timer_id: u64) -> bool

Cancel a timer by ID.

Returns true if the timer was found and cancelled.

pub fn enqueue_hostcall_complete( &mut self, call_id: String, outcome: HostcallOutcome, )

Enqueue a hostcall completion.

pub fn enqueue_hostcall_completions<I>(&mut self, completions: I)

where I: IntoIterator<Item = (String, HostcallOutcome)>,

Enqueue multiple hostcall completions in one scheduler mutation pass.

pub fn enqueue_stream_chunk( &mut self, call_id: String, sequence: u64, chunk: Value, is_final: bool, )

Convenience: enqueue a stream chunk for a hostcall.

pub fn enqueue_event(&mut self, event_id: String, payload: Value)

Enqueue an inbound event from the host.

pub fn tick(&mut self) -> Option<Macrotask>

Execute one tick of the event loop.

Algorithm (from spec):

1. Ingest host completions (done externally via enqueue methods)
2. Move due timers to macrotask queue
3. Run one macrotask (if any)
4. Drain microtasks (done externally by JS engine)

Returns the macrotask that was executed, if any.

pub fn next_timer_deadline(&self) -> Option<u64>

Get the deadline of the next timer, if any.

pub fn time_until_next_timer(&self) -> Option<u64>

Get the time until the next timer fires, if any.

Trait Implementations

impl<C: Clock> Debug for Scheduler<C>

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

Formats the value using the given formatter.

impl Default for Scheduler<WallClock>

fn default() -> Self

Returns the “default value” for a type.