Enum NodeDefinition 

pub enum NodeDefinition {
    Start {
        id: String,
        name: Option<String>,
    },
    End {
        id: String,
        name: Option<String>,
    },
    Task {
        id: String,
        name: String,
        executor: TaskExecutorDef,
        config: NodeConfigDef,
    },
    LLM_AGENT {
        id: String,
        name: String,
        agent: AgentRef,
        prompt_template: Option<String>,
        config: NodeConfigDef,
    },
    Condition {
        id: String,
        name: String,
        condition: ConditionDef,
        config: NodeConfigDef,
    },
    Parallel {
        id: String,
        name: String,
        config: NodeConfigDef,
    },
    Join {
        id: String,
        name: String,
        wait_for: Vec<String>,
        config: NodeConfigDef,
    },
    Loop {
        id: String,
        name: String,
        body: TaskExecutorDef,
        condition: LoopConditionDef,
        max_iterations: u32,
        config: NodeConfigDef,
    },
    Transform {
        id: String,
        name: String,
        transform: TransformDef,
        config: NodeConfigDef,
    },
    SubWorkflow {
        id: String,
        name: String,
        workflow_id: String,
        config: NodeConfigDef,
    },
    Wait {
        id: String,
        name: String,
        event_type: String,
        config: NodeConfigDef,
    },
}

Node definition (tagged enum for different node types)

Variants

Start

Start node

Fields

id: String

name: Option<String>

End

End node

Fields

id: String

name: Option<String>

Task

Task node (custom executor)

Fields

id: String

name: String

executor: TaskExecutorDef

config: NodeConfigDef

LLM_AGENT

LLM Agent node

Fields

id: String

name: String

agent: AgentRef

Agent reference (agent_id for registry agents, inline for embedded)

prompt_template: Option<String>

Optional prompt template

config: NodeConfigDef

Condition

Condition node

Fields

id: String

name: String

condition: ConditionDef

config: NodeConfigDef

Parallel

Parallel node

Fields

id: String

name: String

config: NodeConfigDef

Join

Join node

Fields

id: String

name: String

wait_for: Vec<String>

List of node IDs to wait for

config: NodeConfigDef

Loop

Loop node

Fields

id: String

name: String

body: TaskExecutorDef

condition: LoopConditionDef

max_iterations: u32

config: NodeConfigDef

Transform

Transform node

Fields

id: String

name: String

transform: TransformDef

config: NodeConfigDef

SubWorkflow

Sub-workflow node

Fields

id: String

name: String

workflow_id: String

Reference to another workflow

config: NodeConfigDef

Wait

Wait node

Fields

id: String

name: String

event_type: String

Event type to wait for

config: NodeConfigDef

Implementations

impl NodeDefinition

pub fn id(&self) -> &str

Get the node ID

pub fn node_type(&self) -> NodeType

Get the node type

Trait Implementations

impl Clone for NodeDefinition

fn clone(&self) -> NodeDefinition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeDefinition

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeDefinition

fn deserialize<__D>( __deserializer: __D, ) -> Result<NodeDefinition, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for NodeDefinition

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

where __S: Serializer,

Serialize this value into the given Serde serializer.