import { type Storage } from '../../storage/interface.ts'; import type { Checkpoint, WorkerReplayOperationFailure, WorkerReplayOperationSignature } from '../types.ts'; export declare const CHECKPOINT_REPLAY_PAYLOAD_KEY = "__weftCheckpointReplay"; export type CheckpointReplayPayload = { accumulatedResults?: Array<[number, unknown]>; workerReplaySignatures?: Array<[number, WorkerReplayOperationSignature]>; workerReplayFailures?: Array<[number, WorkerReplayOperationFailure]>; }; export type PrunedCheckpointReplayState = { checkpoint: Checkpoint; replayPayload: CheckpointReplayPayload | undefined; }; export declare function pruneCheckpointReplayState(checkpoint: Checkpoint, pendingOperationStep: number): PrunedCheckpointReplayState; export declare function hydrateCheckpointReplayState(storage: Storage, workflowId: string, checkpoint: Checkpoint): Promise; export declare function hydrateCheckpointReplayStateFromPayload(checkpoint: Checkpoint, replayPayload: CheckpointReplayPayload | undefined): Checkpoint; export declare function attachTransientCheckpointReplayPayload(checkpoint: Checkpoint, replayPayload: CheckpointReplayPayload | undefined): Checkpoint; export declare function createCheckpointEventPayload(checkpointStep: number, replayPayload: CheckpointReplayPayload | undefined): Record; export declare function mergeCheckpointReplayPayloads(left: CheckpointReplayPayload | undefined, right: CheckpointReplayPayload | undefined): CheckpointReplayPayload | undefined; export declare function readCheckpointReplayPayload(payload: unknown): CheckpointReplayPayload | undefined; export declare function stripInternalCheckpointReplayPayload(payload: Record): Record;