import { IConsole, Logger } from '../logger';
import { IWorkerData } from './IWorkerData';
import { IWorkerProcess } from './IWorkerProcess';
export declare const WORKER_ERROR_CODES: {
    TIMEOUT: number;
    BLOCKING: number;
};
export declare const THREAD_EXIT_CODES: {
    SUCCESS: number;
    RETRY: number;
    ERROR: number;
    BLOCKING: number;
};
export declare class AbstractWorkerProcessor {
    protected name: string;
    protected bypassConnection: boolean;
    protected static NeedToStop: boolean;
    protected static BlockingDetected: boolean;
    protected config: any;
    protected input: any;
    protected logger: Logger;
    protected processes: IWorkerProcess[];
    private perfBegin;
    private perfTimeSpentComputing;
    private perfTimeSpentWaiting;
    constructor(name: string, workerData: IWorkerData, bypassConnection?: boolean);
    static CheckIfItShouldStop(): boolean;
    static ForceStop(stop?: boolean): void;
    static IsBlockingDetected(): boolean;
    static ResetBlocking(): void;
    static GetProcesses(): IWorkerProcess[];
    launch(): Promise<boolean>;
    getName(): string;
    getProcesses(): IWorkerProcess[];
    protected loop(asyncFn: (config: any, inputs: any, logger: IConsole, count: number) => Promise<boolean>, count: number, inputs: any): Promise<boolean>;
    protected getLogger(): IConsole;
    protected initLogger(config: any): Logger;
    protected getInputs(config: any, input: any): Promise<any>;
    protected connect(): Promise<boolean>;
    protected disconnect(): Promise<boolean>;
    protected onEnd(allDone: boolean, logger: IConsole, stats: {
        timeSpentTotal: number;
        timeSpentComputing: number;
        timeSpentWaiting: number;
    }): Promise<void>;
    private buildStats;
}