Struct StateGraphImpl 

pub struct StateGraphImpl<S>
where
    S: GraphState,
{ /* private fields */ }

StateGraph implementation - LangGraph-inspired API

Example

use mofa_foundation::workflow::{StateGraphImpl, AppendReducer, OverwriteReducer};
use mofa_kernel::workflow::{StateGraph, START, END};

let graph = StateGraphImpl::<MyState>::new("my_workflow")
    .add_reducer("messages", Box::new(AppendReducer))
    .add_node("process", Box::new(ProcessNode))
    .add_edge(START, "process")
    .add_edge("process", END)
    .compile()?;

Implementations

impl<S> StateGraphImpl<S>

where S: GraphState,

pub fn build(id: impl Into<String>) -> StateGraphImpl<S>

Create a new StateGraph builder with the given ID

pub fn node_count(&self) -> usize

Get the number of nodes

pub fn edge_count(&self) -> usize

Get the number of edges

pub fn node_ids(&self) -> Vec<&str>

Get all node IDs

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

Validate the graph structure

Trait Implementations

impl<S> StateGraph for StateGraphImpl<S>

where S: GraphState + 'static,

type State = S

The state type for this graph

type Compiled = CompiledGraphImpl<S>

The compiled graph type produced by this builder

fn new(id: impl Into<String>) -> StateGraphImpl<S>

Create a new graph with the given ID

fn add_node( &mut self, id: impl Into<String>, node: Box<dyn NodeFunc<S>>, ) -> &mut StateGraphImpl<S>

Add a node to the graph

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

Add an edge between two nodes

fn add_conditional_edges( &mut self, from: impl Into<String>, conditions: HashMap<String, String>, ) -> &mut StateGraphImpl<S>

Add conditional edges from a node

fn add_parallel_edges( &mut self, from: impl Into<String>, targets: Vec<String>, ) -> &mut StateGraphImpl<S>

Add parallel edges from a node

fn set_entry_point(&mut self, node: impl Into<String>) -> &mut StateGraphImpl<S>

Set the entry point (equivalent to add_edge(START, node))

fn set_finish_point( &mut self, node: impl Into<String>, ) -> &mut StateGraphImpl<S>

Set a finish point (equivalent to add_edge(node, END))

fn add_reducer( &mut self, key: impl Into<String>, reducer: Box<dyn Reducer>, ) -> &mut StateGraphImpl<S>

Add a reducer for a state key

fn with_config(&mut self, config: GraphConfig) -> &mut StateGraphImpl<S>

Set the graph configuration

fn id(&self) -> &str

Get the graph ID

fn compile(self) -> Result<CompiledGraphImpl<S>, AgentError>

Compile the graph into an executable form