@bull-board/api - npm Package Compare versions

Comparing version 7.1.5 to 7.2.0

dist/handlers/metrics.d.ts

+import { BullBoardRequest, ControllerHandlerReturnType } from '../../typings/app';
+export declare const metricsHandler: (req: BullBoardRequest) => Promise<ControllerHandlerReturnType>;

dist/handlers/metrics.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.metricsHandler = void 0;
+const queue_1 = require("../providers/queue");
+async function getMetrics(_req, queue) {
+    const [completed, failed] = await Promise.all([
+        queue.getMetrics('completed').catch(() => null),
+        queue.getMetrics('failed').catch(() => null),
+    ]);
+    return {
+        status: 200,
+        body: { completed, failed },
+    };
+}
+exports.metricsHandler = (0, queue_1.queueProvider)(getMetrics, {
+    skipReadOnlyModeCheck: true,
+});
+//# sourceMappingURL=metrics.js.map

dist/handlers/metrics.js.map

+{"version":3,"file":"metrics.js","sourceRoot":"","sources":["../../src/handlers/metrics.ts"],"names":[],"mappings":";;;AAEA,8CAAmD;AAEnD,KAAK,UAAU,UAAU,CACvB,IAAsB,EACtB,KAAkB;IAElB,MAAM,CAAC,SAAS,EAAE,MAAM,CAAC,GAAG,MAAM,OAAO,CAAC,GAAG,CAAC;QAC5C,KAAK,CAAC,UAAU,CAAC,WAAW,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC;QAC/C,KAAK,CAAC,UAAU,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC;KAC7C,CAAC,CAAC;IAEH,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE,SAAS,EAAE,MAAM,EAAE;KAC5B,CAAC;AACJ,CAAC;AAEY,QAAA,cAAc,GAAG,IAAA,qBAAa,EAAC,UAAU,EAAE;IACtD,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}

dist/queueAdapters/base.d.ts

@@ -1,2 +0,2 @@
-import { BullBoardRequest, FormatterField, JobCleanStatus, JobCounts, JobStatus, QueueAdapterOptions, QueueJob, QueueJobOptions, QueueType, Status } from '../../typings/app';
+import { BullBoardRequest, FormatterField, JobCleanStatus, JobCounts, JobStatus, MetricsType, QueueAdapterOptions, QueueJob, QueueJobOptions, QueueMetrics, QueueType, Status } from '../../typings/app';
 export declare abstract class BaseAdapter {
@@ -29,2 +29,3 @@ readonly readOnlyMode: boolean;
     abstract getJobLogs(id: string): Promise<string[]>;
+    abstract getMetrics(type: MetricsType, start?: number, end?: number): Promise<QueueMetrics>;
     abstract getName(): string;
@@ -31,0 +32,0 @@ abstract getRedisInfo(): Promise<string>;

dist/queueAdapters/base.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"base.js","sourceRoot":"","sources":["../../src/queueAdapters/base.ts"],"names":[],"mappings":";;;AAaA,MAAsB,WAAW;IAa/B,YACE,IAAe,EACf,UAA6E,EAAE;QALzE,eAAU,GAAG,IAAI,GAAG,EAAsC,CAAC;QAC3D,qBAAgB,GAA8D,GAAG,EAAE,CAAC,IAAI,CAAC;QAM/F,IAAI,CAAC,YAAY,GAAG,OAAO,CAAC,YAAY,KAAK,IAAI,CAAC;QAClD,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,YAAY,KAAK,KAAK,CAAC;QAC/E,IAAI,CAAC,qBAAqB,GAAG,IAAI,CAAC,YAAY,IAAI,OAAO,CAAC,qBAAqB,KAAK,KAAK,CAAC;QAC1F,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,IAAI,EAAE,CAAC;QACnC,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,SAAS,IAAI,EAAE,CAAC;QACzC,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,WAAW,IAAI,EAAE,CAAC;QAC7C,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,WAAW,IAAI,EAAE,CAAC;QAC7C,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,cAAc,GAAG,OAAO,CAAC,cAAc,CAAC;IAC/C,CAAC;IAEM,cAAc;QACnB,OAAO,IAAI,CAAC,WAAW,CAAC;IAC1B,CAAC;IAEM,cAAc;QACnB,OAAO,IAAI,CAAC,WAAW,CAAC;IAC1B,CAAC;IAEM,YAAY,CACjB,KAAQ,EACR,SAAyD;QAEzD,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;IACxC,CAAC;IAEM,MAAM,CAAC,KAAqB,EAAE,IAAS,EAAE,YAAY,GAAG,IAAI;QACjE,MAAM,cAAc,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QAClD,OAAO,OAAO,cAAc,KAAK,UAAU,CAAC,CAAC,CAAC,cAAc,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC;IACpF,CAAC;IAEM,kBAAkB,CAAC,KAAgE;QACxF,IAAI,CAAC,gBAAgB,GAAG,KAAK,CAAC;IAChC,CAAC;IAEM,SAAS,CAAC,OAAyB;QACxC,OAAO,IAAI,CAAC,gBAAgB,CAAC,OAAO,CAAC,CAAC;IACxC,CAAC;CA2CF;AAjGD,kCAiGC"}
+{"version":3,"file":"base.js","sourceRoot":"","sources":["../../src/queueAdapters/base.ts"],"names":[],"mappings":";;;AAeA,MAAsB,WAAW;IAa/B,YACE,IAAe,EACf,UAA6E,EAAE;QALzE,eAAU,GAAG,IAAI,GAAG,EAAsC,CAAC;QAC3D,qBAAgB,GAA8D,GAAG,EAAE,CAAC,IAAI,CAAC;QAM/F,IAAI,CAAC,YAAY,GAAG,OAAO,CAAC,YAAY,KAAK,IAAI,CAAC;QAClD,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,YAAY,KAAK,KAAK,CAAC;QAC/E,IAAI,CAAC,qBAAqB,GAAG,IAAI,CAAC,YAAY,IAAI,OAAO,CAAC,qBAAqB,KAAK,KAAK,CAAC;QAC1F,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,IAAI,EAAE,CAAC;QACnC,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,SAAS,IAAI,EAAE,CAAC;QACzC,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,WAAW,IAAI,EAAE,CAAC;QAC7C,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,WAAW,IAAI,EAAE,CAAC;QAC7C,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,cAAc,GAAG,OAAO,CAAC,cAAc,CAAC;IAC/C,CAAC;IAEM,cAAc;QACnB,OAAO,IAAI,CAAC,WAAW,CAAC;IAC1B,CAAC;IAEM,cAAc;QACnB,OAAO,IAAI,CAAC,WAAW,CAAC;IAC1B,CAAC;IAEM,YAAY,CACjB,KAAQ,EACR,SAAyD;QAEzD,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;IACxC,CAAC;IAEM,MAAM,CAAC,KAAqB,EAAE,IAAS,EAAE,YAAY,GAAG,IAAI;QACjE,MAAM,cAAc,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QAClD,OAAO,OAAO,cAAc,KAAK,UAAU,CAAC,CAAC,CAAC,cAAc,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC;IACpF,CAAC;IAEM,kBAAkB,CAAC,KAAgE;QACxF,IAAI,CAAC,gBAAgB,GAAG,KAAK,CAAC;IAChC,CAAC;IAEM,SAAS,CAAC,OAAyB;QACxC,OAAO,IAAI,CAAC,gBAAgB,CAAC,OAAO,CAAC,CAAC;IACxC,CAAC;CAiDF;AAvGD,kCAuGC"}

dist/queueAdapters/bull.d.ts

 import BullQueue, { Job, Queue } from 'bull';
-import { JobCleanStatus, JobCounts, JobStatus, QueueAdapterOptions, QueueJobOptions, Status } from '../../typings/app';
+import { JobCleanStatus, JobCounts, JobStatus, MetricsType, QueueAdapterOptions, QueueJobOptions, QueueMetrics, Status } from '../../typings/app';
 import { BaseAdapter } from './base';
@@ -15,2 +15,3 @@ export declare class BullAdapter extends BaseAdapter {
     getJobLogs(id: string): Promise<string[]>;
+    getMetrics(type: MetricsType, start?: number, end?: number): Promise<QueueMetrics>;
     isPaused(): Promise<boolean>;
@@ -17,0 +18,0 @@ pause(): Promise<void>;

dist/queueAdapters/bull.js

@@ -44,2 +44,6 @@ "use strict";
     }
+    async getMetrics(type, start, end) {
+        const metrics = await this.queue.getMetrics(type, start, end);
+        return { ...metrics, data: metrics.data.map((point) => +point || 0) };
+    }
     isPaused() {
@@ -46,0 +50,0 @@ return this.queue.isPaused();

dist/queueAdapters/bull.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"bull.js","sourceRoot":"","sources":["../../src/queueAdapters/bull.ts"],"names":[],"mappings":";;;;;;AAAA,gDAA6C;AAU7C,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,WAAY,SAAQ,kBAAW;IAC1C,YACS,KAAY,EACnB,UAAwC,EAAE;QAE1C,KAAK,CAAC,MAAM,EAAE,EAAE,GAAG,OAAO,EAAE,qBAAqB,EAAE,KAAK,EAAE,CAAC,CAAC;QAHrD,UAAK,GAAL,KAAK,CAAO;QAKnB,IAAI,CAAC,CAAC,KAAK,YAAY,cAAS,CAAC,EAAE,CAAC;YAClC,MAAM,IAAI,KAAK,CAAC,qDAAqD,CAAC,CAAC;QACzE,CAAC;IACH,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,CAAC;IAClC,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,SAAyB,EAAE,WAAmB;QACzD,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,SAAgB,CAAC,CAAC;IACzD,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,KAAK,CAAC,MAAM,CAAC,EAAU;QAC5B,MAAM,GAAG,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QACxC,OAAO,GAAG,IAAI,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC;IACvC,CAAC;IAEM,KAAK,CAAC,OAAO,CAClB,WAAgC,EAChC,KAAc,EACd,GAAY;QAEZ,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC/D,OAAO,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC;IACrC,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;QACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;IACtD,CAAC;IAEM,KAAK,CAAC,kBAAkB,CAAC,GAAW;QACzC,OAAO,KAAK,CAAC;IACf,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,KAAK,CAAC,oBAAoB;QAC/B,OAAO,IAAI,CAAC;IACd,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,YAAoB;QACpD,2CAA2C;IAC7C,CAAC;IAEO,YAAY,CAAC,GAAQ;QAC3B,IAAI,OAAO,CAAA,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,YAAY,CAAA,KAAK,QAAQ,EAAE,CAAC;YAC1C,GAAG,CAAC,YAAY,EAAE,CAAC;QACrB,CAAC;QACD,OAAO,GAAG,CAAC;IACb,CAAC;CACF;AApHD,kCAoHC"}
+{"version":3,"file":"bull.js","sourceRoot":"","sources":["../../src/queueAdapters/bull.ts"],"names":[],"mappings":";;;;;;AAAA,gDAA6C;AAY7C,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,WAAY,SAAQ,kBAAW;IAC1C,YACS,KAAY,EACnB,UAAwC,EAAE;QAE1C,KAAK,CAAC,MAAM,EAAE,EAAE,GAAG,OAAO,EAAE,qBAAqB,EAAE,KAAK,EAAE,CAAC,CAAC;QAHrD,UAAK,GAAL,KAAK,CAAO;QAKnB,IAAI,CAAC,CAAC,KAAK,YAAY,cAAS,CAAC,EAAE,CAAC;YAClC,MAAM,IAAI,KAAK,CAAC,qDAAqD,CAAC,CAAC;QACzE,CAAC;IACH,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,CAAC;IAClC,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,SAAyB,EAAE,WAAmB;QACzD,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,SAAgB,CAAC,CAAC;IACzD,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,KAAK,CAAC,MAAM,CAAC,EAAU;QAC5B,MAAM,GAAG,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QACxC,OAAO,GAAG,IAAI,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC;IACvC,CAAC;IAEM,KAAK,CAAC,OAAO,CAClB,WAAgC,EAChC,KAAc,EACd,GAAY;QAEZ,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC/D,OAAO,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC;IACrC,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,KAAK,CAAC,UAAU,CAAC,IAAiB,EAAE,KAAc,EAAE,GAAY;QACrE,MAAM,OAAO,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC9D,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,KAAK,IAAI,CAAC,CAAC,EAAE,CAAC;IACxE,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;QACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;IACtD,CAAC;IAEM,KAAK,CAAC,kBAAkB,CAAC,GAAW;QACzC,OAAO,KAAK,CAAC;IACf,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,KAAK,CAAC,oBAAoB;QAC/B,OAAO,IAAI,CAAC;IACd,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,YAAoB;QACpD,2CAA2C;IAC7C,CAAC;IAEO,YAAY,CAAC,GAAQ;QAC3B,IAAI,OAAO,CAAA,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,YAAY,CAAA,KAAK,QAAQ,EAAE,CAAC;YAC1C,GAAG,CAAC,YAAY,EAAE,CAAC;QACrB,CAAC;QACD,OAAO,GAAG,CAAC;IACb,CAAC;CACF;AAzHD,kCAyHC"}

dist/queueAdapters/bullMQ.d.ts

 import { Job, Queue } from 'bullmq';
-import { JobCleanStatus, JobCounts, JobStatus, QueueAdapterOptions, QueueJobOptions, Status } from '../../typings/app';
+import { JobCleanStatus, JobCounts, JobStatus, MetricsType, QueueAdapterOptions, QueueJobOptions, QueueMetrics, Status } from '../../typings/app';
 import { BaseAdapter } from './base';
@@ -15,2 +15,3 @@ export declare class BullMQAdapter extends BaseAdapter {
     getJobLogs(id: string): Promise<string[]>;
+    getMetrics(type: MetricsType, start?: number, end?: number): Promise<QueueMetrics>;
     isPaused(): Promise<boolean>;
@@ -17,0 +18,0 @@ pause(): Promise<void>;

dist/queueAdapters/bullMQ.js

@@ -42,2 +42,5 @@ "use strict";
     }
+    getMetrics(type, start, end) {
+        return this.queue.getMetrics(type, start, end);
+    }
     isPaused() {
@@ -44,0 +47,0 @@ return this.queue.isPaused();

dist/queueAdapters/bullMQ.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"bullMQ.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQ.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AAUpC,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,aAAc,SAAQ,kBAAW;IAC5C,YACU,KAAY,EACpB,UAAwC,EAAE;;QAE1C,MAAM,OAAO,GAAG,QAAQ,CAAC;QACzB,KAAK,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;QAJhB,UAAK,GAAL,KAAK,CAAO;QAKpB,IACE,CAAC,CAAC,KAAK,YAAY,cAAK,KAAI,MAAA,GAAG,MAAC,KAAe,CAAC,UAAU,0CAAE,OAAO,EAAE,0CAAE,UAAU,CAAC,OAAO,CAAC,CAAA,CAAC,EAC3F,CAAC;YACD,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAC;QAC7E,CAAC;IACH,CAAC;IAEM,KAAK,CAAC,YAAY;QACvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;QACvC,OAAO,MAAM,CAAC,IAAI,EAAE,CAAC;IACvB,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,KAAK,CAAC,SAAyB,EAAE,WAAmB;QAC/D,MAAM,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,MAAM,CAAC,gBAAgB,EAAE,SAAS,CAAC,CAAC;IAC1E,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,MAAM,CAAC,EAAU;QACtB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;IAC/B,CAAC;IAEM,OAAO,CAAC,WAAwB,EAAE,KAAc,EAAE,GAAY;QACnE,OAAO,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACrD,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,qBAAqB;QACrB,IAAI,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,KAAK,UAAU,EAAE,CAAC;YACjD,MAAM,IAAI,CAAC,KAAK,CAAC,WAAW,EAAE,CAAC;QACjC,CAAC;aAAM,CAAC;YACN,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;YACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QACtD,CAAC;IACH,CAAC;IAEM,kBAAkB,CAAC,EAAU;QAClC,OAAO,IAAI,CAAC,KAAK,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,SAAS;QACd,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;IAC3B,CAAC;IAEM,oBAAoB;;QACzB,OAAO,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,kDAAI,KAAI,IAAI,CAAC;IACrD,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,WAAmB;;QACnD,IAAI,WAAW,IAAI,CAAC,EAAE,CAAC;YACrB,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,uBAAuB,kDAAI,CAAA,CAAC;QAC/C,CAAC;aAAM,CAAC;YACN,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,mDAAG,WAAW,CAAC,CAAA,CAAC;QACvD,CAAC;IACH,CAAC;CACF;AA3HD,sCA2HC"}
+{"version":3,"file":"bullMQ.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQ.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AAYpC,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,aAAc,SAAQ,kBAAW;IAC5C,YACU,KAAY,EACpB,UAAwC,EAAE;;QAE1C,MAAM,OAAO,GAAG,QAAQ,CAAC;QACzB,KAAK,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;QAJhB,UAAK,GAAL,KAAK,CAAO;QAKpB,IACE,CAAC,CAAC,KAAK,YAAY,cAAK,KAAI,MAAA,GAAG,MAAC,KAAe,CAAC,UAAU,0CAAE,OAAO,EAAE,0CAAE,UAAU,CAAC,OAAO,CAAC,CAAA,CAAC,EAC3F,CAAC;YACD,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAC;QAC7E,CAAC;IACH,CAAC;IAEM,KAAK,CAAC,YAAY;QACvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;QACvC,OAAO,MAAM,CAAC,IAAI,EAAE,CAAC;IACvB,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,KAAK,CAAC,SAAyB,EAAE,WAAmB;QAC/D,MAAM,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,MAAM,CAAC,gBAAgB,EAAE,SAAS,CAAC,CAAC;IAC1E,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,MAAM,CAAC,EAAU;QACtB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;IAC/B,CAAC;IAEM,OAAO,CAAC,WAAwB,EAAE,KAAc,EAAE,GAAY;QACnE,OAAO,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACrD,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,UAAU,CAAC,IAAiB,EAAE,KAAc,EAAE,GAAY;QAC/D,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACjD,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,qBAAqB;QACrB,IAAI,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,KAAK,UAAU,EAAE,CAAC;YACjD,MAAM,IAAI,CAAC,KAAK,CAAC,WAAW,EAAE,CAAC;QACjC,CAAC;aAAM,CAAC;YACN,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;YACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QACtD,CAAC;IACH,CAAC;IAEM,kBAAkB,CAAC,EAAU;QAClC,OAAO,IAAI,CAAC,KAAK,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,SAAS;QACd,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;IAC3B,CAAC;IAEM,oBAAoB;;QACzB,OAAO,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,kDAAI,KAAI,IAAI,CAAC;IACrD,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,WAAmB;;QACnD,IAAI,WAAW,IAAI,CAAC,EAAE,CAAC;YACrB,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,uBAAuB,kDAAI,CAAA,CAAC;QAC/C,CAAC;aAAM,CAAC;YACN,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,mDAAG,WAAW,CAAC,CAAA,CAAC;QACvD,CAAC;IACH,CAAC;CACF;AA/HD,sCA+HC"}

dist/routes.js

@@ -11,2 +11,3 @@ "use strict";
 const jobLogs_1 = require("./handlers/jobLogs");
+const metrics_1 = require("./handlers/metrics");
 const job_1 = require("./handlers/job");
@@ -35,2 +36,7 @@ const jobFlow_1 = require("./handlers/jobFlow");
         { method: 'get', route: '/api/queues', handler: queues_1.queuesHandler },
+        {
+            method: 'get',
+            route: '/api/queues/:queueName/metrics',
+            handler: metrics_1.metricsHandler,
+        },
         { method: 'put', route: '/api/queues/pause', handler: pauseAll_1.pauseAllHandler },
@@ -37,0 +43,0 @@ { method: 'put', route: '/api/queues/resume', handler: resumeAll_1.resumeAllHandler },

dist/routes.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"routes.js","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":";;;AACA,8CAAkD;AAClD,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,gEAAoE;AACpE,sDAAmD;AACnD,gDAAoD;AACpD,wCAA4C;AAC5C,gDAAoD;AACpD,sDAA0D;AAC1D,oDAAyD;AACzD,8CAAkD;AAClD,sDAA0D;AAC1D,wDAA4D;AAC5D,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,4DAAgE;AAChE,kDAAsD;AACtD,oDAAwD;AACxD,0EAA8E;AAEjE,QAAA,SAAS,GAAiB;IACrC,UAAU,EAAE;QACV,MAAM,EAAE,KAAK;QACb,KAAK,EAAE,CAAC,GAAG,EAAE,mBAAmB,EAAE,0BAA0B,CAAC;QAC7D,OAAO,EAAE,uBAAU;KACpB;IACD,GAAG,EAAE;QACH,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,kBAAkB,EAAE,OAAO,EAAE,8BAAiB,EAAE;QACxE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,aAAa,EAAE,OAAO,EAAE,sBAAa,EAAE;QAC/D,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,mBAAmB,EAAE,OAAO,EAAE,0BAAe,EAAE;QACvE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,oBAAoB,EAAE,OAAO,EAAE,4BAAgB,EAAE;QACzE;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gBAAU;SACpB;QACD;YACE,MAAM,EAAE,MAAM;YACd,KAAK,EAAE,4BAA4B;YACnC,OAAO,EAAE,sBAAa;SACvB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gCAAkB;SAC5B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,kDAA2B;SACrC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,mCAAmC;YAC1C,OAAO,EAAE,wCAAsB;SAChC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,uCAAuC;YAC9C,OAAO,EAAE,6BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,OAAO;YACf,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,oCAAoB;SAC9B;KACF;CACF,CAAC"}
+{"version":3,"file":"routes.js","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":";;;AACA,8CAAkD;AAClD,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,gEAAoE;AACpE,sDAAmD;AACnD,gDAAoD;AACpD,gDAAoD;AACpD,wCAA4C;AAC5C,gDAAoD;AACpD,sDAA0D;AAC1D,oDAAyD;AACzD,8CAAkD;AAClD,sDAA0D;AAC1D,wDAA4D;AAC5D,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,4DAAgE;AAChE,kDAAsD;AACtD,oDAAwD;AACxD,0EAA8E;AAEjE,QAAA,SAAS,GAAiB;IACrC,UAAU,EAAE;QACV,MAAM,EAAE,KAAK;QACb,KAAK,EAAE,CAAC,GAAG,EAAE,mBAAmB,EAAE,0BAA0B,CAAC;QAC7D,OAAO,EAAE,uBAAU;KACpB;IACD,GAAG,EAAE;QACH,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,kBAAkB,EAAE,OAAO,EAAE,8BAAiB,EAAE;QACxE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,aAAa,EAAE,OAAO,EAAE,sBAAa,EAAE;QAC/D;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,wBAAc;SACxB;QACD,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,mBAAmB,EAAE,OAAO,EAAE,0BAAe,EAAE;QACvE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,oBAAoB,EAAE,OAAO,EAAE,4BAAgB,EAAE;QACzE;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gBAAU;SACpB;QACD;YACE,MAAM,EAAE,MAAM;YACd,KAAK,EAAE,4BAA4B;YACnC,OAAO,EAAE,sBAAa;SACvB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gCAAkB;SAC5B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,kDAA2B;SACrC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,mCAAmC;YAC1C,OAAO,EAAE,wCAAsB;SAChC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,uCAAuC;YAC9C,OAAO,EAAE,6BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,OAAO;YACf,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,oCAAoB;SAC9B;KACF;CACF,CAAC"}

