import { PgConnectionConfig } from '@cardano-sdk/projection-typeorm';
import { CommonProgramOptions, PosgresProgramOptions } from '../options';
import { DataSource } from 'typeorm';
import { HttpService } from '../../Http/HttpService';
import { Logger } from 'ts-log';
import { Observable, Subject } from 'rxjs';
import { PgBossQueue } from '../../PgBoss';
import { Pool } from 'pg';
import { ScheduleConfig } from '../../util/schedule';
import { StakePoolMetadataProgramOptions } from '../options/stakePoolMetadata';
export declare const pgBossEntities: Function[];
export declare const createPgBossDataSource: (connectionConfig$: Observable<PgConnectionConfig>, logger: Logger) => Observable<DataSource>;
export declare type PgBossWorkerArgs = CommonProgramOptions & StakePoolMetadataProgramOptions & PosgresProgramOptions<'DbSync'> & PosgresProgramOptions<'StakePool'> & {
    parallelJobs: number;
    queues: PgBossQueue[];
    schedules: Array<ScheduleConfig>;
};
export interface PgBossServiceDependencies {
    connectionConfig$: Observable<PgConnectionConfig>;
    db: Pool;
    logger: Logger;
}
export declare class PgBossHttpService extends HttpService {
    #private;
    onUnrecoverableError$: Subject<unknown>;
    constructor(cfg: PgBossWorkerArgs, deps: PgBossServiceDependencies);
    protected startImpl(): Promise<void>;
    protected shutdownImpl(): Promise<void>;
    private work;
    private createQueue;
    private workQueue;
    private createSchedule;
}
//# sourceMappingURL=pgboss.d.ts.map