)
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
runTime: { median: false },
- waitTime: { median: false }
+ waitTime: { median: false },
+ elu: { median: false }
})
expect(pool.opts.messageHandler).toBeUndefined()
expect(pool.opts.errorHandler).toBeUndefined()
)
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
runTime: { median: false },
- waitTime: { median: false }
+ waitTime: { median: false },
+ elu: { median: false }
})
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
runTime: { median: false },
- waitTime: { median: false }
+ waitTime: { median: false },
+ elu: { median: false }
})
}
expect(
average: false,
median: false
},
- elu: false
+ elu: {
+ aggregate: false,
+ average: false,
+ median: false
+ }
})
pool.setWorkerChoiceStrategyOptions({ runTime: { median: true } })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
average: false,
median: false
},
- elu: false
+ elu: {
+ aggregate: false,
+ average: false,
+ median: false
+ }
})
pool.setWorkerChoiceStrategyOptions({ runTime: { median: false } })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
average: false,
median: false
},
- elu: false
+ elu: {
+ aggregate: false,
+ average: false,
+ median: false
+ }
})
await pool.destroy()
})
median: 0,
history: expect.any(CircularArray)
},
- elu: undefined
+ elu: {
+ idle: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ active: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ utilization: 0
+ }
})
}
await pool.destroy()
median: 0,
history: expect.any(CircularArray)
},
- elu: undefined
+ elu: {
+ idle: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ active: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ utilization: 0
+ }
})
}
await Promise.all(promises)
median: 0,
history: expect.any(CircularArray)
},
- elu: undefined
+ elu: {
+ idle: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ active: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ utilization: 0
+ }
})
}
await pool.destroy()
median: 0,
history: expect.any(CircularArray)
},
- elu: undefined
+ elu: {
+ idle: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ active: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ utilization: 0
+ }
})
expect(workerNode.workerUsage.tasks.executed).toBeGreaterThan(0)
expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
median: 0,
history: expect.any(CircularArray)
},
- elu: undefined
+ elu: {
+ idle: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ active: {
+ aggregate: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ utilization: 0
+ }
})
expect(workerNode.workerUsage.runTime.history.length).toBe(0)
expect(workerNode.workerUsage.waitTime.history.length).toBe(0)