Trait NodeExecutorRegistry 

pub trait NodeExecutorRegistry: Sync {
    type Executor: NodeExecutor + ?Sized;

    // Required method
    fn executor_for(&self, node_id: &NodeId) -> Result<&Self::Executor>;
}

Registry that resolves workflow nodes to runtime executors.

The registry owns node-to-executor selection while the workflow runner owns graph wiring, cancellation, lifecycle, and metadata behavior.

Required Associated Types

type Executor: NodeExecutor + ?Sized

Concrete executor type returned for nodes in this registry.

Required Methods

fn executor_for(&self, node_id: &NodeId) -> Result<&Self::Executor>

Resolve an executor for one workflow node.

Errors

Returns an error when no executor is registered for the node.

Implementors

impl<E> NodeExecutorRegistry for SingleNodeExecutorRegistry<'_, E>

where E: NodeExecutor + ?Sized,

type Executor = E

impl<E> NodeExecutorRegistry for StaticNodeExecutorRegistry<E>

where E: NodeExecutor,

type Executor = E