import type { Checkpoint, NodeState, WorkflowContext, WorkflowNode } from "../types.js";
import type { WorkflowBackend } from "../backends/types.js";
export interface CheckpointManagerConfig {
    backend: WorkflowBackend;
    debug?: boolean;
}
export interface ResumeInfo {
    checkpoint: Checkpoint;
    startFromNode: string;
    context: WorkflowContext;
    nodeStates: Record<string, NodeState>;
}
/** Canonical run identity used to fence auxiliary writes from stale workers. */
export interface CheckpointOwnership {
    runId: string;
    workerId: string;
}
export declare class CheckpointManager {
    private config;
    constructor(config: CheckpointManagerConfig);
    save(runId: string, checkpoint: Checkpoint, ownership?: CheckpointOwnership): Promise<boolean>;
    createCheckpoint(runId: string, nodeId: string, context: WorkflowContext, nodeStates: Record<string, NodeState>): Promise<Checkpoint>;
    getLatest(runId: string): Promise<Checkpoint | null>;
    getAll(runId: string): Promise<Checkpoint[]>;
    prepareResume(runId: string, nodes: WorkflowNode[], fromCheckpoint?: string): Promise<ResumeInfo | null>;
    private findNextNode;
    /**
     * @deprecated Node checkpoint policy is owned by the DAG executor. This
     * compatibility wrapper preserves the historical public API until the next
     * breaking release.
     */
    shouldCheckpoint(node: WorkflowNode): boolean;
    /**
     * @deprecated Checkpoint retention is enforced by built-in backends. This
     * compatibility wrapper remains for callers that prune checkpoints manually.
     */
    cleanup(runId: string, keepCount?: number): Promise<void>;
}
//# sourceMappingURL=checkpoint-manager.d.ts.map