import { RunnableConsumerFactory } from "../types.js"; import { OrchestratorState } from './fsm.js'; import { Emitter } from '@blackglory/structures'; export { OrchestratorState } from './fsm.js'; export declare class Orchestrator extends Emitter<{ terminated: []; error: [error: Error]; }> { private createRunnableConsumer; private params; private fsm; private retries; private runners; constructor(createRunnableConsumer: RunnableConsumerFactory, params: Params); getState(): OrchestratorState; getNumberOfInstances(): number; terminate(): Promise; scale(concurrency: number | string): Promise; private scaleUp; private scaleDown; private getFirstRunner; private createRunner; private addRunner; private removeRunner; private startRunner; private stopRunner; }