eswyft/jobd
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

jobd: status format update

Browse Source
This commit is contained in:
Evgeny Zinoviev 2021-03-05 00:45:18 +03:00
parent a36dd3d5db
commit 3dd9da8864
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/jobd.js
View File

@ -190,7 +190,7 @@ function onStatus(data, requestNo, connection) {
connection.send( connection.send(
new ResponseMessage(requestNo) new ResponseMessage(requestNo)
.setData({ .setData({
queue: qs, targets: qs.targets,
jobPromisesCount: Object.keys(jobPromises).length, jobPromisesCount: Object.keys(jobPromises).length,
memoryUsage: process.memoryUsage() memoryUsage: process.memoryUsage()
}) })

7
src/lib/worker.js
View File

@ -145,10 +145,13 @@ class Worker extends EventEmitter {
let status = {targets: {}} let status = {targets: {}}
for (const targetName in this.targets) { for (const targetName in this.targets) {
let target = this.targets[targetName] let target = this.targets[targetName]
status.targets[targetName] = {} status.targets[targetName] = {
paused: target.paused,
slots: {}
}
for (const slotName in target.slots) { for (const slotName in target.slots) {
const queue = target.slots[slotName] const queue = target.slots[slotName]
status.targets[targetName][slotName] = { status.targets[targetName].slots[slotName] = {
concurrency: queue.concurrency, concurrency: queue.concurrency,
length: queue.length, length: queue.length,
} }