Struct InlineExecutor 

pub struct InlineExecutor { /* private fields */ }

Real executor that runs Pure stage implementations inline. Handles higher-order stages (map, filter, reduce) by recursively calling itself. Falls back to returning the first example output for unimplemented stages.

Implementations

impl InlineExecutor

pub fn from_store(store: &(impl StageStore + ?Sized)) -> Self

Build from a store using only the built-in stdlib implementations.

This is the standard constructor. Use Self::from_store_with_registry if you need to inject additional inline stage implementations.

pub fn from_store_with_registry( store: &(impl StageStore + ?Sized), registry: InlineRegistry, ) -> Self

Build from a store, augmenting the stdlib with the provided registry.

Registered stages take priority over stdlib stages with the same description string, allowing selective overrides.

pub fn has_implementation(&self, stage_id: &StageId) -> bool

Check if a stage has a real implementation (not just a fallback).

Trait Implementations

impl StageExecutor for InlineExecutor

fn execute( &self, stage_id: &StageId, input: &Value, ) -> Result<Value, ExecutionError>