import { PoolClient } from 'pg';
import type { Database } from './types.js';
import type { PostgresDatabaseConfig } from './schemas.js';
import type { Logger } from '@dexto/core';
/**
 * PostgreSQL database store for production database operations.
 * Implements the Database interface with connection pooling and JSONB support.
 * EXPERIMENTAL - NOT FULLY TESTED YET
 */
export declare class PostgresStore implements Database {
    private config;
    private pool;
    private connected;
    private logger;
    constructor(config: PostgresDatabaseConfig, logger: Logger);
    connect(): Promise<void>;
    /**
     * Creates a PostgreSQL schema if it doesn't exist.
     */
    private createSchema;
    disconnect(): Promise<void>;
    isConnected(): boolean;
    getStoreType(): string;
    get<T>(key: string): Promise<T | undefined>;
    set<T>(key: string, value: T): Promise<void>;
    setIfAbsent<T>(key: string, value: T): Promise<{
        value: T;
        inserted: boolean;
    }>;
    delete(key: string): Promise<void>;
    list(prefix: string): Promise<string[]>;
    append<T>(key: string, item: T): Promise<void>;
    updateList<T, R>(key: string, updater: (items: T[]) => {
        items: T[];
        result: R;
    }): Promise<R>;
    getRange<T>(key: string, start: number, count: number): Promise<T[]>;
    private createTables;
    private checkConnection;
    /**
     * Check if an error is a connection error that should trigger a retry.
     * Common with serverless databases (Neon) where connections go stale.
     */
    private isConnectionError;
    /**
     * Execute a database operation with automatic retry on connection errors.
     * Handles serverless DB connection issues (Neon cold starts, stale connections).
     */
    private withRetry;
    /**
     * Execute a callback within a database transaction.
     * Note: On connection failure, the entire callback will be retried on a new connection.
     * Ensure callback operations are idempotent or use this only for read operations.
     */
    transaction<T>(callback: (client: PoolClient) => Promise<T>): Promise<T>;
    private transactionOnce;
    getStats(): Promise<{
        kvCount: number;
        listCount: number;
        totalSize: string;
    }>;
    vacuum(): Promise<void>;
}
//# sourceMappingURL=postgres-store.d.ts.map