import { type Disposes, type Drains, type LifecycleContext, type QueueDeliveryHandler, type QueueEnvelope, type QueueJobRecord, type QueueRuntimeRoles, QueueManager, type ScheduleDefinition, type SpanLink, type Starts, type Stops } from '@doxajs/core';
export interface PgBossQueueOptions {
    readonly connectionString: string;
    readonly localConcurrency?: number;
    readonly pollingIntervalSeconds?: number;
    readonly outboxPollingMilliseconds?: number;
    readonly applicationName?: string;
}
export declare class PgBossQueueManager extends QueueManager implements Starts, Drains, Stops, Disposes {
    #private;
    private readonly options;
    constructor(options: PgBossQueueOptions);
    bind(handler: QueueDeliveryHandler): void;
    selectRoles(roles: QueueRuntimeRoles): void;
    reconcileSchedules(schedules: readonly ScheduleDefinition[]): void;
    start(context: LifecycleContext): Promise<void>;
    enqueue(envelope: QueueEnvelope): Promise<string>;
    flushOutbox(): Promise<number>;
    findJob(id: string): Promise<QueueJobRecord | undefined>;
    findAttemptTrace(id: string, attempt: number): Promise<SpanLink | undefined>;
    recordAttemptTrace(id: string, attempt: number, trace: SpanLink): Promise<void>;
    clearAttemptTraces(id: string): Promise<void>;
    drain(_context: LifecycleContext): Promise<void>;
    stop(_context: LifecycleContext): Promise<void>;
    dispose(_context: LifecycleContext): Promise<void>;
    get lastEngineError(): unknown;
}
export declare function installQueueSchema(connectionString: string): Promise<void>;
export declare function inspectQueueJob(connectionString: string, id: string): Promise<QueueJobRecord | undefined>;
export declare function clearQueueJobs(connectionString: string): Promise<void>;
export declare function listQueueJobs(connectionString: string, state?: QueueJobRecord['state']): Promise<readonly QueueJobRecord[]>;
export declare function retryQueueJob(connectionString: string, id: string): Promise<void>;
export declare function cancelQueueJob(connectionString: string, id: string): Promise<void>;
//# sourceMappingURL=index.d.ts.map