Struct Executor 

pub struct Executor {
    pub registry: TransformRegistry,
}

Stateless executor that drives a single HyperEdge.

Fields

registry: TransformRegistry

Implementations

impl Executor

pub fn new(registry: TransformRegistry) -> Self

Create an executor backed by the given transform registry.

pub async fn execute( &self, edge: &HyperEdge, port_values: &mut HashMap<PortId, Value>, ) -> Result<(), EngineError>

Execute one edge.

1. Collect input values from port_values[sources]. Missing source ports resolve to Value::Null.
2. Evaluate the edge transform (may be async).
3. Write the result into port_values for every target port.