repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'elu-strategy' of github.com:poolifier/poolifier into elu-strategy
[poolifier.git]
/
src
/
pools
/
worker.ts
diff --git
a/src/pools/worker.ts
b/src/pools/worker.ts
index 841a2bcb1513ba3dc017d4b599ef61e3329611ab..ba9393ab9ba8241e5f1a1184165d42055b859835 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 aggregation
.
*/
*/
-
ra
n: number
+
aggregatio
n: 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 tasks executed
.
*/
*/
-
avgRunTime
: number
+
executed
: number
/**
/**
- *
Median tasks runtime
.
+ *
Number of tasks executing
.
*/
*/
-
medRunTime
: number
+
executing
: number
/**
/**
- *
Tasks wait time
.
+ *
Number of tasks queued
.
*/
*/
-
waitTime
: number
+
queued
: number
/**
/**
- *
Tasks wait time history
.
+ *
Number of tasks failed
.
*/
*/
- 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.
*/