ri-agent-graph 0.2.4

Run 9 agents at once — graph-based agent orchestration for Rust with parallel fan-out (up to 16 nodes), fan-in joins, checkpointing, interrupt/resume, and event streaming
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! # agent-graph
//!
//! Graph-based agent orchestration for Rust - LangGraph for the Rust ecosystem.
//!
//! ## Quick Start
//!
//! ```rust,no_run
//! use ri_agent_graph::prelude::*;
//!
//! #[tokio::main]
//! async fn main() -> Result<()> {
//!     let graph = AgentGraph::builder()
//!         .add_node("step1", node!(|state| async move {
//!             state.set("count", 1).await?;
//!             Ok(())
//!         }))
//!         .add_node("step2", node!(|state| async move {
//!             let count: i32 = state.get("count").await?;
//!             state.set("count", count + 1).await?;
//!             Ok(())
//!         }))
//!         .add_edge("step1", "step2")
//!         .build()?;
//!
//!     let state = AgentState::new();
//!     let result = graph.execute("step1", state).await?;
//!
//!     let final_count: i32 = result.get("count").await?;
//!     assert_eq!(final_count, 2);
//!
//!     Ok(())
//! }
//! ```

pub mod builder;
pub mod checkpoint_store;
pub mod checkpointer;
pub mod command;
pub mod config;
pub mod edge;
pub mod engine;
pub mod error;
pub mod event_sink;
pub mod execution_cursor;
pub mod executor;
pub mod graph;
pub mod interrupt;
pub mod join;
pub mod node;
pub mod outcome;
pub mod payload;
pub mod prelude;
pub mod receipt;
pub mod reducer;
pub mod retry;
pub mod router;
pub mod state;
pub mod stream;

#[cfg(feature = "checkpointing")]
pub mod checkpoint;

pub use error::{AgentGraphError, CheckpointStoreOperation, Result};
pub use graph::{AgentGraph, END, START};
pub use receipt::{ExecutionOutcome, GraphExecutionReceiptV1, StepExecutionReceiptV1};
pub use state::AgentState;