import { IQueueProcessor } from '../libs/queue/IQueueProcessor'; import { Tasks } from '../libs/tasks/Tasks'; import { AsyncWorkerQueue } from '../libs/queue/AsyncWorkerQueue'; import { IWorkerStatisitic } from '../libs/worker/IWorkerStatisitic'; import { TaskEvent } from '../libs/tasks/worker/TaskEvent'; import { IWorker } from '../libs/worker/IWorker'; import { StorageRef } from '../libs/storage/StorageRef'; import { ILoggerApi } from '../libs/logging/ILoggerApi'; import { ITaskMonitorWorkerOptions } from '../libs/tasks/worker/ITaskMonitorWorkerOptions'; export declare class TaskMonitorWorker implements IQueueProcessor, IWorker { static NAME: string; name: string; inc: number; nodeId: string; queue: AsyncWorkerQueue; tasks: Tasks; storageRef: StorageRef; logdir: string; logger: ILoggerApi; prepare(options?: ITaskMonitorWorkerOptions): Promise; onTaskEvent(event: TaskEvent): void; do(event: TaskEvent, queue?: AsyncWorkerQueue): Promise; statistic(): IWorkerStatisitic; finish(_await?: boolean): Promise; }