Skip to content

Commit fc03f5a

Browse files
committed
feat(queue): show queue gloabl config if present
1 parent ab4cd7c commit fc03f5a

File tree

7 files changed

+284
-393
lines changed

7 files changed

+284
-393
lines changed

example/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
"@fastify/express": "^2.3.0",
2121
"bee-queue": "^1.4.0",
2222
"bull": "^4.12.4",
23-
"bullmq": "^5.51.0",
23+
"bullmq": "^5.63.0",
2424
"express": "^4.17.1",
2525
"fastify": "^4.13.0"
2626
}

example/yarn.lock

Lines changed: 227 additions & 232 deletions
Large diffs are not rendered by default.

package-lock.json

Lines changed: 6 additions & 149 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
"@semantic-release/github": "^7.0.7",
2424
"@semantic-release/npm": "^7.0.5",
2525
"@semantic-release/release-notes-generator": "^9.0.1",
26-
"bee-queue": "^1.2.3",
2726
"bull": "^3.16.0",
2827
"commitizen": "^4.2.5",
2928
"conventional-changelog-conventionalcommits": "^4.3.0",

src/server/views/dashboard/queueDetails.js

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
const {rest} = require('lodash');
12
const QueueHelpers = require('../helpers/queueHelpers');
23

34
async function handler(req, res) {
@@ -14,12 +15,19 @@ async function handler(req, res) {
1415
hasFlows: Flows.hasFlows(),
1516
});
1617

17-
let jobCounts, isPaused;
18+
let jobCounts, isPaused, globalConfig;
1819
if (queue.IS_BEE) {
1920
jobCounts = await queue.checkHealth();
2021
delete jobCounts.newestJob;
2122
} else if (queue.IS_BULLMQ) {
2223
jobCounts = await queue.getJobCounts(...QueueHelpers.BULLMQ_STATES);
24+
if (queue.getMeta) {
25+
const meta = await queue.getMeta();
26+
if (meta) {
27+
const {paused, ...restMeta} = meta;
28+
globalConfig = restMeta;
29+
}
30+
}
2331
} else {
2432
jobCounts = await queue.getJobCounts();
2533
}
@@ -37,6 +45,7 @@ async function handler(req, res) {
3745
queueIsBee: !!queue.IS_BEE,
3846
queueIsBullMQ: !!queue.IS_BULLMQ,
3947
hasFlows: Flows.hasFlows(),
48+
globalConfig,
4049
jobCounts,
4150
stats,
4251
});

src/server/views/dashboard/templates/queueDetails.hbs

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,23 @@
8686
</table>
8787
</div>
8888
</div>
89+
{{#if globalConfig}}
90+
<div class="panel panel-default">
91+
<div class="panel-heading">
92+
<h4 class="panel-title">Global Configuration</h4>
93+
</div>
94+
<div class="panel-body">
95+
<table class="table">
96+
{{#each globalConfig}}
97+
<tr>
98+
<th>{{ @key }}</th>
99+
<th>{{ this }}</th>
100+
</tr>
101+
{{/each}}
102+
</table>
103+
</div>
104+
</div>
105+
{{/if}}
89106
</div>
90107
</div>
91108

0 commit comments

Comments
 (0)