import { type HotWriteToken, type LongTermStore, type ReleasePreconditions, type ReleaseResult, type ShortTermStore } from './types.js';
export interface StorageCoordinatorOptions {
    shortTermStore: ShortTermStore;
    longTermStore: LongTermStore;
    archiveBatchSize?: number;
    storageLockTtlMs?: number;
    rehydrateReplayEvents?: number;
    requiredStorageProtocolVersion?: number;
    generateId?: () => string;
    now?: () => number;
    observe?: (observation: Record<string, unknown>) => void;
}
export declare class StorageCoordinator {
    private readonly shortTermStore;
    private readonly longTermStore;
    private readonly archiveBatchSize;
    private readonly storageLockTtlMs;
    private readonly rehydrateReplayEvents;
    private readonly requiredStorageProtocolVersion;
    private readonly generateId;
    private readonly now;
    private readonly observe;
    constructor(options: StorageCoordinatorOptions);
    releaseTaskStorage(taskId: string, preconditions: ReleasePreconditions): Promise<ReleaseResult>;
    private releaseTaskStorageInner;
    ensureTaskHotForWrite(taskId: string, rehydrateCold?: boolean): Promise<HotWriteToken>;
    private rehydrateColdTask;
    private rehydrateColdTaskInner;
    recoverTaskStorage(taskId: string): Promise<ReleaseResult>;
    private describeArchiveSource;
    private readSourceBatches;
    private reopenAfterFailure;
    private requireHotLifecycle;
    private errorCode;
    private requireDurableLifecycle;
}
//# sourceMappingURL=storage-coordinator.d.ts.map