X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Ftypes%2FWorker.ts;h=c9882ccdadbd6c0b95a0fa547e5a25ad1ed92a2c;hb=85c603dabe1b0415dfa956baec73f34267093cf0;hp=20c4488224f620f68e415426384446fb1239a7ed;hpb=a4624c96a6c159b4885f5d0baaf592ceec0bab30;p=e-mobility-charging-stations-simulator.git diff --git a/src/types/Worker.ts b/src/types/Worker.ts index 20c44882..c9882ccd 100644 --- a/src/types/Worker.ts +++ b/src/types/Worker.ts @@ -1,23 +1,38 @@ import { Worker } from 'worker_threads'; +import { PoolOptions } from 'poolifier'; + +import { JsonObject } from './JsonType'; + export enum WorkerProcessType { WORKER_SET = 'workerSet', DYNAMIC_POOL = 'dynamicPool', - STATIC_POOL = 'staticPool' + STATIC_POOL = 'staticPool', } -// FIXME: make it more generic -export interface WorkerData { - index: number; - templateFile: string; +export interface WorkerOptions { + workerStartDelay?: number; + elementStartDelay?: number; + poolMaxSize?: number; + poolMinSize?: number; + elementsPerWorker?: number; + poolOptions?: PoolOptions; + messageHandler?: (message: unknown) => void | Promise; } +export type WorkerData = JsonObject; + export interface WorkerSetElement { - worker: Worker, - numberOfWorkerElements: number + worker: Worker; + numberOfWorkerElements: number; } -export enum WorkerEvents { - START_WORKER_ELEMENT = 'startWorkerElement', +export interface WorkerMessage { + id: WorkerMessageEvents; + data: T; } +export enum WorkerMessageEvents { + START_WORKER_ELEMENT = 'startWorkerElement', + STOP_WORKER_ELEMENT = 'stopWorkerElement', +}