Struct Workflow 

pub struct Workflow {
    pub id: String,
    pub name: String,
    pub nodes: Vec<Arc<dyn WorkflowNode>>,
    pub edges: Vec<WorkflowEdge>,
    pub start_node: String,
}

Workflow definition.

Fields

id: String

Workflow ID.

name: String

Workflow name.

nodes: Vec<Arc<dyn WorkflowNode>>

Nodes in the workflow.

edges: Vec<WorkflowEdge>

Edges connecting nodes.

start_node: String

Starting node ID.

Implementations

impl Workflow

pub fn new( id: impl Into<String>, name: impl Into<String>, start_node: impl Into<String>, ) -> Self

Create a new workflow.

pub fn add_node(&mut self, node: Arc<dyn WorkflowNode>)

Add a node.

pub fn add_edge(&mut self, from: impl Into<String>, to: impl Into<String>)

Add an edge.

pub fn add_conditional_edge( &mut self, from: impl Into<String>, to: impl Into<String>, condition: impl Into<String>, )

Add a conditional edge.

pub fn find_node(&self, id: &str) -> Option<&Arc<dyn WorkflowNode>>

Find node by ID.

pub fn outgoing_edges(&self, node_id: &str) -> Vec<&WorkflowEdge>

Find outgoing edges from a node.