1 import { Counter, Meter } from '@opentelemetry/api-metrics'
2 import { MVideoImmutable } from '@server/types/models'
3 import { PlaybackMetricCreate } from '@shared/models'
5 export class PlaybackMetrics {
6 private errorsCounter: Counter
7 private resolutionChangesCounter: Counter
9 private downloadedBytesP2PCounter: Counter
10 private uploadedBytesP2PCounter: Counter
12 private downloadedBytesHTTPCounter: Counter
14 constructor (private readonly meter: Meter) {
19 this.errorsCounter = this.meter.createCounter('peertube_playback_errors_count', {
20 description: 'Errors collected from PeerTube player.'
23 this.resolutionChangesCounter = this.meter.createCounter('peertube_playback_resolution_changes_count', {
24 description: 'Resolution changes collected from PeerTube player.'
27 this.downloadedBytesHTTPCounter = this.meter.createCounter('peertube_playback_http_downloaded_bytes', {
28 description: 'Downloaded bytes with HTTP by PeerTube player.'
30 this.downloadedBytesP2PCounter = this.meter.createCounter('peertube_playback_p2p_downloaded_bytes', {
31 description: 'Downloaded bytes with P2P by PeerTube player.'
34 this.uploadedBytesP2PCounter = this.meter.createCounter('peertube_playback_p2p_uploaded_bytes', {
35 description: 'Uploaded bytes with P2P by PeerTube player.'
39 observe (video: MVideoImmutable, metrics: PlaybackMetricCreate) {
41 videoOrigin: video.remote
45 playerMode: metrics.playerMode,
47 resolution: metrics.resolution + '',
48 fps: metrics.fps + '',
53 this.errorsCounter.add(metrics.errors, attributes)
54 this.resolutionChangesCounter.add(metrics.resolutionChanges, attributes)
56 this.downloadedBytesHTTPCounter.add(metrics.downloadedBytesHTTP, attributes)
57 this.downloadedBytesP2PCounter.add(metrics.downloadedBytesP2P, attributes)
59 this.uploadedBytesP2PCounter.add(metrics.uploadedBytesP2P, attributes)