Enum NodeExecutionData 

pub enum NodeExecutionData {
    Start {
        next: String,
    },
    Llm {
        model: String,
        output: String,
        next: String,
    },
    Tool {
        tool: String,
        output: Value,
        next: String,
    },
    Condition {
        expression: String,
        evaluated: bool,
        next: String,
    },
    Debounce {
        key: String,
        suppressed: bool,
        next: String,
    },
    Throttle {
        key: String,
        throttled: bool,
        next: String,
    },
    RetryCompensate {
        tool: String,
        attempts: usize,
        compensated: bool,
        output: Value,
        next: String,
    },
    HumanInTheLoop {
        approved: bool,
        response: Value,
        next: String,
    },
    CacheRead {
        key: String,
        hit: bool,
        value: Value,
        next: String,
    },
    CacheWrite {
        key: String,
        value: Value,
        next: String,
    },
    EventTrigger {
        event: String,
        matched: bool,
        next: String,
    },
    Router {
        selected: String,
        next: String,
    },
    Transform {
        expression: String,
        output: Value,
        next: String,
    },
    Loop {
        condition: String,
        evaluated: bool,
        iteration: u32,
        next: String,
    },
    Subgraph {
        graph: String,
        terminal_node_id: String,
        output: Value,
        next: String,
    },
    Batch {
        items_path: String,
        item_count: usize,
        next: String,
    },
    Filter {
        items_path: String,
        expression: String,
        kept: usize,
        next: String,
    },
    Parallel {
        branches: Vec<String>,
        outputs: BTreeMap<String, Value>,
        next: String,
    },
    Merge {
        policy: MergePolicy,
        sources: Vec<String>,
        output: Value,
        next: String,
    },
    Map {
        item_count: usize,
        output: Value,
        next: String,
    },
    Reduce {
        operation: ReduceOperation,
        output: Value,
        next: String,
    },
    End,
}

Structured result data emitted for each node.

Variants

Start

Start node transition.

Fields

next: String

Next node id.

Llm

LLM node output.

Fields

model: String

Model used.

output: String

Assistant output text.

next: String

Next node id.

Tool

Tool node output.

Fields

tool: String

Tool name.

output: Value

Tool output JSON payload.

next: String

Next node id.

Condition

Condition node decision.

Fields

expression: String

Original expression.

evaluated: bool

Evaluated bool.

next: String

Chosen next node id.

Debounce

Debounce gate decision.

Fields

key: String

Resolved debounce key.

suppressed: bool

Whether the event was suppressed.

next: String

Chosen next node id.

Throttle

Throttle gate decision.

Fields

key: String

Resolved throttle key.

throttled: bool

Whether the event was throttled.

next: String

Chosen next node id.

RetryCompensate

Explicit retry/compensation execution result.

Fields

tool: String

Primary tool name.

attempts: usize

Total primary attempts executed.

compensated: bool

Whether compensation path was used.

output: Value

Node output payload.

next: String

Chosen next node id.

HumanInTheLoop

Human decision result.

Fields

approved: bool

True when approved.

response: Value

Optional human payload routed through the node.

next: String

Chosen next node id.

CacheRead

Cache read result.

Fields

key: String

Cache key.

hit: bool

True when key was found.

value: Value

Returned value (null on miss).

next: String

Chosen next node id.

CacheWrite

Cache write result.

Fields

key: String

Cache key.

value: Value

Stored value.

next: String

Next node id.

EventTrigger

Event trigger evaluation result.

Fields

event: String

Expected event name.

matched: bool

True when input event matched.

next: String

Chosen next node id.

Router

Router/selector decision.

Fields

selected: String

Selected route node id.

next: String

Chosen next node id.

Transform

Transform node output.

Fields

expression: String

Original transform expression.

output: Value

Evaluated output payload.

next: String

Next node id.

Loop

Loop node decision.

Fields

condition: String

Original loop condition.

evaluated: bool

Evaluated bool.

iteration: u32

Current iteration when entering body. Zero when exiting loop.

next: String

Chosen next node id.

Subgraph

Subgraph execution result.

Fields

graph: String

Subgraph registry key.

terminal_node_id: String

Subgraph terminal node id.

output: Value

Aggregated subgraph node outputs.

next: String

Next node id.

Batch

Batch extraction result.

Fields

items_path: String

Source path used for extraction.

item_count: usize

Number of extracted items.

next: String

Next node id.

Filter

Filter evaluation result.

Fields

items_path: String

Source path used for extraction.

expression: String

Filter predicate expression.

kept: usize

Number of retained items.

next: String

Next node id.

Parallel

Parallel node aggregate result.

Fields

branches: Vec<String>

Branch node ids executed by this node.

outputs: BTreeMap<String, Value>

Branch outputs keyed by branch node id.

next: String

Next node id.

Merge

Merge node aggregate output.

Fields

policy: MergePolicy

Merge policy used.

sources: Vec<String>

Source node ids consumed.

output: Value

Merged value.

next: String

Next node id.

Map

Map node output.

Fields

item_count: usize

Number of input items mapped.

output: Value

Collected mapped values in source order.

next: String

Next node id.

Reduce

Reduce node output.

Fields

operation: ReduceOperation

Reduce operation executed.

output: Value

Reduced result.

next: String

Next node id.

End

End node reached.

Trait Implementations

impl Clone for NodeExecutionData

fn clone(&self) -> NodeExecutionData

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NodeExecutionData

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

Formats the value using the given formatter.

impl PartialEq for NodeExecutionData

fn eq(&self, other: &NodeExecutionData) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for NodeExecutionData