RoundRobinWorkerChoiceStrategy
} = require('../../../lib/pools/selection-strategies/round-robin-worker-choice-strategy')
const {
- LessUsedWorkerChoiceStrategy
-} = require('../../../lib/pools/selection-strategies/less-used-worker-choice-strategy')
+ LeastUsedWorkerChoiceStrategy
+} = require('../../../lib/pools/selection-strategies/least-used-worker-choice-strategy')
const {
- LessBusyWorkerChoiceStrategy
-} = require('../../../lib/pools/selection-strategies/less-busy-worker-choice-strategy')
+ LeastBusyWorkerChoiceStrategy
+} = require('../../../lib/pools/selection-strategies/least-busy-worker-choice-strategy')
+const {
+ LeastEluWorkerChoiceStrategy
+} = require('../../../lib/pools/selection-strategies/least-elu-worker-choice-strategy')
const {
FairShareWorkerChoiceStrategy
} = require('../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy')
const {
WeightedRoundRobinWorkerChoiceStrategy
} = require('../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy')
+const {
+ InterleavedWeightedRoundRobinWorkerChoiceStrategy
+} = require('../../../lib/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy')
describe('Worker choice strategy context test suite', () => {
const min = 1
)
})
- it('Verify that setWorkerChoiceStrategy() works with LESS_USED and fixed pool', () => {
- const workerChoiceStrategy = WorkerChoiceStrategies.LESS_USED
+ it('Verify that setWorkerChoiceStrategy() works with LEAST_USED and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_USED
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
)
- ).toBeInstanceOf(LessUsedWorkerChoiceStrategy)
+ ).toBeInstanceOf(LeastUsedWorkerChoiceStrategy)
expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
workerChoiceStrategy
)
})
- it('Verify that setWorkerChoiceStrategy() works with LESS_USED and dynamic pool', () => {
- const workerChoiceStrategy = WorkerChoiceStrategies.LESS_USED
+ it('Verify that setWorkerChoiceStrategy() works with LEAST_USED and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_USED
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
)
- ).toBeInstanceOf(LessUsedWorkerChoiceStrategy)
+ ).toBeInstanceOf(LeastUsedWorkerChoiceStrategy)
expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
workerChoiceStrategy
)
})
- it('Verify that setWorkerChoiceStrategy() works with LESS_BUSY and fixed pool', () => {
- const workerChoiceStrategy = WorkerChoiceStrategies.LESS_BUSY
+ it('Verify that setWorkerChoiceStrategy() works with LEAST_BUSY and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_BUSY
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
)
- ).toBeInstanceOf(LessBusyWorkerChoiceStrategy)
+ ).toBeInstanceOf(LeastBusyWorkerChoiceStrategy)
expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
workerChoiceStrategy
)
})
- it('Verify that setWorkerChoiceStrategy() works with LESS_BUSY and dynamic pool', () => {
- const workerChoiceStrategy = WorkerChoiceStrategies.LESS_BUSY
+ it('Verify that setWorkerChoiceStrategy() works with LEAST_BUSY and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_BUSY
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
)
- ).toBeInstanceOf(LessBusyWorkerChoiceStrategy)
+ ).toBeInstanceOf(LeastBusyWorkerChoiceStrategy)
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
+ )
+ })
+
+ it('Verify that setWorkerChoiceStrategy() works with LEAST_ELU and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_ELU
+ const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
+ fixedPool
+ )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.workerChoiceStrategies.get(
+ workerChoiceStrategy
+ )
+ ).toBeInstanceOf(LeastEluWorkerChoiceStrategy)
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
+ )
+ })
+
+ it('Verify that setWorkerChoiceStrategy() works with LEAST_ELU and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_ELU
+ const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
+ dynamicPool
+ )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.workerChoiceStrategies.get(
+ workerChoiceStrategy
+ )
+ ).toBeInstanceOf(LeastEluWorkerChoiceStrategy)
expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
workerChoiceStrategy
)
)
})
- it('Verify that worker choice strategy options enable median run time pool statistics', () => {
+ it('Verify that setWorkerChoiceStrategy() works with INTERLEAVED_WEIGHTED_ROUND_ROBIN and fixed pool', () => {
+ const workerChoiceStrategy =
+ WorkerChoiceStrategies.INTERLEAVED_WEIGHTED_ROUND_ROBIN
+ const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
+ fixedPool
+ )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.workerChoiceStrategies.get(
+ workerChoiceStrategy
+ )
+ ).toBeInstanceOf(InterleavedWeightedRoundRobinWorkerChoiceStrategy)
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
+ )
+ })
+
+ it('Verify that setWorkerChoiceStrategy() works with INTERLEAVED_WEIGHTED_ROUND_ROBIN and dynamic pool', () => {
+ const workerChoiceStrategy =
+ WorkerChoiceStrategies.INTERLEAVED_WEIGHTED_ROUND_ROBIN
+ const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
+ dynamicPool
+ )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.workerChoiceStrategies.get(
+ workerChoiceStrategy
+ )
+ ).toBeInstanceOf(InterleavedWeightedRoundRobinWorkerChoiceStrategy)
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
+ )
+ })
+
+ it('Verify that worker choice strategy options enable median runtime pool statistics', () => {
const wwrWorkerChoiceStrategy = WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
let workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool,
wwrWorkerChoiceStrategy,
{
- medRunTime: true
+ runTime: { median: true }
}
)
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime
+ .average
+ ).toBe(false)
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median
+ ).toBe(true)
workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool,
wwrWorkerChoiceStrategy,
{
- medRunTime: true
+ runTime: { median: true }
}
)
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime
+ .average
+ ).toBe(false)
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median
+ ).toBe(true)
const fsWorkerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE
workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool,
fsWorkerChoiceStrategy,
{
- medRunTime: true
+ runTime: { median: true }
}
)
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime
+ .average
+ ).toBe(false)
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median
+ ).toBe(true)
workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool,
fsWorkerChoiceStrategy,
{
- medRunTime: true
+ runTime: { median: true }
}
)
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime
+ .average
+ ).toBe(false)
+ expect(
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median
+ ).toBe(true)
})
})