Struct JsonDynamicNode 

pub struct JsonDynamicNode { /* private fields */ }

JsonDynamic node - schemaless JSON handling.

Handles dynamic/volatile JSON payloads that don’t conform to strict schemas. Useful for:

• Accepting webhook payloads from external services
• Working with APIs that change frequently
• Late binding before converting to strict types

Ports

• Input: “in” - Any JSON input
• Output: “out” - Processed JSON output
• Output: “error” - Emitted on errors

Example Configuration

nodes:
  handle_webhook:
    type: std::json_dynamic
    config:
      operation: extract
      fields:
        - $.data.user.id
        - $.data.user.email
        - $.metadata.timestamp
    inputs:
      - from: webhook.out -> in
    outputs:
      out: -> validate.in

Implementations

impl JsonDynamicNode

pub fn passthrough() -> Self

Create a passthrough node (no transformation).

pub fn extract(fields: Vec<String>) -> Self

Create a node that extracts specific fields.

pub fn merge() -> Self

Create a node that merges multiple inputs.

pub fn set(path: impl Into<String>, value: Value) -> Self

Create a node that sets a specific field.

pub fn delete(path: impl Into<String>) -> Self

Create a node that deletes a field.

pub fn flatten(separator: impl Into<String>) -> Self

Create a node that flattens nested objects.

pub fn with_required(self, fields: Vec<String>) -> Self

Add required field validation.

Trait Implementations

impl Debug for JsonDynamicNode

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

Formats the value using the given formatter.

impl Node for JsonDynamicNode

fn info(&self) -> NodeInfo

Get metadata about this node.

fn execute<'a>( &'a self, ctx: Context, inputs: HashMap<String, RelPtr<()>>, ) -> NodeFuture<'a>

Execute the node.

fn shutdown(&self)

Called when the node is being shut down.

fn output_schema_hash(&self) -> u64

Get the schema hash for this node’s output type.