export = WorkersRegistry;
declare class WorkersRegistry extends EventEmitter<[never]> {
    static create(...args: any[]): import("./workers-registry");
    constructor(config: any, profiler?: Readonly<{
        readonly level: 0;
        isEnabled(_minLevel?: import("../profiler/schema").EnabledProfilerLevel): boolean;
        startSpan(_kind: string, _options?: import("../profiler/runtime/types").SpanOptions | undefined): import("../profiler/runtime/types").SpanHandle;
        withSpan<T>(_kind: string, _options: import("../profiler/runtime/types").SpanOptions, action: () => T): T;
        withContext<T_1>(_context: Partial<import("../profiler/schema").CorrelationContext>, action: () => T_1): T_1;
        increment(_metric: string, _value?: number | undefined, _dimensions?: Record<string, import("../profiler/schema").ProfilerValue> | undefined): void;
        sample(_metric: string, _value: number, _dimensions?: Record<string, import("../profiler/schema").ProfilerValue> | undefined): void;
        recordError(_stage: string, _error: unknown): void;
        recordMeasurement(_kind: string, _durationMs: number, _options?: import("../profiler/runtime/types").SpanOptions | undefined, _status?: "failed" | "completed" | "interrupted" | undefined): void;
        snapshot(): import("../profiler/runtime/types").RuntimeSnapshot | null;
        closeOpenSpans(): void;
        stop(): void;
        takeFragment(): import("../profiler/runtime/types").ProfilerFragment | null;
        ingestFragment(_fragment: unknown): void;
    }>);
    _config: any;
    _ended: boolean;
    _workerFarm: workerFarm.Workers | null;
    _registeredWorkers: any[];
    _profiler: Readonly<{
        readonly level: 0;
        isEnabled(_minLevel?: import("../profiler/schema").EnabledProfilerLevel): boolean;
        startSpan(_kind: string, _options?: import("../profiler/runtime/types").SpanOptions | undefined): import("../profiler/runtime/types").SpanHandle;
        withSpan<T>(_kind: string, _options: import("../profiler/runtime/types").SpanOptions, action: () => T): T;
        withContext<T_1>(_context: Partial<import("../profiler/schema").CorrelationContext>, action: () => T_1): T_1;
        increment(_metric: string, _value?: number | undefined, _dimensions?: Record<string, import("../profiler/schema").ProfilerValue> | undefined): void;
        sample(_metric: string, _value: number, _dimensions?: Record<string, import("../profiler/schema").ProfilerValue> | undefined): void;
        recordError(_stage: string, _error: unknown): void;
        recordMeasurement(_kind: string, _durationMs: number, _options?: import("../profiler/runtime/types").SpanOptions | undefined, _status?: "failed" | "completed" | "interrupted" | undefined): void;
        snapshot(): import("../profiler/runtime/types").RuntimeSnapshot | null;
        closeOpenSpans(): void;
        stop(): void;
        takeFragment(): import("../profiler/runtime/types").ProfilerFragment | null;
        ingestFragment(_fragment: unknown): void;
    }>;
    _children: Map<any, any>;
    _allChildren: Set<any>;
    _workerSequence: number;
    _flushRequests: Map<any, any>;
    _activeCalls: number;
    _peakActiveCalls: number;
    init(): void;
    end(): Promise<void>;
    shutdown(): Promise<void>;
    isEnded(): boolean;
    register(workerFilepath: any, exportedMethods: any): EventEmitter<[never]>;
    _createWorkerFarm(): workerFarm.Workers;
    _inspectParams(): {
        workerOptions: {
            execArgv: string[];
        };
        maxConcurrentWorkers: number;
        maxCallsPerWorker: number;
    } | undefined;
    _initChild(child: any): void;
    _flushProfiler(): Promise<void>;
    _handleProfilerFlushed(data: any, { child, workerInstanceId }: {
        child: any;
        workerInstanceId: any;
    }): void;
    _ingestProfilerMessage(data: any, { child, workerInstanceId }: {
        child: any;
        workerInstanceId: any;
    }, errorStage: any): void;
}
import { EventEmitter } from "events";
import workerFarm = require("worker-farm");