Skip to main content

Crate lellm_graph

Crate lellm_graph 

Source
Expand description

lellm-graph — Graph/Node/Edge 编排层 + 状态管理 + Checkpoint。

通用工作流引擎(类似 LangGraph / Temporal / Prefect)。 吸收了原 lellm-runtime,包含 State/StateDelta/Checkpoint 等基础设施。 依赖 lellm-core,不依赖 agent/provider。

Re-exports§

pub use ids::SpanId;
pub use ids::TraceId;
pub use state::ExecutionEntry;
pub use state::GraphResult;
pub use state::State;
pub use state::StateError;
pub use state::StateExt;
pub use state::StateReducer;
pub use state::array_reducer;
pub use delta::DeltaOp;
pub use delta::DeltaSource;
pub use delta::Reducer;
pub use delta::ReducerRegistry;
pub use delta::StateDelta;
pub use statekey::SK_COUNT;
pub use statekey::SK_MESSAGES;
pub use statekey::SK_STEPS;
pub use statekey::StateKey;
pub use statekey::StateKeyExt;
pub use checkpoint::BarrierDecisionRecord;
pub use checkpoint::Checkpoint;
pub use checkpoint::CheckpointId;
pub use checkpoint::CheckpointPolicy;
pub use checkpoint::CheckpointScore;
pub use checkpoint::CheckpointStore;
pub use checkpoint::CheckpointStoreError;
pub use checkpoint::CheckpointTrigger;
pub use checkpoint::ExecutionMetadata;
pub use checkpoint::ExecutionTrace;
pub use checkpoint::GraphHashMode;
pub use checkpoint::IncrementalSnapshotState;
pub use checkpoint::NodeId;
pub use checkpoint::StateSnapshot;
pub use store::InMemoryCheckpointStore;
pub use error::BuildError;
pub use error::BuildErrors;
pub use error::Diagnostic;
pub use error::DiagnosticCategory;
pub use error::DiagnosticSeverity;
pub use error::GraphDiagnostics;
pub use error::GraphError;
pub use error::ObservedError;
pub use error::TerminalError;
pub use event::BarrierDecision;
pub use event::BarrierId;
pub use event::FlowEvent;
pub use event::GraphEvent;
pub use event::GraphExecution;
pub use event::GraphHandle;
pub use event::GraphStream;
pub use graph::CycleAnalysis;
pub use graph::Edge;
pub use graph::Graph;
pub use graph::GraphBuilder;
pub use node::BarrierDefaultAction;
pub use node::BarrierNode;
pub use node::BranchCondition;
pub use node::ConditionNode;
pub use node::ConditionNodeBuilder;
pub use node::FlowNode;
pub use node::NextStep;
pub use node::NodeKind;
pub use node::NodeOutput;
pub use node::ParallelErrorStrategy;
pub use node::ParallelNode;
pub use node::TaskFn;
pub use node::TaskNode;
pub use executor::GraphExecutor;
pub use hook::AgentHook;
pub use hook::NoOpHook;
pub use hook::TracingHook;

Modules§

barrier_node
Human-in-the-loop 审批节点。
checkpoint
Checkpoint + ExecutionTrace — 从 lellm-runtime 合并。
delta
StateDelta + Reducer — 键级状态增量与合并策略。
error
Graph 错误类型。
event
Graph 层流式事件。
executor
Graph 执行引擎。
graph
Graph 和 GraphBuilder。
hook
AgentHook — 可观测性扩展点。
ids
TraceId / SpanId — 执行追踪标识符。
node
节点核心类型与模块。
parallel_node
ParallelNode — 并行执行多个分支,合并 StateDelta。
state
State 和执行结果。
statekey
StateKey — 编译期类型安全的 State 键。
store
Checkpoint 存储后端实现 — 从 lellm-runtime 合并。