1 import { Meter } from '@opentelemetry/api'
2 import { JobQueue } from '@server/lib/job-queue'
4 export class JobQueueObserversBuilder {
6 constructor (private readonly meter: Meter) {
11 this.meter.createObservableGauge('peertube_job_queue_total', {
12 description: 'Total jobs in the PeerTube job queue'
13 }).addCallback(async observableResult => {
14 const stats = await JobQueue.Instance.getStats()
16 for (const { jobType, counts } of stats) {
17 for (const state of Object.keys(counts)) {
18 observableResult.observe(counts[state], { jobType, state })