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

//! Convenience re-exports for common use

// Core graph types
pub use crate::config::GraphConfig;
pub use crate::edge::EdgeType;
pub use crate::error::{AgentGraphError, CheckpointStoreOperation, Result};
pub use crate::graph::{AgentGraph, AgentGraphBuilder, END, START};
pub use crate::state::{AgentState, StateLimits, StateSnapshot, StateTransaction};

// Node types
pub use crate::command::{Command, Navigation, NodeOutput, SendOp};
pub use crate::join::JoinNode;
pub use crate::node::{FnNode, Node};
pub use crate::payload::{Payload, PayloadContext, PayloadError, PayloadNode, PayloadOutput};

// Routing
pub use crate::router::{FnRouter, RouterOutput, RoutingFunction};

// Execution outcomes
pub use crate::outcome::{Interrupt, InterruptKind, NodeOutcome};

// Event system
pub use crate::event_sink::{
    CallbackEventSink, ChannelEventSink, CompositeEventSink, EventSink, GraphEvent,
    NodeOutcomeKind, NoopEventSink,
};
pub use crate::stream::{StreamEvent, StreamMode};

// Checkpoint store (granular)
pub use crate::checkpoint_store::{
    AttemptRecord, AttemptStatus, CheckpointAttemptId, CheckpointMetadata, CheckpointStore,
    InMemoryCheckpointStore, RunId, RunState, RunStatus, RunSummary,
};

// Legacy checkpoint system
pub use crate::checkpointer::{CheckpointSaver, MemorySaver};

// Executor
pub use crate::executor::{Executor, InProcessExecutor};

// Reducers
pub use crate::reducer::{
    AddReducer, AppendReducer, FnReducer, LastWriteWins, MergeReducer, Reducer,
};

// Retry
pub use crate::retry::RetryPolicy;

// Interrupt (legacy)
pub use crate::interrupt::{ExecutionResult, InterruptCheckpoint, InterruptConfig};

// Re-export macros
pub use crate::{node, router};

#[cfg(feature = "checkpointing")]
pub use crate::checkpoint::{Checkpoint, CheckpointManager};
pub use crate::execution_cursor::{ExecutionCursor, InterruptPhase};

#[cfg(feature = "checkpointing")]
pub use crate::checkpointer::SqliteSaver;