Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Deterministic event scheduler for simulation.

Processes events in timestamp order with deterministic tie-breaking. All randomness goes through the seeded RNG.

Implementations

impl Scheduler

pub fn new(seed: u64) -> Self

Creates a new scheduler with the given seed.

pub fn with_config(seed: u64, config: SchedulerConfig) -> Self

Creates a new scheduler with the given seed and configuration.

pub fn time(&self) -> &VirtualTime

Returns a reference to the virtual time.

pub fn time_mut(&mut self) -> &mut VirtualTime

Returns a mutable reference to the virtual time.

pub fn now(&self) -> u64

Returns the current virtual time in nanoseconds.

pub fn rng(&self) -> &SimulationRng

Returns a reference to the RNG.

pub fn seed(&self) -> u64

Returns the seed used for this scheduler.

pub fn pending_count(&self) -> usize

Returns the number of pending events.

pub fn event_log(&self) -> &[Event]

Returns the event log for replay verification.

pub fn clear_event_log(&mut self)

Clears the event log.

pub fn schedule_at(&mut self, timestamp: u64, event_type: EventType) -> EventId

Schedules an event at the given absolute timestamp.

pub fn schedule_after( &mut self, delay: Duration, event_type: EventType, ) -> EventId

Schedules an event after the given delay from now.

pub fn schedule_now(&mut self, event_type: EventType) -> EventId

Schedules an event at the current time.

pub fn cancel(&mut self, id: EventId) -> bool

Cancels a pending event by ID.

Returns true if the event was found and cancelled.

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

Returns the timestamp of the next pending event, if any.

pub fn step(&mut self) -> Option<Event>

Processes the next pending event, advancing time if necessary.

Returns the processed event, or None if no events are pending.

pub fn run_until<F>(&mut self, condition: F) -> usize

where F: FnMut(&Scheduler) -> bool,

Processes events until the given condition is true or no events remain.

Returns the number of events processed.

pub fn run_until_time(&mut self, target_time: u64) -> usize

Processes events until the given time is reached.

Returns the number of events processed.

pub fn run_all(&mut self) -> usize

Processes all pending events.

Returns the number of events processed.

pub fn drain_pending(&mut self) -> Vec<Event>

Drains all pending events without processing them.

Trait Implementations

impl Debug for Scheduler

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

Formats the value using the given formatter.