/** * Checkpoint Engine - Engine * * Main checkpoint engine with recovery strategies. */ import type { CheckpointEngineConfig, CheckpointMetadata, PruneResult, RecoveryResult, RecoveryStrategy, RuntimeState, StateDelta, VerificationResult } from "./types.js"; export declare class CheckpointEngine { private readonly config; private readonly storage; private readonly differ; private lastStates; constructor(config: CheckpointEngineConfig); /** * Get current version for a job */ private getCurrentVersion; /** * Create metadata for a checkpoint */ private createMetadata; /** * Save a checkpoint (full or incremental based on config) */ save(jobId: string, state: RuntimeState): Promise; /** * Decide if we should use a full checkpoint */ private shouldUseFullCheckpoint; /** * Save an incremental checkpoint explicitly */ saveIncremental(jobId: string, delta: StateDelta): Promise; /** * Load the latest state for a job */ load(jobId: string): Promise; /** * Load state at specific version */ loadState(jobId: string, version: number): Promise; /** * Reconstruct state from incremental checkpoint */ private reconstructFromIncremental; /** * Recover job state using specified strategy */ recover(jobId: string, strategy: RecoveryStrategy): Promise; /** * Verify a checkpoint */ verify(jobId: string, version: number): Promise; /** * Prune old checkpoints */ prune(jobId: string, keepCount: number): Promise; /** * Get metadata for all checkpoints */ getMetadata(jobId: string): Promise; /** * Get cached last state */ getLastState(jobId: string): RuntimeState | undefined; /** * Delete all checkpoints for a job */ deleteAll(jobId: string): Promise; } /** * Create a checkpoint engine */ export declare function createCheckpointEngine(config?: CheckpointEngineConfig): CheckpointEngine; //# sourceMappingURL=engine.d.ts.map