langchainrust 0.2.15

A LangChain-inspired framework for building LLM applications in Rust. Supports OpenAI, Agents, Tools, Memory, Chains, RAG, BM25, Hybrid Retrieval, LangGraph, HyDE, Reranking, MultiQuery, and native Function Calling.
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
67
68
69
70
71
72
73
74
75
76
77

// src/langgraph/mod.rs
//! LangGraph - Graph-based orchestration framework for building stateful LLM applications
//!
//! LangGraph provides a low-level graph orchestration framework that enables:
//! - Stateful, long-running agent workflows
//! - Conditional routing and branching
//! - Subgraph composition
//! - Cycle support for iterative processes
//!
//! # Core Concepts
//!
//! - **StateGraph**: Main graph class that manages State, Nodes, and Edges
//! - **Node**: Execution unit that takes state and produces state updates
//! - **Edge**: Transition between nodes (fixed or conditional)
//! - **State**: Data structure that flows through the graph
//!
//! # Example
//!
//! ```rust,ignore
//! use langchainrust::langgraph::{StateGraph, GraphNode, StateSchema, START, END};
//! use serde::{Deserialize, Serialize};
//!
//! // Define state
//! #[derive(Serialize, Deserialize, Clone)]
//! struct MyState {
//!     messages: Vec<String>,
//!     count: usize,
//! }
//!
//! impl StateSchema for MyState {}
//!
//! // Create graph
//! let mut graph = StateGraph::<MyState>::new();
//!
//! // Add nodes
//! graph.add_node("process", |state: MyState| {
//!     MyState {
//!         messages: state.messages.clone(),
//!         count: state.count + 1,
//!     }
//! });
//!
//! // Add edges
//! graph.add_edge(START, "process");
//! graph.add_edge("process", END);
//!
//! // Compile and run
//! let compiled = graph.compile();
//! let result = compiled.invoke(MyState { messages: vec![], count: 0 }).await?;
//! ```

pub mod state;
pub mod node;
pub mod edge;
pub mod graph;
pub mod compiled;
pub mod errors;
pub mod checkpointer;
pub mod subgraph;
pub mod persistence;

// Re-export core types
pub use state::{StateSchema, StateUpdate, Reducer, ReplaceReducer, AppendReducer, AppendMessagesReducer, AppendStepsReducer, AgentState, MessageEntry, MessageRole, StepEntry};
pub use node::{GraphNode, NodeResult, NodeConfig, AsyncNode, AsyncFn};
pub use edge::{GraphEdge, ConditionalEdge, EdgeTarget, FunctionRouter, AsyncFunctionRouter};
pub use graph::{StateGraph, GraphBuilder, START, END};
pub use compiled::{CompiledGraph, GraphInvocation, StreamEvent, ExecutionStep, GraphExecution, ParallelInvocation, ParallelBranch};
pub use errors::{GraphError, GraphResult};
pub use checkpointer::{Checkpointer, MemoryCheckpointer, ThreadSafeMemoryCheckpointer, FileCheckpointer, CheckpointData};
pub use subgraph::{SubgraphNode, SubgraphBuilder};
pub use persistence::{
    GraphPersistence, GraphDefinition, NodeDefinition, EdgeDefinition,
    NodeType, EdgeType, RouterDefinition, MemoryPersistence, FilePersistence,
};

#[cfg(feature = "mongodb-persistence")]
pub use persistence::{MongoPersistence, MongoConfig};