import type { ClickHouseExecutor } from '@chkit/clickhouse';
import type { JournalStore, MigrationRowState, OperationState } from '../../runtime/journal-store.js';
export interface AsyncApplyInput {
    db: ClickHouseExecutor;
    journalStore: JournalStore;
    sql: string;
    migrationName: string;
    migrationChecksum: string;
    statementIndex: number;
    operationType: string;
    operationKey: string;
    beforeRetry: string | null;
    log: (line: string) => void;
    pollIntervalMs?: number;
    sleep?: (ms: number) => Promise<void>;
    now?: () => number;
}
export type AsyncApplyResult = {
    kind: 'completed';
    operation: OperationState;
} | {
    kind: 'skipped';
    operation: OperationState;
};
export declare function applyAsyncStatement(input: AsyncApplyInput): Promise<AsyncApplyResult>;
export declare function upsertOperation(state: MigrationRowState, op: OperationState, now: () => number): MigrationRowState;
export declare function freshMigrationState(migrationName: string, checksum: string): MigrationRowState;
export declare function makeDeterministicQueryId(migrationName: string, statementIndex: number): string;
export declare function isoWithoutZone(date: Date): string;
//# sourceMappingURL=async-apply.d.ts.map