X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=5c8c177fcfd4ee40e02b78ebb23818ef99ecbe9e;hb=45a9839313c9bd8e81d61349bde0ea3bb69adf6a;hp=cfbe2dacb3b71cb9d6b755eb829468363454da62;hpb=4c7c767b9ed625eee3e28f34bda8e63ecc4391b4;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index cfbe2dac..5c8c177f 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -1,60 +1,62 @@ -import type { Worker } from 'node:worker_threads'; +import type { Worker } from 'node:worker_threads' -import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier'; +import { type PoolEvent, PoolEvents, type ThreadPoolOptions } from 'poolifier' export enum WorkerProcessType { workerSet = 'workerSet', - /** @experimental */ - dynamicPool = 'dynamicPool', fixedPool = 'fixedPool', + /** @experimental */ + dynamicPool = 'dynamicPool' } export interface SetInfo { - version: string; - type: string; - worker: string; - size: number; - elementsExecuting: number; - elementsPerWorker: number; + version: string + type: string + worker: string + started: boolean + size: number + elementsExecuting: number + elementsPerWorker: number } export enum WorkerSetEvents { started = 'started', stopped = 'stopped', error = 'error', - elementStarted = 'elementStarted', - elementError = 'elementError', + elementAdded = 'elementAdded', + elementError = 'elementError' } export const WorkerEvents = { ...PoolEvents, - ...WorkerSetEvents, -} as const; -export type WorkerEvents = PoolEvent | WorkerSetEvents; + ...WorkerSetEvents +} as const +// eslint-disable-next-line @typescript-eslint/no-redeclare +export type WorkerEvents = PoolEvent | WorkerSetEvents export interface WorkerOptions { - workerStartDelay?: number; - elementStartDelay?: number; - poolMaxSize: number; - poolMinSize: number; - elementsPerWorker?: number; - poolOptions?: ThreadPoolOptions; + workerStartDelay?: number + elementStartDelay?: number + poolMaxSize: number + poolMinSize: number + elementsPerWorker?: number + poolOptions?: ThreadPoolOptions } -export type WorkerData = Record; +export type WorkerData = Record export interface WorkerSetElement { - worker: Worker; - numberOfWorkerElements: number; + worker: Worker + numberOfWorkerElements: number } export interface WorkerMessage { - event: WorkerMessageEvents; - data: T; + event: WorkerMessageEvents + data: T } export enum WorkerMessageEvents { - startWorkerElement = 'startWorkerElement', - startWorkerElementError = 'startWorkerElementError', - startedWorkerElement = 'startedWorkerElement', + addWorkerElement = 'addWorkerElement', + addedWorkerElement = 'addedWorkerElement', + workerElementError = 'workerElementError' }