Struct NodeRegistry 

pub struct NodeRegistry { /* private fields */ }

Registry of step-node factories. Ingress types are tracked by name only — the runner owns their execution.

Implementations

impl NodeRegistry

pub fn empty() -> Self

Empty registry — no node types known.

pub fn with_builtins() -> Self

Registry pre-loaded with the generic (non-business) node types.

pub fn register_step( &mut self, node_type: impl Into<String>, factory: StepFactory, )

Register a step-node factory under node_type.

pub fn register_ingress(&mut self, node_type: impl Into<String>)

Mark a node type as an ingress source.

pub fn register_fan_out(&mut self, node_type: impl Into<String>)

Mark a node type as fan-out-capable (its process may return FanOut). The validator (R4’) bans these upstream of execute.*.

pub fn is_fan_out_capable(&self, node_type: &str) -> bool

pub fn register_side_effect_guard(&mut self, node_type: impl Into<String>)

Declare a product node as an authorization guard for execute.* side effects.

pub fn is_side_effect_guard(&self, node_type: &str) -> bool

pub fn is_ingress(&self, node_type: &str) -> bool

pub fn is_step(&self, node_type: &str) -> bool

pub fn build_step( &self, node_type: &str, config: &Value, ) -> Result<Box<dyn StepNode>, NodeError>

Build a step node instance from a spec node’s type + config.

pub fn known_step_types(&self) -> impl Iterator<Item = &str>

pub fn register_schema( &mut self, node_type: impl Into<String>, schema: NodeSchema, )

pub fn schema(&self, node_type: &str) -> Option<&NodeSchema>

Trait Implementations

impl Debug for NodeRegistry

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

Formats the value using the given formatter.