import Directory from "./directory";
import Message from "./message";
import Vertex from "./vertex";
export interface IExecutorOptions {
    maxParallelism?: number;
    maxMessageScanDepth?: number;
    maxUncommittedAgeMS?: number;
}
export default class Executor {
    static readonly MAX_UNCOMMITTED_AGE_DEFAULT: number;
    static readonly SCHEDULE_MIN_INTERVAL = 1000;
    static startTime: number;
    id: string;
    directory: Directory;
    protected vertexTypes: {
        [id: string]: typeof Vertex;
    };
    messages: {
        [vertexType: string]: {
            [vertexId: string]: Message<any>[];
        };
    };
    messagesQueued: number;
    vertices: {
        [vertexId: string]: Vertex<any>;
    };
    uncommittedVertices: {
        [vertexId: string]: Vertex<any>;
    };
    protected scheduleQueued: boolean;
    protected vertexBusy: {
        [vertexId: string]: boolean;
    };
    protected maxParallelism: number | undefined;
    protected maxMessageScanDepth: number | undefined;
    protected maxUncommittedAgeMS: number;
    lastStatsDisplay: number;
    statistics: any;
    constructor(options: IExecutorOptions);
    activate(vertexId: string): Promise<Vertex<unknown>>;
    get(vertexId: string): Promise<Vertex<any>>;
    commit(vertex: Vertex<any>): Promise<Vertex<any>>;
    deactivate(vertexId: string): Promise<Vertex<any>>;
    register(vertexClass: any): void;
    send(messages: Message<any>[]): Promise<void>;
    protected triggerSchedule(): Promise<void>;
    protected atMaxParallelism(): boolean;
    protected processAndEmit(vertex: Vertex<any>, message: Message<any>): Promise<Vertex<any>>;
    protected scheduleMessages(): Promise<{
        [id: string]: Promise<Vertex<any>>;
    }>;
    protected scheduleCommits(): Promise<{
        [id: string]: Promise<Vertex<any>>;
    }>;
    protected scheduleDeactivations(): Promise<{
        [id: string]: Promise<Vertex<any>>;
    }>;
    protected displayStats(): void;
    protected retirePromises(promises: {
        [id: string]: Promise<Vertex<any>>;
    }): Promise<void>;
    protected schedule(): Promise<[void, void, void]>;
}