Struct GraphBuilder 

pub struct GraphBuilder { /* private fields */ }

Builder for creating graphs

Implementations

impl GraphBuilder

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

Create a new graph builder

pub fn name(self, name: impl Into<String>) -> Self

Set graph name

pub fn add_node<F, Fut>(self, id: impl Into<String>, func: F) -> Self

where F: Fn(GraphState) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<GraphState, CrewError>> + Send + 'static,

Add a node with an async function

pub fn add_node_executor( self, id: impl Into<String>, executor: Arc<dyn NodeFn>, ) -> Self

Add a node with a custom executor

pub fn add_edge(self, from: impl Into<String>, to: impl Into<String>) -> Self

Add a direct edge between two nodes

pub fn add_conditional_edge<F>(self, from: impl Into<String>, router: F) -> Self

where F: Fn(&GraphState) -> String + Send + Sync + 'static,

Add a conditional edge with a routing function

pub fn add_conditional_edge_router( self, from: impl Into<String>, router: ConditionRouter, ) -> Self

Add a conditional edge with a ConditionRouter

pub fn set_entry(self, node_id: impl Into<String>) -> Self

Set the entry node

pub fn max_iterations(self, max: u32) -> Self

Set maximum iterations

pub fn with_checkpointing(self, store: Arc<dyn CheckpointStore>) -> Self

Enable checkpointing

pub fn checkpoint_interval(self, interval: u32) -> Self

Set checkpoint interval

pub fn node_timeout_ms(self, timeout: u64) -> Self

Set node timeout

pub fn build(self) -> Result<Graph, CrewError>

Build the graph

Trait Implementations

impl GraphBuilderSubgraphExt for GraphBuilder

fn add_subgraph( self, id: impl Into<String>, graph: Graph, mapping: StateMapping, ) -> Self

Add a subgraph as a node

fn add_parallel_subgraphs( self, id: impl Into<String>, parallel: ParallelSubgraphs, ) -> Self

Add a parallel subgraphs node

fn add_conditional_subgraph( self, id: impl Into<String>, conditional: ConditionalSubgraph, ) -> Self

Add a conditional subgraph node

fn add_loop_subgraph(self, id: impl Into<String>, loop_sg: LoopSubgraph) -> Self

Add a loop subgraph node

fn add_retry_subgraph(self, id: impl Into<String>, retry: RetrySubgraph) -> Self

Add a retry subgraph node