X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=12d5ab26f13f7d62c408f20a8f55f09b862ca7b5;hb=d929adcc32a8cc79f0c7182d16f70367b001d28c;hp=99ce69cd88091b3c1321592e5b2fb9ee747d16e1;hpb=19bdf4ca58ec313de2404dc598553a328b425722;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index 99ce69cd..12d5ab26 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -4,18 +4,24 @@ import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier'; export enum WorkerProcessType { workerSet = 'workerSet', + /** @experimental */ dynamicPool = 'dynamicPool', staticPool = 'staticPool', } -export type SetInfo = { +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 = { @@ -24,27 +30,29 @@ export const WorkerEvents = { } as const; export type WorkerEvents = PoolEvent | WorkerSetEvents; -export type WorkerOptions = { +export interface WorkerOptions { workerStartDelay?: number; elementStartDelay?: number; poolMaxSize: number; poolMinSize: number; elementsPerWorker?: number; poolOptions?: ThreadPoolOptions; -}; +} export type WorkerData = Record; -export type WorkerSetElement = { +export interface WorkerSetElement { worker: Worker; numberOfWorkerElements: number; -}; +} -export type WorkerMessage = { - id: WorkerMessageEvents; +export interface WorkerMessage { + event: WorkerMessageEvents; data: T; -}; +} export enum WorkerMessageEvents { startWorkerElement = 'startWorkerElement', + startWorkerElementError = 'startWorkerElementError', + startedWorkerElement = 'startedWorkerElement', }