X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=cfbe2dacb3b71cb9d6b755eb829468363454da62;hb=8b75cab6a9906ba8a0a571c07cc80489c761dc15;hp=3986164bfb82471657cdc7f5188216f890ddb4d6;hpb=628c30e510dd0f12be4432bd5eb0ff86790c4de0;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index 3986164b..cfbe2dac 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -4,21 +4,26 @@ import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier'; export enum WorkerProcessType { workerSet = 'workerSet', + /** @experimental */ dynamicPool = 'dynamicPool', - staticPool = 'staticPool', + fixedPool = 'fixedPool', } -export type SetInfo = { +export interface SetInfo { version: string; type: string; worker: string; size: number; elementsExecuting: number; elementsPerWorker: number; -}; +} export enum WorkerSetEvents { + started = 'started', + stopped = 'stopped', error = 'error', + elementStarted = 'elementStarted', + elementError = 'elementError', } export const WorkerEvents = { @@ -27,27 +32,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', }