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

Whether the node type may return FanOut.

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 register_guard(&mut self, node_type: impl Into<String>, kind: GuardKind)

Declare the role a guard plays on an action’s dominating path.

pub fn guard_kind(&self, node_type: &str) -> Option<GuardKind>

Guard role of a node type, if registered as a guard.

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

Whether the node type is a registered guard.

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

Whether the node type is an ingress source.

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

Whether the node type can be compiled as a step.

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>

Registered step node types.

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

Attach a config schema to a node type.

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

Config schema of a node type.

pub fn register_capability( &mut self, manifest: CapabilityManifest, ) -> Result<(), NodeError>

Register the immutable contract for a trigger, expression, guard or action.

pub fn capability(&self, id: &str) -> Option<&CapabilityManifest>

Registered manifest by capability id.

pub fn capability_manifests(&self) -> impl Iterator<Item = &CapabilityManifest>

Every registered manifest.

Trait Implementations

impl Debug for NodeRegistry

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

Formats the value using the given formatter.