Struct Workflow 

pub struct Workflow {
    pub metadata: WorkflowMetadata,
    pub nodes: Vec<Node>,
    pub edges: Vec<Edge>,
}

Complete workflow definition

Fields

metadata: WorkflowMetadata

Workflow metadata

nodes: Vec<Node>

Nodes in the workflow

edges: Vec<Edge>

Edges connecting the nodes

Implementations

impl Workflow

pub fn new(name: String) -> Self

pub fn add_node(&mut self, node: Node)

Add a node to the workflow

pub fn add_edge(&mut self, edge: Edge)

Add an edge to the workflow

pub fn get_node(&self, id: &NodeId) -> Option<&Node>

Find a node by its ID

pub fn get_node_mut(&mut self, id: &NodeId) -> Option<&mut Node>

Find a mutable node by its ID

pub fn find_nodes_by_kind(&self, kind: &NodeKind) -> Vec<&Node>

Find all nodes of a specific kind

pub fn get_start_node(&self) -> Option<&Node>

Get the start node of the workflow

pub fn get_end_nodes(&self) -> Vec<&Node>

Get all end nodes of the workflow

pub fn remove_node(&mut self, id: &NodeId) -> bool

Remove a node and all its associated edges

pub fn remove_edge(&mut self, from: &NodeId, to: &NodeId) -> bool

Remove an edge between two nodes

pub fn node_count(&self) -> usize

Get the number of nodes in the workflow

pub fn edge_count(&self) -> usize

Get the number of edges in the workflow

pub fn get_outgoing_edges(&self, node_id: &NodeId) -> Vec<&Edge>

Get all outgoing edges from a node

pub fn get_incoming_edges(&self, node_id: &NodeId) -> Vec<&Edge>

Get all incoming edges to a node

pub fn validate(&self) -> Result<(), String>

Validate the workflow structure with comprehensive checks

pub fn to_json(&self) -> Result<String, String>

Export workflow to JSON string

pub fn to_json_file(&self, path: &str) -> Result<(), String>

Export workflow to JSON file

pub fn from_json(json: &str) -> Result<Self, String>

Import workflow from JSON string

pub fn from_json_file(path: &str) -> Result<Self, String>

Import workflow from JSON file

pub fn to_yaml(&self) -> Result<String, String>

Export workflow to YAML string

pub fn to_yaml_file(&self, path: &str) -> Result<(), String>

Export workflow to YAML file

pub fn from_yaml(yaml: &str) -> Result<Self, String>

Import workflow from YAML string

pub fn from_yaml_file(path: &str) -> Result<Self, String>

Import workflow from YAML file

pub fn create_new_version( &self, change_description: String, version_type: VersionBump, ) -> Self

Create a new version of this workflow

pub fn is_newer_than(&self, other: &Workflow) -> Result<bool, String>

Check if this workflow is a newer version of another

pub fn version_tuple(&self) -> Result<(u32, u32, u32), String>

Get version as tuple for comparison

Trait Implementations

impl Clone for Workflow

fn clone(&self) -> Workflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Workflow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Workflow

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Workflow

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

where __S: Serializer,

Serialize this value into the given Serde serializer.