/// <reference types="node" />
import { EventEmitter } from 'events';
import { JobProxy, JobOptProxy } from '../../shared/types/client';
import { JobWrap } from './type';
import { uuid } from '../../shared/types/base';
import { ServerStatus } from '../../shared/types/common';
import { Socket } from "socket.io-client";
export declare class JobAccumulator extends EventEmitter {
    jobsPool: Record<string, JobProxy>;
    jobsQueue: JobWrap[];
    jobsPromisesReject: Record<uuid, (value: unknown) => void>;
    jobsPromisesResolve: Record<uuid, (reason?: unknown) => void>;
    JMstatus: ServerStatus;
    TCPip: string;
    port: number;
    constructor();
    _getJobQueueWrapper(jobID: string): JobWrap | undefined;
    _countSentJob(): number;
    _getWaitingJob(): JobWrap | undefined;
    popQueue(): Promise<string>;
    abortAll(): void;
    appendToQueue(jobOpt: JobOptProxy): Promise<JobProxy>;
    isIdle(): boolean;
    deleteJob(jobID: string): boolean;
    pulse(): void;
    flush(jobID: uuid): JobProxy | undefined;
    getJobObject(maybeJobID: uuid): JobProxy | undefined;
    createJobSocket(jobID: uuid): Promise<Socket>;
}