@bull-monitor/fastify
Fastify adapter for bull-monitor
Usage
npm i @bull-monitor/fastify
import Fastify from 'fastify';
import { BullMonitorFastify } from '@bull-monitor/fastify';
import { BullAdapter } from '@bull-monitor/root/dist/bull-adapter';
import Queue from 'bull';
(async () => {
const app = Fastify();
const monitor = new BullMonitorFastify({
queues: [
new BullAdapter(new Queue('1', 'REDIS_URI')),
new BullAdapter(new Queue('2', 'REDIS_URI'), { readonly: true }),
],
gqlIntrospection: true,
baseUrl: '/my/url',
metrics: {
collectInterval: { hours: 1 },
maxMetrics: 100,
blacklist: ['1'],
},
});
await monitor.init({ app });
await app.register(monitor.plugin);
await app.listen(3000);
monitor.setQueues([new BullAdapter(new Queue('3', 'REDIS_URI'))]);
})();