repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: measure -> measurement
[poolifier.git]
/
src
/
pools
/
worker.ts
diff --git
a/src/pools/worker.ts
b/src/pools/worker.ts
index d10a27c9171c978ce44e7b9f6a1d2a9fb66131db..ba9393ab9ba8241e5f1a1184165d42055b859835 100644
(file)
--- a/
src/pools/worker.ts
+++ b/
src/pools/worker.ts
@@
-47,9
+47,9
@@
export interface Task<Data = unknown> {
*/
readonly data?: Data
/**
*/
readonly data?: Data
/**
- *
Submission t
imestamp.
+ *
T
imestamp.
*/
*/
- readonly
submissionT
imestamp?: number
+ readonly
t
imestamp?: number
/**
* Message UUID.
*/
/**
* Message UUID.
*/
@@
-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.
*/