package.json

 {
   "name": "@bull-board/api",
-  "version": "7.1.5",
+  "version": "7.2.0",
   "description": "A Dashboard server API built on top of bull or bullmq.",
@@ -54,3 +54,3 @@ "keywords": [
   "peerDependencies": {
-    "@bull-board/ui": "7.1.5"
+    "@bull-board/ui": "7.2.0"
   },
@@ -57,0 +57,0 @@ "publishConfig": {

README.md

@@ -9,7 +9,7 @@ # <img alt="@bull-board" src="https://raw.githubusercontent.com/felixmosh/bull-board/master/packages/ui/src/static/images/logo.svg" width="35px" /> @bull-board/api
   </a>
-  <a href="https://www.npmjs.com/package/bull-board">
-    <img alt="npm downloads" src="https://img.shields.io/npm/dw/bull-board">
+  <a href="https://www.npmjs.com/package/@bull-board/api">
+    <img alt="npm downloads" src="https://img.shields.io/npm/dw/@bull-board/api">
   </a>
-  <a href="https://github.com/vcapretz/bull-board/blob/master/LICENSE">
-    <img alt="licence" src="https://img.shields.io/github/license/vcapretz/bull-board">
+  <a href="https://github.com/felixmosh/bull-board/blob/master/LICENSE">
+    <img alt="licence" src="https://img.shields.io/github/license/felixmosh/bull-board">
   </a>
@@ -16,0 +16,0 @@ <p>

typings/app.d.ts

@@ -9,2 +9,14 @@ import type { RedisInfo } from 'redis-info';
 
+export type MetricsType = 'completed' | 'failed';
+
+export interface QueueMetrics {
+  meta: {
+    count: number;
+    prevTS: number;
+    prevCount: number;
+  };
+  data: number[];
+  count: number;
+}
+
 type Library = 'bull' | 'bullmq';
@@ -261,2 +273,3 @@
   hideRedisDetails?: boolean;
+  showMetrics?: boolean;
   environment?: {
@@ -263,0 +276,0 @@ label: string;

typings/responses.d.ts

@@ -1,2 +0,2 @@
-import { AppJob, AppQueue, Status } from './app';
+import { AppJob, AppQueue, QueueMetrics, Status } from './app';
 
@@ -11,1 +11,6 @@ export interface GetQueuesResponse {
 }
+
+export interface GetQueueMetricsResponse {
+  completed: QueueMetrics | null;
+  failed: QueueMetrics | null;
+}

No alert changes

Improved metrics

Total package byte prevSize

110577

2.85%

Number of package files

117

2.63%

Lines of code

1797

2.86%

No dependency changes