import { Worker } from "cluster";
import { Invokable } from "./Invokable.js";
export declare class RecycledWorker<T = any> {
    get worker(): Worker;
    private currentWorker;
    private destroyed;
    private eventMap;
    constructor(env?: any);
    on(msg: string, handler: any): void;
    send(a: any): void;
    destroy(): void;
}
export default abstract class ClusterInstance<T> extends Invokable {
    get maxWorkerCount(): number;
    protected isPrimary: boolean;
    protected readonly workers: RecycledWorker[];
    run(arg: T): void;
    protected abstract runPrimary(arg: T): Promise<void>;
    protected abstract runWorker(arg: T): Promise<void>;
    protected fork(env?: any): RecycledWorker<any>;
    protected setupPrimary(arg: T): Promise<void>;
    /**
     * keep worker process alive for 4 hours by default
     * you can choose your own recycle schedule.
     *
     * Recycling process is important to flush out dead connections.
     */
    protected keepAlive(): Promise<void>;
    protected setupWorker(arg: T): Promise<void>;
    protected invoke(invoke: string, ...args: any[]): Promise<any>;
}
//# sourceMappingURL=ClusterInstance.d.ts.map