1 import { Meter } from '@opentelemetry/api'
2 import { VideoScope, ViewerScope } from '@server/lib/views/shared'
3 import { VideoViewsManager } from '@server/lib/views/video-views-manager'
5 export class ViewersObserversBuilder {
7 constructor (private readonly meter: Meter) {
12 this.meter.createObservableGauge('peertube_viewers_total', {
13 description: 'Total viewers on the instance'
14 }).addCallback(observableResult => {
15 for (const viewerScope of [ 'local', 'remote' ] as ViewerScope[]) {
16 for (const videoScope of [ 'local', 'remote' ] as VideoScope[]) {
17 const result = VideoViewsManager.Instance.getTotalViewers({ viewerScope, videoScope })
19 observableResult.observe(result, { viewerOrigin: viewerScope, videoOrigin: videoScope })