X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=12d5ab26f13f7d62c408f20a8f55f09b862ca7b5;hb=b3d7d65476a4ab586b3ccd188f0bfbe8452aba0e;hp=7bcb108e9a5fe3c89722956e19103ed1e77d9b96;hpb=0bde1ea1ef9f72552609d6314d0533d565a09aba;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index 7bcb108e..12d5ab26 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -4,20 +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 = { @@ -26,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', }