/// <reference types="node" />
import EventEmitter from "events";
import "durr";
export interface ClientEvents<Response = undefined> extends IClientEvents {
    readonly init: () => void;
    readonly success: (response?: Response) => void;
    readonly fail: (reason: string) => void;
    readonly close: () => void;
}
export interface WorkerEvents extends IWorkerEvents {
    readonly init: () => void;
    readonly cancel: () => void;
    readonly close: () => void;
}
export type IWorkerEvents = {
    [key: string | symbol]: ((...args: any[]) => void) | (() => void);
};
export type IClientEvents = {
    [key: string | symbol]: ((...args: any[]) => void) | (() => void);
};
export type BasePayload = unknown;
export interface Job<Payload extends BasePayload = unknown> {
    readonly payload: Payload;
}
export declare function isJob<Payload extends BasePayload = unknown>(it: unknown, payloadTypeGuard?: (p: unknown) => p is Payload): it is Job;
export interface ClientEventEmitter<Response, Client extends ClientEvents<Response> = ClientEvents<Response>> extends EventEmitter {
    on<U extends keyof Client>(event: U, listener: Client[U]): this;
    emit<U extends keyof Client>(event: U, ...args: Parameters<Client[U]>): boolean;
}
export declare class ClientEventEmitter<Response, Client extends ClientEvents<Response> = ClientEvents<Response>> extends EventEmitter {
    constructor();
}
export interface WorkerEventEmitter<Worker extends WorkerEvents = WorkerEvents> extends EventEmitter {
    on<U extends keyof Worker>(event: U, listener: Worker[U]): this;
    emit<U extends keyof Worker>(event: U, ...args: Parameters<Worker[U]>): boolean;
}
export declare class WorkerEventEmitter<Worker extends WorkerEvents = WorkerEvents> extends EventEmitter {
    constructor();
}
export type JobId = string;
export type JobHandler<Payload extends BasePayload = unknown, Response = undefined, Client extends ClientEvents<Response> = ClientEvents<Response>, Worker extends WorkerEvents = WorkerEvents> = (job: Job<Payload>, context: ClientEventEmitter<Response, Client>, workerEvents: WorkerEventEmitter<Worker>) => void;
export interface JobQueue<Payload extends BasePayload = unknown, Response = undefined, Client extends ClientEvents<Response> = ClientEvents<Response>, Worker extends WorkerEvents = WorkerEvents> {
    submit(job: Job<Payload>, preHook?: (emitter: ClientEventEmitter<Response, Client>, id: JobId) => Promise<void>): Promise<JobId>;
    register(handler: JobHandler<Payload, Response, Client, Worker>): Promise<JobWorker>;
    monitor(jobId: JobId): Promise<ClientEventEmitter<Response, Client>>;
    cancel(jobId: JobId): void;
    notify(jobId: JobId, eventName: keyof Worker, ...params: Parameters<Worker[typeof eventName]>): Promise<void>;
    close(): Promise<void>;
}
export interface JobWorker {
    readonly isCanceled: () => boolean;
    readonly cancel: () => void;
}
//# sourceMappingURL=JobQueue.d.ts.map