X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=82aed5526c976a1d05691dd04d922d4f33bcd5ee;hb=b46d5ebcbac30dbc70aa7c47433fd20204f1b01e;hp=1f8efbc66e429bc65f58aa8ecbcf5b9807f88f6d;hpb=0274ce2ddfe129ce40ff5b322f52777449902386;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 1f8efbc6..82aed552 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -30,29 +30,55 @@ export type ExitHandler = ( ) => void /** - * Worker task interface. + * Message object that is passed as a task between main worker and worker. + * + * @typeParam Data - Type of data sent to the worker. This can only be serializable data. + * @internal */ export interface Task { /** - * Worker task data. + * Input data that will be passed to the worker. */ - data: Data + readonly data?: Data /** - * Task UUID. + * UUID of the message. */ - id: string + readonly id?: string } /** * Worker tasks usage statistics. + * + * @internal */ export interface TasksUsage { + /** + * Number of tasks executed. + */ run: number + /** + * Number of tasks running. + */ running: number + /** + * Tasks runtime. + */ runTime: number + /** + * Tasks runtime history. + */ runTimeHistory: CircularArray + /** + * Average tasks runtime. + */ avgRunTime: number + /** + * Median tasks runtime. + */ medRunTime: number + /** + * Number of tasks errored. + */ error: number } @@ -81,9 +107,22 @@ export interface IWorker { /** * Worker node interface. + * + * @typeParam Worker - Type of worker. + * @typeParam Data - Type of data sent to the worker. This can only be serializable data. + * @internal */ export interface WorkerNode { - worker: Worker + /** + * Worker node worker. + */ + readonly worker: Worker + /** + * Worker node tasks usage statistics. + */ tasksUsage: TasksUsage - tasksQueue: Array> + /** + * Worker node tasks queue. + */ + readonly tasksQueue: Array> }