X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerTypes.ts;h=faf327dbede39d111c139d32b8dcd313d2981381;hb=5a15db9001b93665ab7581d2974c5f01a9e0fbe3;hp=5bf339fb976677ef3a8e275b399330758ecdea75;hpb=56e2e1ab1829773ae32048930fbf6c4c98333891;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts index 5bf339fb..faf327db 100644 --- a/src/worker/WorkerTypes.ts +++ b/src/worker/WorkerTypes.ts @@ -1,54 +1,61 @@ -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', - staticPool = 'staticPool', + fixedPool = 'fixedPool' } -export type SetInfo = { - version: string; - type: string; - worker: string; - size: number; - elementsExecuting: number; - elementsPerWorker: number; -}; +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 = { ...PoolEvents, - ...WorkerSetEvents, -} as const; -export type WorkerEvents = PoolEvent | WorkerSetEvents; - -export type WorkerOptions = { - workerStartDelay?: number; - elementStartDelay?: number; - poolMaxSize: number; - poolMinSize: number; - elementsPerWorker?: number; - poolOptions?: ThreadPoolOptions; -}; - -export type WorkerData = Record; - -export type WorkerSetElement = { - worker: Worker; - numberOfWorkerElements: number; -}; - -export type WorkerMessage = { - id: WorkerMessageEvents; - data: T; -}; + ...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 +} + +export type WorkerData = Record + +export interface WorkerSetElement { + worker: Worker + numberOfWorkerElements: number +} + +export interface WorkerMessage { + event: WorkerMessageEvents + data: T +} export enum WorkerMessageEvents { startWorkerElement = 'startWorkerElement', + startWorkerElementError = 'startWorkerElementError', + startedWorkerElement = 'startedWorkerElement' }