/** * LocalGroupDispatchSessionDataStore:Group Dispatch Session 的追加式 Turn 日志。 * * 每次状态迁移都追加完整快照;读取时按 dispatch_id 选择最后一条记录,因此中断前 * 已提交的状态不会被覆盖,文件尾部的非完整写入也可以安全修复。 */ import type { FileSystem } from "@downcity/workspace"; import type { GroupDispatchSessionDataStore, GroupDispatchTurnRecord } from "../../types/group/GroupDispatchSession.js"; /** 基于 GroupSession 私有目录的 Dispatch Session Store。 */ export declare class LocalGroupDispatchSessionDataStore implements GroupDispatchSessionDataStore { private readonly files; private readonly dispatch_root_path; private readonly turns_file_path; private readonly transaction_lock_path; constructor(options: { /** 当前 Group StorageScope 文件能力。 */ readonly files: FileSystem; /** 当前 GroupSession 的私有存储根目录。 */ readonly session_root_path: string; }); /** 读取每个调度 Turn 最后一次成功提交的状态。 */ list_turns(): Promise; /** 追加一个完整状态快照,状态提交与其它调度 Turn 串行。 */ append_turn(turn: GroupDispatchTurnRecord): Promise; /** 读取状态日志;只允许修复进程中断产生的最后一条残缺记录。 */ private read_records; } //# sourceMappingURL=LocalGroupDispatchSessionDataStore.d.ts.map