Struct NodeCtx 

pub struct NodeCtx<'a> {
    pub run_id: Uuid,
    pub step: u64,
    pub config: &'a RunnableConfig,
    /* private fields */
}

Per-superstep context handed to every Node::execute call. Carries run-correlation metadata and the active RunnableConfig. The lifetime is the superstep — don’t hold across awaits beyond execute returning.

Fields

run_id: Uuid

Correlation ID for this run.

step: u64

Superstep counter (0-indexed).

config: &'a RunnableConfig

The active runnable config (recursion_limit, observers, cancel_token, …).

Implementations

impl<'a> NodeCtx<'a>

pub fn new(run_id: Uuid, step: u64, config: &'a RunnableConfig) -> Self

Create a new NodeCtx. Primarily used by the engine; exposed publicly so node implementations in external crates can construct test contexts.

pub fn payload(&self) -> Option<&Value>

The Send payload accompanying this dispatch, if any. Returns None when the node is invoked via Goto::Node or Goto::Multiple.

pub fn remaining_steps(&self) -> Option<u32>

Number of supersteps remaining before the recursion limit fires. None when running outside the engine (unit tests).

pub fn is_last_step(&self) -> bool

True if this is the final superstep — i.e. the engine will not run another step after this one returns. Mirrors V1 IsLastStep.

pub fn emit(&self, event: &Event)

Notify every observer in config.observers of an event.

pub fn write_custom(&self, kind: impl Into<String>, payload: Value)

Emit a Custom event on the run’s observer stream. Used by StreamMode::Custom consumers to surface node-authored progress signals (mirrors V1 StreamWriter).

pub fn is_cancelled(&self) -> bool

True if the run was cancelled.

pub fn observers(&self) -> &[Arc<dyn Observer>]

Convenience accessor for observers.