import Pg from "pg";
import { PGlite as Pglite } from "@electric-sql/pglite";
import type { Canonical, QueueMember } from "./canonicalise/index.ts";
export declare class DbAdapter {
    private client;
    private external?;
    resolveQueue: QueueMember[];
    queryCount: number;
    constructor(client: Pg.Client | Pg.Pool | Pglite, external?: boolean | undefined);
    resetQueue(): void;
    resetQueryCount(): void;
    reset(): void;
    enqueue(type: string): Canonical;
    resolve(): Promise<Canonical[]>;
    connect(): Promise<void>;
    /**
     * Execute a read query and return just the rows
     */
    query<R, I extends any[] = []>(text: string, params?: I): Promise<R[]>;
    /**
     * Close the connection and clear the cache
     */
    close(): Promise<void>;
}