Struct GraphFlow 

pub struct GraphFlow { /* private fields */ }

DAG of flows. Each node is itself a flow; edges route based on node output. A node without an outgoing edge is terminal — its output is the graph’s output.

Implementations

impl GraphFlow

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

New empty graph rooted at entry. The entry node must be added via GraphFlow::node before GraphFlow::run is called.

pub fn node(self, name: impl Into<String>, flow: Arc<dyn Flow>) -> Self

Insert a node.

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

where A: Agent + 'static,

Convenience builder that wraps a concrete klieo_core::agent::Agent in crate::flow::AgentFlow + upcasts to Arc<dyn Flow> in one call.

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

Add an unconditional edge from -> to.

pub fn edge_branch<F>( self, from: impl Into<String>, predicate: F, on_true: impl Into<String>, on_false: impl Into<String>, ) -> Self

where F: Fn(&Value) -> bool + Send + Sync + 'static,

Add a conditional edge from from that branches on predicate.

pub fn with_max_steps(self, n: u32) -> Self

Override the default step cap (32). Hitting it returns FlowError::Graph("max_steps exceeded; possible cycle").

Trait Implementations

impl Flow for GraphFlow

fn name(&self) -> &str

Stable flow name. Used in tracing spans.

fn run<'life0, 'async_trait>( &'life0 self, ctx: AgentContext, input: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, FlowError>> + Send + 'async_trait>>

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

Execute the flow once.