Struct WorkerState 

#[non_exhaustive]
pub struct WorkerState {
    pub node_index: usize,
    pub node_count: usize,
    pub current_tick: Ticks,
    pub readiness: Readiness,
    pub backpressure: WatermarkState,
    pub last_step: Option<StepResult>,
    pub last_error: bool,
}

Per-worker state snapshot for scheduling decisions.

Populated by the codegen-generated worker loop before each WorkerScheduler::decide call. Edge occupancy is queried from concrete edge types (no dyn dispatch) and summarised here.

Extensibility model: #[non_exhaustive] — fields will be added as planned work lands. The codegen loop queries edges using concrete types (no dyn) and populates this snapshot. The scheduler never touches edges directly — it only sees the snapshot. New edge capabilities (peek_header, mailbox, urgency) are exposed by adding fields here, with the codegen loop doing the actual querying.

Planned extensions (one field per planned item):

• earliest_deadline: Option<DeadlineNs> (R1 — from peeked input headers)
• max_input_urgency: Option<Urgency> (R1 — highest urgency among inputs)
• inputs_fresh: bool (R2 — all inputs within max_age threshold)
• input_liveness_ok: bool (R5 — all inputs within liveness threshold)
• micros_since_last_step: u64 (R6 — for node liveness violation detection)
• criticality: CriticalityClass (R8 — node’s criticality tier)
• input_count: usize / inputs_ready_count: usize (C2 — N→M per-port)

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

node_index: usize

Index of this node in the graph.

node_count: usize

Total number of nodes in the graph.

current_tick: Ticks

Current clock tick (monotonic). Enables freshness/liveness calculations without the scheduler needing a clock reference.

readiness: Readiness

Readiness derived from input availability and output pressure.

backpressure: WatermarkState

Max output backpressure (watermark across all outputs).

last_step: Option<StepResult>

Result of the last step, if any.

last_error: bool

Whether the last step errored (NodeError details go to telemetry).

Implementations

impl WorkerState

pub const fn new( node_index: usize, node_count: usize, current_tick: Ticks, ) -> Self

Construct a new initial worker state for a given node.

Trait Implementations

impl Clone for WorkerState

fn clone(&self) -> WorkerState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerState

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

Formats the value using the given formatter.

impl Copy for WorkerState