export interface PendingMessageClaim { wireId: string; seq: number; claimedAt: number; } /** * Body-free crash journal for the SQLite getMessages read boundary. * * A claim lands before getMessages marks its exact oldest-first batch read. * After a crash, getHistoryItem can therefore recover the body by wire ID * without fleet ever duplicating message plaintext in its own state. */ export declare class MessageRecoveryState { private readonly path; private readonly limit; private pending; private corrupt; constructor(path: string, limit?: number); integrity(): boolean; list(): PendingMessageClaim[]; claim(items: PendingMessageClaim[]): void; pruneHandled(handled: (wireId: string) => boolean): number; private assertHealthy; private persist; }