repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix: fix build after merge with main branch
[poolifier.git]
/
src
/
pools
/
worker.ts
diff --git
a/src/pools/worker.ts
b/src/pools/worker.ts
index 841a2bcb1513ba3dc017d4b599ef61e3329611ab..70e4a7edd0ee481a0b608bb53ae6463d3517c144 100644
(file)
--- a/
src/pools/worker.ts
+++ b/
src/pools/worker.ts
@@
-57,55
+57,71
@@
export interface Task<Data = unknown> {
}
/**
}
/**
- *
Worker tasks usage
statistics.
+ *
Measurement
statistics.
*
* @internal
*/
*
* @internal
*/
-export interface
TasksUsage
{
+export interface
MeasurementStatistics
{
/**
/**
- *
Number of tasks executed
.
+ *
Measurement aggregate
.
*/
*/
-
ran
: number
+
aggregate
: number
/**
/**
- *
Number of tasks running
.
+ *
Measurement average
.
*/
*/
-
running
: number
+
average
: number
/**
/**
- *
Tasks runtime
.
+ *
Measurement median
.
*/
*/
-
runTime
: number
+
median
: number
/**
/**
- *
Tasks runtime
history.
+ *
Measurement
history.
*/
*/
- runTimeHistory: CircularArray<number>
+ history: CircularArray<number>
+}
+
+/**
+ * Task statistics.
+ *
+ * @internal
+ */
+export interface TaskStatistics {
/**
/**
- *
Average tasks runtime
.
+ *
Number of executed tasks
.
*/
*/
-
avgRunTime
: number
+
executed
: number
/**
/**
- *
Median tasks runtime
.
+ *
Number of executing tasks
.
*/
*/
-
medRunTime
: number
+
executing
: number
/**
/**
- *
Tasks wait time
.
+ *
Number of queued tasks
.
*/
*/
-
waitTime
: number
+
readonly queued
: number
/**
/**
- *
Tasks wait time history
.
+ *
Number of failed tasks
.
*/
*/
- waitTimeHistory: CircularArray<number>
+ failed: number
+}
+
+/**
+ * Worker usage statistics.
+ *
+ * @internal
+ */
+export interface WorkerUsage {
/**
/**
- *
Average tasks wait time
.
+ *
Tasks statistics
.
*/
*/
- avgWaitTime: number
+ tasks: TaskStatistics
/**
/**
- *
Median tasks wait time
.
+ *
Tasks runtime statistics
.
*/
*/
- medWaitTime: number
+ runTime: MeasurementStatistics
/**
/**
- *
Number of tasks errored
.
+ *
Tasks wait time statistics
.
*/
*/
- error: number
+ waitTime: MeasurementStatistics
/**
* Event loop utilization.
*/
/**
* Event loop utilization.
*/
@@
-148,9
+164,9
@@
export interface WorkerNode<Worker extends IWorker, Data = unknown> {
*/
readonly worker: Worker
/**
*/
readonly worker: Worker
/**
- * Worker node
tasks
usage statistics.
+ * Worker node
worker
usage statistics.
*/
*/
-
tasksUsage: Tasks
Usage
+
workerUsage: Worker
Usage
/**
* Worker node tasks queue.
*/
/**
* Worker node tasks queue.
*/