- expect(workerNode.messageChannel).toBeInstanceOf(MessageChannel)
- expect(workerNode.tasksQueueBackPressureSize).toBe(12)
- expect(workerNode.tasksQueue).toBeInstanceOf(Deque)
- expect(workerNode.tasksQueue.size).toBe(0)
- expect(workerNode.taskFunctionsUsage).toBeInstanceOf(Map)
+ expect(threadWorkerNode.messageChannel).toBeInstanceOf(MessageChannel)
+ expect(threadWorkerNode.tasksQueueBackPressureSize).toBe(12)
+ expect(threadWorkerNode.tasksQueue).toBeInstanceOf(Deque)
+ expect(threadWorkerNode.tasksQueue.size).toBe(0)
+ expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
+
+ expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
+ expect(clusterWorkerNode.worker).toBe(clusterWorker)
+ expect(clusterWorkerNode.info).toStrictEqual({
+ id: clusterWorker.id,
+ type: WorkerTypes.cluster,
+ dynamic: false,
+ ready: false
+ })
+ expect(clusterWorkerNode.usage).toStrictEqual({
+ tasks: {
+ executed: 0,
+ executing: 0,
+ queued: 0,
+ maxQueued: 0,
+ stolen: 0,
+ failed: 0
+ },
+ runTime: {
+ history: new CircularArray()
+ },
+ waitTime: {
+ history: new CircularArray()
+ },
+ elu: {
+ idle: {
+ history: new CircularArray()
+ },
+ active: {
+ history: new CircularArray()
+ }
+ }
+ })
+ expect(clusterWorkerNode.messageChannel).toBeUndefined()
+ expect(clusterWorkerNode.tasksQueueBackPressureSize).toBe(12)
+ expect(clusterWorkerNode.tasksQueue).toBeInstanceOf(Deque)
+ expect(clusterWorkerNode.tasksQueue.size).toBe(0)
+ expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)