const workerUsage = this.workerNodes[workerNodeKey].usage
++workerUsage.tasks.executing
this.updateWaitTimeWorkerUsage(workerUsage, task)
- const tasksWorkerUsage = this.workerNodes[
- workerNodeKey
- ].getTasksWorkerUsage(task.name as string) as WorkerUsage
+ const tasksWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage(
+ task.name as string
+ ) as WorkerUsage
++tasksWorkerUsage.tasks.executing
this.updateWaitTimeWorkerUsage(tasksWorkerUsage, task)
}
this.updateTaskStatisticsWorkerUsage(workerUsage, message)
this.updateRunTimeWorkerUsage(workerUsage, message)
this.updateEluWorkerUsage(workerUsage, message)
- const tasksWorkerUsage = this.workerNodes[
- workerNodeKey
- ].getTasksWorkerUsage(message.name as string) as WorkerUsage
+ const tasksWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage(
+ message.name as string
+ ) as WorkerUsage
this.updateTaskStatisticsWorkerUsage(tasksWorkerUsage, message)
this.updateRunTimeWorkerUsage(tasksWorkerUsage, message)
this.updateEluWorkerUsage(tasksWorkerUsage, message)
}
/** @inheritdoc */
- public getTasksWorkerUsage (name: string): WorkerUsage | undefined {
+ public getTaskWorkerUsage (name: string): WorkerUsage | undefined {
if (!this.tasksUsage.has(name)) {
this.tasksUsage.set(name, this.initTaskWorkerUsage(name))
}
*/
readonly resetUsage: () => void
/**
- * Worker node get tasks usage statistics.
+ * Worker node get task usage statistics.
*/
- readonly getTasksWorkerUsage: (name: string) => WorkerUsage | undefined
+ readonly getTaskWorkerUsage: (name: string) => WorkerUsage | undefined
}