Struct CycleExecutor 

pub struct CycleExecutor { /* private fields */ }

The single-dispatcher cycle executor. Not Sync by design: all methods run on the engine dispatcher task.

Implementations

impl CycleExecutor

pub fn new(slot: Arc<PlanSlot>) -> Self

pub fn epoch(&self) -> u64

pub fn plan(&self) -> &SharedPlan

pub fn cycle_complete(&self) -> bool

pub fn start_cycle(&mut self, now: Instant) -> Vec<NodeJob>

Start the next cycle and return the seed jobs (all source nodes).

pub fn on_node_done( &mut self, epoch: u64, node: NodeId, now: Instant, ) -> (Vec<NodeJob>, bool)

Record a worker completion. Stale-epoch completions are dropped. Returns newly dispatchable jobs and whether the cycle is complete.

pub fn force_timeouts( &mut self, now: Instant, timeout: Duration, ) -> ForceOutcome

Force-complete timed-out nodes (silence their outputs) and, once the task timeout has elapsed since cycle start, dispatch the forced feedback nodes. Call this on every dispatcher tick and completion.

pub fn abandon_node(&mut self, node: NodeId, now: Instant) -> ForceOutcome

A dispatch failed (worker channel closed): complete the node with silence immediately so the cycle cannot stall.