build(deps): apply updates

[e-mobility-charging-stations-simulator.git] / src / worker / WorkerTypes.ts

import type { Worker } from 'node:worker_threads';

import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier';

export enum WorkerProcessType {
  workerSet = 'workerSet',
  dynamicPool = 'dynamicPool',
  staticPool = 'staticPool',
}

export type SetInfo = {
  version: string;
  type: string;
  worker: string;
  size: number;
  elementsExecuting: number;
  elementsPerWorker: number;
};

export enum WorkerSetEvents {
  error = 'error',
}

export const WorkerEvents = {
  ...PoolEvents,
  ...WorkerSetEvents,
} as const;
export type WorkerEvents = PoolEvent | WorkerSetEvents;

export type WorkerOptions = {
  workerStartDelay?: number;
  elementStartDelay?: number;
  poolMaxSize: number;
  poolMinSize: number;
  elementsPerWorker?: number;
  poolOptions?: ThreadPoolOptions;
};

export type WorkerData = Record<string, unknown>;

export type WorkerSetElement = {
  worker: Worker;
  numberOfWorkerElements: number;
};

export type WorkerMessage<T extends WorkerData> = {
  id: WorkerMessageEvents;
  data: T;
};

export enum WorkerMessageEvents {
  startWorkerElement = 'startWorkerElement',
}