Struct RunState 

pub struct RunState<S> {
    pub user: S,
    pub errors: IndexMap<NodeId, BspError>,
    pub step: u64,
    /* private fields */
}

The complete schedulable state of one run: consumer state, value store, and all activation accounting. Suspension, resumption, and step-limit results all package this.

Fields

user: S

The consumer-owned state. The engine moves it; it never inspects it.

errors: IndexMap<NodeId, BspError>

The node errors recorded so far (populated by RouteToErrorEdge recovery).

step: u64

Number of supersteps executed so far (counts toward max_steps).

Implementations

impl<S> RunState<S>

pub const fn values(&self) -> &ValueStore

The engine-owned value store.

pub const fn values_mut(&mut self) -> &mut ValueStore

Mutable access to the engine-owned value store (e.g. to restore pin state out of band).

pub const fn iterations(&self) -> &IndexMap<EdgeId, u64>

Per-edge iteration counters, keyed by edge declaration index.

pub const fn executions(&self) -> &IndexMap<NodeId, u64>

Per-node execution counters (counts execute invocations, including retries).

pub fn execution_count(&self, node_id: NodeId) -> u64

How many times a node has executed so far.

pub fn iteration_count(&self, edge: EdgeId) -> u64

How many times an edge has fired against its iteration budget so far.

pub fn get_output_typed<T: Any + Send + Sync + Clone>( &self, pin: OutputPin, ) -> Option<T>

Retrieves a typed value associated with an output pin, if it exists.

Trait Implementations

impl<S> BspOutputMapExt for RunState<S>

fn get_typed<T: Any + Send + Sync + Clone>( &self, pin: OutputPin, ) -> Result<T, BspError>

Typed access to the value store’s output map, so a completed run reads exactly like the dataflow engine’s output map did.

impl<S: Debug> Debug for RunState<S>

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

Formats the value using the given formatter.