Enum NodeKind 

pub enum NodeKind {
    Start {
        next: String,
    },
    Llm {
        model: String,
        prompt: String,
        next: Option<String>,
    },
    Tool {
        tool: String,
        input: Value,
        next: Option<String>,
    },
    Condition {
        expression: String,
        on_true: String,
        on_false: String,
    },
    Debounce {
        key_path: String,
        window_steps: u32,
        next: String,
        on_suppressed: Option<String>,
    },
    Throttle {
        key_path: String,
        window_steps: u32,
        next: String,
        on_throttled: Option<String>,
    },
    RetryCompensate {
        tool: String,
        input: Value,
        max_retries: usize,
        compensate_tool: String,
        compensate_input: Value,
        next: String,
        on_compensated: Option<String>,
    },
    HumanInTheLoop {
        decision_path: String,
        response_path: Option<String>,
        on_approve: String,
        on_reject: String,
    },
    CacheWrite {
        key_path: String,
        value_path: String,
        next: String,
    },
    CacheRead {
        key_path: String,
        next: String,
        on_miss: Option<String>,
    },
    EventTrigger {
        event: String,
        event_path: String,
        next: String,
        on_mismatch: Option<String>,
    },
    Router {
        routes: Vec<RouterRoute>,
        default: String,
    },
    Transform {
        expression: String,
        next: String,
    },
    Loop {
        condition: String,
        body: String,
        next: String,
        max_iterations: Option<u32>,
    },
    Subgraph {
        graph: String,
        next: Option<String>,
    },
    Batch {
        items_path: String,
        next: String,
    },
    Filter {
        items_path: String,
        expression: String,
        next: String,
    },
    Parallel {
        branches: Vec<String>,
        next: String,
        max_in_flight: Option<usize>,
    },
    Merge {
        sources: Vec<String>,
        policy: MergePolicy,
        quorum: Option<usize>,
        next: String,
    },
    Map {
        tool: String,
        items_path: String,
        next: String,
        max_in_flight: Option<usize>,
    },
    Reduce {
        source: String,
        operation: ReduceOperation,
        next: String,
    },
    End,
}

Canonical node taxonomy for v0.

Variants

Start

Entry node. Must have exactly one in the workflow.

Fields

next: String

Llm

LLM call node.

Fields

model: String

prompt: String

next: Option<String>

Tool

Tool invocation node.

Fields

tool: String

input: Value

next: Option<String>

Condition

Conditional branching node.

Fields

expression: String

on_true: String

on_false: String

Debounce

Debounces repeated events for a key across nearby steps.

Fields

key_path: String

window_steps: u32

next: String

on_suppressed: Option<String>

Throttle

Throttles repeated events for a key to one pass per window.

Fields

key_path: String

window_steps: u32

next: String

on_throttled: Option<String>

RetryCompensate

Explicit retry node with compensation fallback.

Fields

tool: String

input: Value

max_retries: usize

compensate_tool: String

compensate_input: Value

next: String

on_compensated: Option<String>

HumanInTheLoop

Human decision gate that routes on approve/reject.

Fields

decision_path: String

response_path: Option<String>

on_approve: String

on_reject: String

CacheWrite

Writes a value into runtime cache.

Fields

key_path: String

value_path: String

next: String

CacheRead

Reads a value from runtime cache.

Fields

key_path: String

next: String

on_miss: Option<String>

EventTrigger

Event gate for schedule/cron/webhook style entry checks.

Fields

event: String

event_path: String

next: String

on_mismatch: Option<String>

Router

Router/selector node that picks first matching route.

Fields

routes: Vec<RouterRoute>

default: String

Transform

Deterministic transform node using JSON literal or path expression.

Fields

expression: String

next: String

Loop

Loop node with explicit body and exit transitions.

Fields

condition: String

body: String

next: String

max_iterations: Option<u32>

Subgraph

Executes a registered subgraph in an isolated child scope.

Fields

graph: String

next: Option<String>

Batch

Captures an array payload from scope for downstream processing.

Fields

items_path: String

next: String

Filter

Filters an array payload deterministically with a boolean expression.

Fields

items_path: String

expression: String

next: String

Parallel

Concurrently executes branch nodes and continues to next.

Fields

branches: Vec<String>

next: String

max_in_flight: Option<usize>

Merge

Merges outputs from source nodes according to policy.

Fields

sources: Vec<String>

policy: MergePolicy

quorum: Option<usize>

next: String

Map

Applies a tool to each item in an array from scoped input.

Fields

tool: String

items_path: String

next: String

max_in_flight: Option<usize>

Reduce

Reduces an array output into a single value.

Fields

source: String

operation: ReduceOperation

next: String

End

Terminal node.

Trait Implementations

impl Clone for NodeKind

fn clone(&self) -> NodeKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeKind

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeKind

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for NodeKind

fn eq(&self, other: &NodeKind) -> 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 Serialize for NodeKind

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for NodeKind