X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fworker%2FWorkerTypes.ts;h=b180983e8a9594c3e1308fa12679a4fc2cfd4493;hb=47f846b2a74439a610321356604f2f4184cb5c0b;hp=faf327dbede39d111c139d32b8dcd313d2981381;hpb=13a6f27c10768faa05acf33fd8e0637511d49e3e;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index faf327db..b180983e 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -4,15 +4,16 @@ import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier' export enum WorkerProcessType { workerSet = 'workerSet', + fixedPool = 'fixedPool', /** @experimental */ - dynamicPool = 'dynamicPool', - fixedPool = 'fixedPool' + dynamicPool = 'dynamicPool' } export interface SetInfo { version: string type: string worker: string + started: boolean size: number elementsExecuting: number elementsPerWorker: number @@ -22,7 +23,7 @@ export enum WorkerSetEvents { started = 'started', stopped = 'stopped', error = 'error', - elementStarted = 'elementStarted', + elementAdded = 'elementAdded', elementError = 'elementError' } @@ -35,7 +36,7 @@ export type WorkerEvents = PoolEvent | WorkerSetEvents export interface WorkerOptions { workerStartDelay?: number - elementStartDelay?: number + elementAddDelay?: number poolMaxSize: number poolMinSize: number elementsPerWorker?: number @@ -44,18 +45,26 @@ export interface WorkerOptions { export type WorkerData = Record +export interface WorkerDataError extends WorkerData { + event: WorkerMessageEvents + name: string + message: string + stack?: string +} + export interface WorkerSetElement { worker: Worker numberOfWorkerElements: number } export interface WorkerMessage { + uuid: `${string}-${string}-${string}-${string}` event: WorkerMessageEvents data: T } export enum WorkerMessageEvents { - startWorkerElement = 'startWorkerElement', - startWorkerElementError = 'startWorkerElementError', - startedWorkerElement = 'startedWorkerElement' + addWorkerElement = 'addWorkerElement', + addedWorkerElement = 'addedWorkerElement', + workerElementError = 'workerElementError' }