- Type/Function/Variantを Segment* 系へ統一 - SessionId/SessionStart/SessionOrigin/SessionStartState/SessionState/SessionLogSink/SessionLockInfo - new_session_id / session_id / create_session* / list_sessions / lookup_session / update_session / find_by_session - protocol Event::SessionRotated → SegmentRotated、CompactDone.new_session_id → new_segment_id - Module: session_log → segment_log / session → segment (file mv 含む) pod 側の session_log_sink → segment_log_sink も同様 - crate 名 (session-store)、CLI flag (--session)、ResumeWithSession (CLI tied) は据え置き - session-tests/session_metrics_test 等の Store impl も追従 |
||
|---|---|---|
| .. | ||
| src | ||
| tests | ||
| Cargo.toml | ||
| README.md | ||
llm-worker-persistence
Worker のセッション永続化を提供するクレート。追記専用の JSONL ログとして状態遷移を記録し、ログの再生によってセッションを完全に復元する。大きなツール出力は Blob ストアに分離保存する。
公開型
セッション
Session<C, St>— Worker をラップした永続化セッション(run(),resume(),fork(),fork_at())SessionId— UUID v7 によるセッション識別子SessionConfig— 永続化設定(イベントトレース記録の有無)
ストア
Storeトレイト — 永続化バックエンド抽象(append,read_all,list_sessions)FsStore— ファイルシステム上の JSONL ストア実装BlobStoreトレイト — Blob ストレージ抽象(store,load)FsBlobStore— ファイルシステム上の Blob ストア実装BlobOutputProcessor— ToolOutputProcessor 実装(小さい出力はインライン、大きい出力は Blob 保存)
ログ
LogEntry— セッションログのエントリ型(SessionStart,UserInput,AssistantItems,TurnEndなど)RestoredState— ログ再生で復元された状態collect_state()— ログエントリ列から状態を復元する関数
ツール
InspectTool— Blob 内容を取得する組み込みツール(行範囲・配列スライス・キー指定セレクタ対応)