import { Pool } from "pg";
import type { PostgresProviderConfig } from "../config.js";
import type { CandidateMemory, CandidateReviewItem, CandidateReviewStore, CandidateStatusSummary, SessionObservation } from "../observation.js";
import type { CatalogEntry, EmbeddingModel, MemoryContext, MemoryMutationOptions, MemoryProvider, MemoryRecord, MemoryResult, MemorySearchRequest, MemoryWrite, ProviderDescriptor, ProviderHealth } from "../types.js";
export interface PostgresMemoryProviderOptions {
    pool?: Pool;
    embeddingModel?: EmbeddingModel;
}
export declare class PostgresMemoryProvider implements MemoryProvider, CandidateReviewStore {
    private readonly config;
    readonly id: string;
    private readonly pool;
    private readonly embeddingModel;
    private readonly ownsPool;
    /** Exposes the underlying connection pool so other durable stores (e.g. `PostgresCorrectionCandidateStore`) can share it instead of opening a second pool to the same database. */
    get connectionPool(): Pool;
    constructor(config: PostgresProviderConfig, options?: PostgresMemoryProviderOptions);
    capabilities(): {
        lexicalSearch: boolean;
        semanticSearch: boolean;
        metadataFiltering: boolean;
        catalog: boolean;
        read: boolean;
        write: boolean;
        update: boolean;
        delete: boolean;
        episodicHistory: boolean;
        structuredEntities: boolean;
        filesystemDocuments: boolean;
    };
    descriptor(): Promise<ProviderDescriptor>;
    catalog(context: MemoryContext, signal: AbortSignal): Promise<CatalogEntry[]>;
    search(request: MemorySearchRequest): Promise<MemoryResult[]>;
    get(id: string, context: MemoryContext): Promise<MemoryRecord | undefined>;
    write(memory: MemoryWrite, options?: MemoryMutationOptions): Promise<MemoryRecord>;
    update(id: string, memory: MemoryWrite, options?: MemoryMutationOptions): Promise<MemoryRecord>;
    supersede(id: string, replacement: MemoryWrite, options?: MemoryMutationOptions): Promise<MemoryRecord>;
    delete(id: string, _context: MemoryContext): Promise<void>;
    persistCandidate(observation: SessionObservation, candidate: CandidateMemory, options?: {
        timeoutMs?: number;
        signal?: AbortSignal;
    }): Promise<void>;
    candidateStatus(context: MemoryContext): Promise<CandidateStatusSummary>;
    listCandidates(status?: CandidateMemory["status"]): Promise<CandidateReviewItem[]>;
    reviewCandidate(id: string, status: "approved" | "rejected"): Promise<void>;
    consolidateCandidates(batchSize?: number): Promise<import("../consolidation.js").ConsolidationRun>;
    reembedStale(batchSize?: number): Promise<import("../reembedding.js").ReembedRunResult>;
    health(): Promise<ProviderHealth>;
    close(): Promise<void>;
    dispose(): Promise<void>;
    private recordEmbeddingSettings;
    private writeWithClient;
    private insertSource;
    private insertEntitiesAndRelationships;
}