import { Pool } from 'pg';
import type { JobRepository, JobRepositoryOptions, RemoveJobsOptions, JobParameters, JobId, JobsQueryOptions, JobsResult, JobsOverview } from 'agenda';
import type { PostgresBackendConfig } from './types.js';
/**
 * PostgreSQL implementation of JobRepository
 */
export declare class PostgresJobRepository implements JobRepository {
    private config;
    private pool;
    private ownPool;
    private tableName;
    private ensureSchema;
    private sort;
    private disconnected;
    constructor(config: PostgresBackendConfig);
    private createPool;
    /**
     * Get the underlying pool (for use by notification channel)
     */
    getPool(): Pool;
    connect(): Promise<void>;
    private createSchema;
    disconnect(): Promise<void>;
    /**
     * Force close the pool - should only be called on application shutdown
     * or when you're sure the backend won't be reused
     */
    close(): Promise<void>;
    /**
     * Convert PostgreSQL row to JobParameters
     */
    private rowToJob;
    /**
     * Convert SortDirection to SQL ASC/DESC
     */
    private toSqlDirection;
    /**
     * Convert sort options to PostgreSQL ORDER BY clause
     */
    private toOrderByClause;
    getJobById(id: string): Promise<JobParameters | null>;
    queryJobs(options?: JobsQueryOptions): Promise<JobsResult>;
    getJobsOverview(): Promise<JobsOverview[]>;
    getDistinctJobNames(): Promise<string[]>;
    getQueueSize(): Promise<number>;
    removeJobs(options: RemoveJobsOptions): Promise<number>;
    /**
     * Build PostgreSQL filter conditions from RemoveJobsOptions
     */
    private buildFilterFromOptions;
    disableJobs(options: RemoveJobsOptions): Promise<number>;
    enableJobs(options: RemoveJobsOptions): Promise<number>;
    purgeAllJobs(): Promise<number>;
    unlockJob(job: JobParameters): Promise<void>;
    unlockJobs(jobIds: (JobId | string)[]): Promise<void>;
    lockJob(job: JobParameters, options: JobRepositoryOptions | undefined): Promise<JobParameters | undefined>;
    getNextJobToRun(jobName: string, nextScanAt: Date, lockDeadline: Date, now: Date | undefined, options: JobRepositoryOptions | undefined): Promise<JobParameters | undefined>;
    saveJobState(job: JobParameters, options: JobRepositoryOptions | undefined): Promise<void>;
    saveJob<DATA = unknown>(job: JobParameters<DATA>, options: JobRepositoryOptions | undefined): Promise<JobParameters<DATA>>;
}