X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=12d5ab26f13f7d62c408f20a8f55f09b862ca7b5;hb=cfc9875aed1b5e773f4baaa30574f1a06534f566;hp=9204eadce8456c5c17c311c8c8ce6574e6f05a29;hpb=268a74bb051fcbbad532fd833f0d8fd2b33b6c64;p=e-mobility-charging-stations-simulator.git

diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts
index 9204eadc..12d5ab26 100644
--- a/src/worker/WorkerTypes.ts
+++ b/src/worker/WorkerTypes.ts
@@ -1,37 +1,58 @@
-import type { Worker } from 'worker_threads';
+import type { Worker } from 'node:worker_threads';
 
-import type { PoolOptions } from 'poolifier';
+import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier';
 
 export enum WorkerProcessType {
-  WORKER_SET = 'workerSet',
-  DYNAMIC_POOL = 'dynamicPool',
-  STATIC_POOL = 'staticPool',
+  workerSet = 'workerSet',
+  /** @experimental */
+  dynamicPool = 'dynamicPool',
+  staticPool = 'staticPool',
 }
 
-export type MessageHandler<T> = (this: T, message: unknown) => void;
+export interface SetInfo {
+  version: string;
+  type: string;
+  worker: string;
+  size: number;
+  elementsExecuting: number;
+  elementsPerWorker: number;
+}
+
+export enum WorkerSetEvents {
+  error = 'error',
+  elementStarted = 'elementStarted',
+  elementError = 'elementError',
+}
+
+export const WorkerEvents = {
+  ...PoolEvents,
+  ...WorkerSetEvents,
+} as const;
+export type WorkerEvents = PoolEvent | WorkerSetEvents;
 
-export type WorkerOptions = {
+export interface WorkerOptions {
   workerStartDelay?: number;
   elementStartDelay?: number;
   poolMaxSize: number;
   poolMinSize: number;
   elementsPerWorker?: number;
-  poolOptions?: PoolOptions<Worker>;
-  messageHandler?: MessageHandler<Worker>;
-};
+  poolOptions?: ThreadPoolOptions;
+}
 
 export type WorkerData = Record<string, unknown>;
 
-export type WorkerSetElement = {
+export interface WorkerSetElement {
   worker: Worker;
   numberOfWorkerElements: number;
-};
+}
 
-export type WorkerMessage<T extends WorkerData> = {
-  id: WorkerMessageEvents;
+export interface WorkerMessage<T extends WorkerData> {
+  event: WorkerMessageEvents;
   data: T;
-};
+}
 
 export enum WorkerMessageEvents {
-  START_WORKER_ELEMENT = 'startWorkerElement',
+  startWorkerElement = 'startWorkerElement',
+  startWorkerElementError = 'startWorkerElementError',
+  startedWorkerElement = 'startedWorkerElement',
 }