import { type DeleteRunOptions, type RunFilter, type RunRef, type RunState, type RunStore, type StepFinalizePatch, type StepRecord } from '@kuralle-agents/core';
import type { QueryResult } from 'pg';
type PostgresClient = {
    query: (text: string, params?: unknown[]) => Promise<QueryResult>;
};
export type PostgresRunStoreOptions = {
    client: PostgresClient;
    stateTableName?: string;
    stepsTableName?: string;
    autoMigrate?: boolean;
};
export declare class PostgresRunStore implements RunStore {
    readonly ready: Promise<void>;
    private readonly client;
    private readonly stateTable;
    private readonly stepsTable;
    constructor(options: PostgresRunStoreOptions);
    appendStep(runId: string, record: StepRecord): Promise<void>;
    finalizeStep(runId: string, key: string, patch: StepFinalizePatch): Promise<void>;
    getSteps(runId: string): Promise<StepRecord[]>;
    getRunState(runId: string): Promise<RunState | null>;
    putRunState(state: RunState): Promise<void>;
    initRun(state: RunState): Promise<void>;
    pruneStepsBeforeEpoch(runId: string, keepEpoch: number): Promise<void>;
    reserveSteps(runId: string, count: number): Promise<number[]>;
    listRuns(filter: RunFilter): AsyncIterable<RunRef>;
    deleteRun(runId: string, options?: DeleteRunOptions): Promise<void>;
    private init;
    private withTransaction;
    private stepCount;
    private stepParams;
    private insertStepRow;
    private parseStep;
}
export {};