}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: maxMultiplier,
executing: 0,
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: maxMultiplier,
executing: 0,
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
}
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
}
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.waitTime.aggregate).toBeGreaterThanOrEqual(
- 0
- )
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.waitTime.aggregate).toBeGreaterThanOrEqual(0)
}
// We need to clean up the resources after our test
await pool.destroy()
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.waitTime.aggregate).toBeGreaterThanOrEqual(
- 0
- )
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.waitTime.aggregate).toBeGreaterThanOrEqual(0)
}
// We need to clean up the resources after our test
await pool.destroy()
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: expect.any(Number)
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.elu.utilization).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeLessThanOrEqual(1)
+ expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
// We need to clean up the resources after our test
await pool.destroy()
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: expect.any(Number)
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.elu.utilization).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeLessThanOrEqual(1)
+ expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
// We need to clean up the resources after our test
await pool.destroy()
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: expect.any(Number)
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.runTime.average).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeLessThanOrEqual(1)
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.runTime.average).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: expect.any(Number)
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.runTime.average).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeLessThanOrEqual(1)
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.runTime.average).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: expect.any(Number)
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.runTime.median).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.elu.utilization).toBeLessThanOrEqual(1)
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.runTime.median).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.runTime.average).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.runTime.average).toBeGreaterThanOrEqual(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThan(0)
- expect(workerNode.workerUsage.runTime.average).toBeGreaterThan(0)
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThan(0)
+ expect(workerNode.usage.runTime.average).toBeGreaterThan(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ expect(workerNode.usage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(
max * maxMultiplier
)
- expect(workerNode.workerUsage.runTime.aggregate).toBeGreaterThan(0)
- expect(workerNode.workerUsage.runTime.median).toBeGreaterThan(0)
+ expect(workerNode.usage.runTime.aggregate).toBeGreaterThan(0)
+ expect(workerNode.usage.runTime.median).toBeGreaterThan(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: maxMultiplier,
executing: 0,
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.workerUsage).toStrictEqual({
+ expect(workerNode.usage).toStrictEqual({
tasks: {
executed: maxMultiplier,
executing: 0,