Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Tracks scheduling state for all registered edges and accumulates a queue of edge ids that are ready to execute.

Implementations

impl Scheduler

pub fn new() -> Self

Create an empty scheduler.

pub fn register(&mut self, edge: &HyperEdge)

Register an edge with the scheduler.

The scheduling policy is taken from the edge’s EdgeSchedule.

pub fn notify_change(&mut self, port: PortId)

Notify the scheduler that port has a new value.

All OnChange edges whose source list includes port are enqueued.

pub fn tick(&mut self, delta: Duration)

Advance time by delta. All OnTick edges whose interval has elapsed are enqueued (and their elapsed counter resets to zero).

pub fn fire_event(&mut self, name: &str)

Fire a named event, enqueuing all edges registered for that event name.

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

Drain the pending queue, returning edge ids in FIFO order.

Duplicate ids are deduplicated while preserving first-occurrence order.

Trait Implementations

impl Default for Scheduler

fn default() -> Scheduler

Returns the “default value” for a type.