From 80a2172715b6dd225a331d8f2cbccc78dcbd1302 Mon Sep 17 00:00:00 2001 From: syuilo Date: Sun, 10 Mar 2019 19:16:33 +0900 Subject: Resolve #4462 --- src/daemons/queue-stats.ts | 43 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 src/daemons/queue-stats.ts (limited to 'src/daemons/queue-stats.ts') diff --git a/src/daemons/queue-stats.ts b/src/daemons/queue-stats.ts new file mode 100644 index 0000000000..26f2bf7c03 --- /dev/null +++ b/src/daemons/queue-stats.ts @@ -0,0 +1,43 @@ +import * as Deque from 'double-ended-queue'; +import Xev from 'xev'; +import { deliverQueue, inboxQueue } from '../queue'; + +const ev = new Xev(); + +const interval = 1000; + +/** + * Report queue stats regularly + */ +export default function() { + const log = new Deque(); + + ev.on('requestQueueStatsLog', x => { + ev.emit(`queueStatsLog:${x.id}`, log.toArray().slice(0, x.length || 50)); + }); + + async function tick() { + const deliverJobCounts = await deliverQueue.getJobCounts(); + const inboxJobCounts = await inboxQueue.getJobCounts(); + + const stats = { + deliver: { + active: Math.floor(Math.random() * 100), + delayed: Math.floor(Math.random() * 1000), + }, + inbox: { + active: Math.floor(Math.random() * 100), + delayed: Math.floor(Math.random() * 1000), + } + }; + + ev.emit('queueStats', stats); + + log.unshift(stats); + if (log.length > 200) log.pop(); + } + + tick(); + + setInterval(tick, interval); +} -- cgit v1.2.3-freya