/// <reference types="node" />
import { EventEmitter } from "stream";
import { PinoLogger } from "../logger";
import { TaskQueue } from "../../interfaces";
declare class Task {
    name: string;
    protected handler: any;
    protected doneFn: any;
    protected logger: PinoLogger;
    isDone: boolean;
    constructor(name: string, handler: any, doneFn: any);
    run(): Promise<void>;
}
declare class Queue {
    protected queueName: string;
    protected logger: PinoLogger;
    protected eventEmitter: EventEmitter;
    isRunning: boolean;
    tasks: Task[];
    protected _interval: any;
    constructor(queueName: string);
    onExhausted(callback: any): void;
    protected runNextTask(): Promise<void>;
    protected run(): Promise<void>;
    add(task: Task): void;
}
export declare class SyncTaskQueue implements TaskQueue {
    protected logger: PinoLogger;
    protected queueList: Map<string, Queue>;
    push<T>(queueName: string, name: string, handler: any): Promise<T>;
}
export {};