import { Pg } from './pg.ts';
import type { Adapter, Options, StartStop } from './types.ts';
import type { Es } from './es.ts';
export declare class Transfer implements StartStop {
    private logger;
    private queue;
    private readonly options;
    private readonly pg;
    private readonly adapter;
    private readonly es;
    constructor(options: Options, pg: Pg, adapter: Adapter, es: Es);
    start(): Promise<void>;
    stop(): Promise<void>;
    transferMessages(): Promise<void>;
    private doTransferMessages;
    private normalizeError;
    private fetchPgMessages;
    private updateToProcessed;
}