Struct AgentGraph 

pub struct AgentGraph { /* private fields */ }

The agent graph — an orchestrator that owns control-flow and delegates node work to the Payload layer.

Implementations

impl AgentGraph

Execution-related methods on AgentGraph.

pub async fn execute( &self, start_node: &str, state: AgentState, ) -> Result<AgentState>

Execute the graph starting from a specific node.

pub async fn execute_with_summary( &self, start_node: &str, state: AgentState, config: GraphConfig, ) -> (Result<AgentState>, RunSummary)

Execute the graph and return a structured run summary alongside the result.

pub async fn execute_with_config( &self, start_node: &str, state: AgentState, config: GraphConfig, ) -> Result<AgentState>

Execute the graph with a runtime config.

pub async fn execute_with_interrupt( &self, start_node: &str, state: AgentState, config: GraphConfig, ) -> ExecutionResult

Execute the graph with interrupt support.

pub fn execute_cancellable( self: Arc<Self>, start_node: &str, state: AgentState, config: GraphConfig, ) -> (JoinHandle<Result<AgentState>>, Arc<AtomicBool>)

Execute with cancellation support using an Arc-wrapped graph.

pub fn stream( self: Arc<Self>, start_node: &str, state: AgentState, config: GraphConfig, ) -> (JoinHandle<Result<AgentState>>, Receiver<StreamEvent>)

Execute with streaming using Arc-wrapped graph. Returns a join handle for the result and a receiver for events.

impl AgentGraph

pub fn builder() -> AgentGraphBuilder

Create a new graph builder.

pub async fn resume( &self, state: AgentState, config: GraphConfig, checkpoint: InterruptCheckpoint, ) -> Result<AgentState>

Resume execution from an interrupt checkpoint.

Validates that the graph topology hasn’t changed since the checkpoint was taken. Returns CheckpointMismatch if the graph hash differs. Use Self::resume_force to skip this check.

pub async fn resume_force( &self, state: AgentState, config: GraphConfig, checkpoint: InterruptCheckpoint, ) -> Result<AgentState>

Resume execution from an interrupt checkpoint without validating graph topology.

pub async fn get_state( &self, config: &GraphConfig, ) -> Result<Option<AgentState>>

Get current state from checkpointer.

pub async fn get_state_history( &self, config: &GraphConfig, ) -> Result<Vec<Checkpoint>>

Get checkpoint history for a thread.

pub async fn update_state( &self, config: &GraphConfig, updates: HashMap<String, Value>, ) -> Result<()>

Update state in the checkpointer (time travel).

pub fn to_mermaid(&self) -> String

Generate a Mermaid diagram of the graph structure.

pub fn name(&self) -> Option<&str>

Get the graph name.

pub fn node_names(&self) -> Vec<&String>

Get the node names.

pub fn edge_map(&self) -> &HashMap<String, Vec<EdgeType>>

Get the edge map for inspection.

pub fn compute_graph_hash(&self) -> String

Compute a stable hash of the graph’s topology (node names + edges).

Used to detect graph-definition drift when resuming from a checkpoint. Two graphs with the same nodes and edges produce the same hash.

Trait Implementations

impl Debug for AgentGraph

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

Formats the value using the given formatter.

impl Node for AgentGraph

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 AgentState, config: &'life2 GraphConfig, ) -> Pin<Box<dyn Future<Output = Result<NodeOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute this node

fn name(&self) -> Option<&str>

Optional: Get a name for this node (for debugging)