Struct GraphAgentBuilder 

pub struct GraphAgentBuilder { /* private fields */ }

Builder for GraphAgent

Implementations

impl GraphAgentBuilder

pub fn new(name: &str) -> Self

Create a new builder

pub fn description(self, desc: &str) -> Self

Set description

pub fn state_schema(self, schema: StateSchema) -> Self

Set state schema

pub fn channels(self, channels: &[&str]) -> Self

Add channels to state schema

pub fn node<N: Node + 'static>(self, node: N) -> Self

Add a node

pub fn node_fn<F, Fut>(self, name: &str, func: F) -> Self

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

Add a function as a node

pub fn edge(self, source: &str, target: &str) -> Self

Add a direct edge

pub fn conditional_edge<F, I>(self, source: &str, router: F, targets: I) -> Self

where F: Fn(&State) -> String + Send + Sync + 'static, I: IntoIterator<Item = (&'static str, &'static str)>,

Add a conditional edge

pub fn checkpointer<C: Checkpointer + 'static>(self, checkpointer: C) -> Self

Set checkpointer

pub fn checkpointer_arc(self, checkpointer: Arc<dyn Checkpointer>) -> Self

Set checkpointer with Arc

pub fn interrupt_before(self, nodes: &[&str]) -> Self

Set nodes to interrupt before

pub fn interrupt_after(self, nodes: &[&str]) -> Self

Set nodes to interrupt after

pub fn recursion_limit(self, limit: usize) -> Self

Set recursion limit

pub fn input_mapper<F>(self, mapper: F) -> Self

where F: Fn(&dyn InvocationContext) -> State + Send + Sync + 'static,

Set custom input mapper

pub fn output_mapper<F>(self, mapper: F) -> Self

where F: Fn(&State) -> Vec<Event> + Send + Sync + 'static,

Set custom output mapper

pub fn before_agent_callback<F, Fut>(self, callback: F) -> Self

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

Set before agent callback

pub fn after_agent_callback<F, Fut>(self, callback: F) -> Self

where F: Fn(Arc<dyn InvocationContext>, Event) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Set after agent callback

Note: The callback receives a cloned Event to avoid lifetime issues.

pub fn build(self) -> Result<GraphAgent>

Build the GraphAgent