lellm-graph 0.4.4

Graph/Node/Edge orchestration layer for LeLLM — with State, Delta, Checkpoint
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

//! lellm-graph — Graph/Node/Edge 编排层 + 状态管理 + Checkpoint。
//!
//! 通用工作流引擎（类似 LangGraph / Temporal / Prefect）。

pub mod barrier_node;
pub mod barrier_wait;
pub mod checkpoint;
pub mod checkpoint_codec;
pub mod checkpoint_policy;
pub mod error;
pub mod event;
pub mod execution_engine;
pub mod execution_loop;
pub mod graph;
pub mod graph_analysis;
pub mod ids;
pub mod mutation_log;
pub mod node;
pub mod node_context;
pub mod parallel_node;
pub mod runtime_event;
pub mod state;
pub mod statekey;
pub mod store;
pub mod stream_chunk;
pub mod stream_emitter;
pub mod test_executor;
pub mod workflow_state;

// ─── IDs ─────────────────────────────────────────────────────
pub use checkpoint::TraceId;
pub use ids::SpanId;

// ─── State ───────────────────────────────────────────────────
pub use state::{
    ExecutionEntry, GraphResult, State, StateError, StateExt, StateMerge, StateMutation,
    StateReducer, array_reducer,
};

// ─── StateKey ────────────────────────────────────────────────
pub use statekey::{
    Reducer, SK_COUNT, SK_ITERATIONS, SK_MESSAGES, SK_OUTPUT_TOKENS, SK_PENDING_TOOL_CALLS,
    SK_REASONING_TOKENS, SK_STEPS, SK_TOTAL_TOOL_CALLS, StateKey, StateKeyExt,
};

// ─── Checkpoint ──────────────────────────────────────────────
#[allow(deprecated)]
pub use checkpoint::{
    Checkpoint, CheckpointBlob, CheckpointId, CheckpointPolicy, CheckpointStoreError, NodeId,
};

// ─── Checkpoint Policy ───────────────────────────────────────
pub use checkpoint_policy::{RetentionPolicy, TriggerPolicy};

// ─── Checkpoint Codec ────────────────────────────────────────
pub use checkpoint_codec::{CheckpointCodec, SerdeCheckpointCodec, TypedCheckpointStore};

// ─── Store ───────────────────────────────────────────────────
pub use store::{BlobCheckpointStore, InMemoryBlobStore};

// ─── Error Types ─────────────────────────────────────────────
pub use error::{
    BuildError, BuildErrors, Diagnostic, DiagnosticCategory, DiagnosticSeverity, GraphDiagnostics,
    GraphError, ObservedError, TerminalError,
};

// ─── Events ──────────────────────────────────────────────────
pub use event::{
    BarrierDecision, BarrierId, FlowEvent, GraphEvent, GraphExecution, GraphHandle, GraphStream,
};

// ─── Graph ───────────────────────────────────────────────────
pub use graph::{Edge, Graph, GraphBuilder};
pub use graph_analysis::CycleAnalysis;

// ─── Nodes ───────────────────────────────────────────────────
pub use node::{
    BarrierDefaultAction, BarrierNode, BranchCondition, ConditionNode, ConditionNodeBuilder,
    ExecutorOperation, FlowNode, LeafNode, NodeKind, ParallelErrorStrategy, ParallelNode,
    ParallelNodeBuilder, TaskFn, TaskNode,
};

// ─── Test Executor (SimpleExecutor 兼容层) ────────────────────
pub use test_executor::SimpleExecutor;

// ─── v04: ExecutionEngine + NodeContext + Stream ─────────────
pub use execution_engine::{
    ExecutionContext, ExecutionControl, ExecutionEngine, ExecutionSignal, ExecutionView,
    ExecutorState, NextAction, NodeMetadata,
};
pub use node_context::{LeafContext, NodeContext};
pub use runtime_event::RuntimeEvent;
pub use stream_chunk::{StreamChunk, ToolPhase};
pub use stream_emitter::{
    BufferedSink, ChannelSink, NoopSink, StreamHub, StreamSink, noop_sink, sink_arc,
    spawn_forward_task,
};
pub use tokio_util::sync::CancellationToken;
pub use workflow_state::{LastWriteWins, MergeStrategy, WorkflowError, WorkflowState};

// ─── Trace ───────────────────────────────────────────────────
pub mod trace;
pub use trace::{
    ExecutionTrace, ExportedTrace, ExportedTraceStep, MemoryTraceSink, TraceSink, TraceStep,
};

// ─── MutationLog ─────────────────────────────────────────────
pub use mutation_log::{
    InMemoryMutationLog, MutationLogEntry, MutationLogStore, mutations_to_log_entries,
};