Expand description
lellm-graph — Graph/Node/Edge 编排层 + 状态管理 + Checkpoint。
通用工作流引擎（类似 LangGraph / Temporal / Prefect）。
Re-exports§
pub use checkpoint::TraceId;pub use ids::SpanId;pub use state::ExecutionEntry;pub use state::GraphResult;pub use state::State;pub use state::StateEffect;pub use state::StateError;pub use state::StateExt;pub use state::StateMerge;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_ITERATIONS;pub use statekey::SK_MESSAGES;pub use statekey::SK_OUTPUT_TOKENS;pub use statekey::SK_PENDING_TOOL_CALLS;pub use statekey::SK_REASONING_TOKENS;pub use statekey::SK_STEPS;pub use statekey::SK_TOTAL_TOOL_CALLS;pub use statekey::StateKey;pub use statekey::StateKeyExt;pub use checkpoint::Checkpoint;pub use checkpoint::CheckpointId;pub use checkpoint::CheckpointPolicy;pub use checkpoint::CheckpointStore;pub use checkpoint::CheckpointStoreError;pub use checkpoint::NodeId;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::ParallelNodeBuilder;pub use node::TaskFn;pub use node::TaskNode;pub use executor::GraphExecutor;pub use hook::AgentHook;pub use hook::NoOpHook;pub use hook::TracingHook;pub use branch_state::BranchState;pub use branch_state::ChangeOperation;pub use branch_state::ChangeRecord;pub use node_context::ExecutionControl;pub use node_context::ExecutionSignal;pub use node_context::NextAction;pub use node_context::NodeContext;pub use node_context::NodeMetadata;pub use runtime_event::RuntimeEvent;pub use stream_chunk::StreamChunk;pub use stream_emitter::StreamEmitter;pub use workflow_state::Effect;pub use workflow_state::LastWriteWins;pub use workflow_state::MergeStrategy;pub use workflow_state::WorkflowError;pub use workflow_state::WorkflowState;pub use trace::ExecutionTrace;pub use trace::ExportedTrace;pub use trace::ExportedTraceStep;pub use trace::MemoryTraceSink;pub use trace::TraceSink;pub use trace::TraceStep;
Modules§
- barrier_
node - Human-in-the-loop 审批节点。
- branch_
state - BranchState — Overlay State 模型。
- checkpoint
- Checkpoint — 执行恢复的唯一数据源。
- delta
- StateDelta + Reducer — 键级状态增量与合并策略。
- error
- Graph 错误类型。
- event
- Graph 层流式事件。
- executor
- Graph 执行引擎。
- graph
- Graph 和 GraphBuilder。
- hook
- AgentHook — 可观测性扩展点。
- ids
- TraceId / SpanId — 执行追踪标识符。
- node
- 节点核心类型与模块。
- node_
context - NodeContext + ExecutionControl + StreamEmitter — v04 核心类型。
- parallel_
node - ParallelNode — 并行执行多个分支，通过 MergeStrategy 合并 State。
- runtime_
event - RuntimeEvent — Control Plane 控制面事件。
- state
- State 和执行结果。
- statekey
- StateKey
— 编译期类型安全的 State 键。 - store
- Checkpoint 存储后端实现 — 内存后端。
- stream_
chunk - StreamChunk — Data Plane 数据面事件。
- stream_
emitter - StreamEmitter — 数据面发射器。
- trace
- ExecutionTrace + TraceSink — 审计日志，与 Checkpoint 分离。
- workflow_
state - WorkflowState + Effect + MergeStrategy — Typed State 框架。