import { ITaskWorkload } from './../libs/tasks/worker/ITaskWorkload'; import { IWorker } from '../libs/worker/IWorker'; import { IWorkerStatisitic } from '../libs/worker/IWorkerStatisitic'; import { IQueueProcessor } from '../libs/queue/IQueueProcessor'; import { AsyncWorkerQueue } from '../libs/queue/AsyncWorkerQueue'; import { ILoggerApi } from '../libs/logging/ILoggerApi'; import { ITaskQueueWorkerOptions } from '../libs/tasks/worker/ITaskQueueWorkerOptions'; import { TaskRunnerRegistry } from '../libs/tasks/TaskRunnerRegistry'; import { Cache } from '../libs/cache/Cache'; import { TaskProposeEvent } from '../libs/tasks/event/TaskProposeEvent'; import { TaskEvent } from '../libs/tasks/event/TaskEvent'; export declare class TaskQueueWorker implements IQueueProcessor, IWorker { static NAME: string; name: string; cache: Cache; taskRunnerRegistry: TaskRunnerRegistry; inc: number; nodeId: string; queue: AsyncWorkerQueue; options: ITaskQueueWorkerOptions; intervalId: any; logger: ILoggerApi; heapSize: { limit?: number; downgrade?: number; }; prepare(options?: ITaskQueueWorkerOptions): Promise; loadAverage(): void; memStr(mem: number): string; getTasksRegistry(): import("..").Tasks; onTaskEvent(proposeEvent: TaskProposeEvent): TaskEvent; do(workLoad: ITaskWorkload, queue?: AsyncWorkerQueue): Promise; fireState(e: TaskEvent): TaskEvent; statistic(): IWorkerStatisitic; finish(): Promise; }