Struct Graph 

pub struct Graph { /* private fields */ }

A graph of agents for orchestrated execution.

Implementations

impl Graph

pub fn builder() -> GraphBuilder

Creates a new graph builder.

pub fn graph_id(&self) -> &str

Returns the graph ID.

pub fn state(&self) -> &GraphState

Returns the current graph state.

pub fn node_ids(&self) -> impl Iterator<Item = &str>

Returns an iterator over node IDs.

pub fn entry_points(&self) -> &HashSet<String>

Returns the entry point node IDs.

pub fn interrupt_state(&self) -> &InterruptState

Returns a reference to the interrupt state.

pub fn interrupt_state_mut(&mut self) -> &mut InterruptState

Returns a mutable reference to the interrupt state.

pub fn call(&mut self, task: impl Into<MultiAgentInput>) -> Result<GraphResult>

Invokes the graph synchronously.

pub async fn invoke_async( &mut self, task: MultiAgentInput, invocation_state: Option<&InvocationState>, ) -> Result<GraphResult>

Invokes the graph asynchronously and returns the result.

pub fn stream_async<'a>( &'a mut self, task: MultiAgentInput, _invocation_state: Option<&'a InvocationState>, ) -> MultiAgentEventStream<'a>

Streams events during graph execution.

Trait Implementations

impl MultiAgentBase for Graph

fn id(&self) -> &str

Returns the unique ID of this multi-agent system.

fn invoke_async<'life0, 'life1, 'async_trait>( &'life0 mut self, task: MultiAgentInput, invocation_state: Option<&'life1 InvocationState>, ) -> Pin<Box<dyn Future<Output = Result<MultiAgentResult>> + Send + 'async_trait>>

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

Invokes the multi-agent system asynchronously.

fn stream_async<'a>( &'a mut self, task: MultiAgentInput, invocation_state: Option<&'a InvocationState>, ) -> MultiAgentEventStream<'a>

Streams events during multi-agent execution.

fn serialize_state(&self) -> Value

Serializes the current state for persistence.

fn deserialize_state(&mut self, payload: &Value) -> Result<()>

Deserializes state from persistence.