X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=5c8c177fcfd4ee40e02b78ebb23818ef99ecbe9e;hb=6027002ff1398a1cb3bb55d4994e4615efded2c0;hp=b7b21ba30f580c39ffd9cd925a1b106b77fbc6d8;hpb=e1d9a0f4d6ff1a90048e9a694fd12b7031cc6961;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index b7b21ba3..5c8c177f 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -1,54 +1,62 @@ -import type { Worker } from 'node:worker_threads'; +import type { Worker } from 'node:worker_threads' -import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier'; +import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier' export enum WorkerProcessType { workerSet = 'workerSet', + fixedPool = 'fixedPool', /** @experimental */ - dynamicPool = 'dynamicPool', - staticPool = 'staticPool', + dynamicPool = 'dynamicPool' } export interface SetInfo { - version: string; - type: string; - worker: string; - size: number; - elementsExecuting: number; - elementsPerWorker: number; + version: string + type: string + worker: string + started: boolean + size: number + elementsExecuting: number + elementsPerWorker: number } export enum WorkerSetEvents { + started = 'started', + stopped = 'stopped', error = 'error', + elementAdded = 'elementAdded', + elementError = 'elementError' } export const WorkerEvents = { ...PoolEvents, - ...WorkerSetEvents, -} as const; -export type WorkerEvents = PoolEvent | WorkerSetEvents; + ...WorkerSetEvents +} as const +// eslint-disable-next-line @typescript-eslint/no-redeclare +export type WorkerEvents = PoolEvent | WorkerSetEvents export interface WorkerOptions { - workerStartDelay?: number; - elementStartDelay?: number; - poolMaxSize: number; - poolMinSize: number; - elementsPerWorker?: number; - poolOptions?: ThreadPoolOptions; + workerStartDelay?: number + elementStartDelay?: number + poolMaxSize: number + poolMinSize: number + elementsPerWorker?: number + poolOptions?: ThreadPoolOptions } -export type WorkerData = Record; +export type WorkerData = Record export interface WorkerSetElement { - worker: Worker; - numberOfWorkerElements: number; + worker: Worker + numberOfWorkerElements: number } export interface WorkerMessage { - id: WorkerMessageEvents; - data: T; + event: WorkerMessageEvents + data: T } export enum WorkerMessageEvents { - startWorkerElement = 'startWorkerElement', + addWorkerElement = 'addWorkerElement', + addedWorkerElement = 'addedWorkerElement', + workerElementError = 'workerElementError' }