import { PersistentQueue, PersistentQueueOptions, QueuedJob, QueuedQueryJob } from "./persistent_queue";
import { TimedJob, Timer, TimerOptions } from "./timer";
import { delay, FakeWorkerPool, WorkerPool, WorkerPoolOptions, WorkerStatus, WORKER_POOL_ERROR_DESCRIPTIONS } from "./worker_pool";
import { Worker, WorkerPortal } from "./worker_types";
export { delay, PersistentQueue, PersistentQueueOptions, QueuedJob, TimedJob, Timer, TimerOptions, FakeWorkerPool, Worker, WorkerPool, WorkerPoolOptions, WorkerPortal, WORKER_POOL_ERROR_DESCRIPTIONS, };
export interface NightCoralStats {
    timerCount: number;
    idleWorkerCount: number;
    currentTimerLatency: number;
}
export interface NightCoralOptions<J> extends PersistentQueueOptions, TimerOptions, WorkerPoolOptions<J> {
    databaseFilename: string;
    fakeWorker?: (job: J, returnAddress?: string) => Promise<J | undefined>;
    fakePortal?: WorkerPortal<J>;
}
export declare class NightCoral<J, P = Object> {
    private db;
    private options;
    timer: Timer<J>;
    queue: PersistentQueue<J>;
    workerPool: WorkerPool<J, P>;
    fakePortal?: WorkerPortal<J>;
    constructor(options?: Partial<NightCoralOptions<J>>);
    stop(): Promise<void>;
    launch(workerCodePath: string, count: number): Promise<void>;
    idle(): Promise<void>;
    add(job: J): QueuedJob<J>;
    addQuery(job: J): QueuedQueryJob<J>;
    monitor(frequency: number, timeout: number): AsyncIterable<WorkerStatus<P>[]>;
    addTimerAt(expires: number, job: J): TimedJob<J>;
    addTimer(timeout: number, job: J): TimedJob<J>;
    postReply(returnAddress: string, reply: J): void;
}