From 4e16e4275c139041cb67c83a01e1dcd314e0c037 Mon Sep 17 00:00:00 2001 From: David Colburn Date: Fri, 12 Nov 2021 20:21:54 -0800 Subject: [PATCH] move NewStatsInterceptorFactory --- pkg/telemetry/interceptor.go | 8 ++++++++ pkg/telemetry/service.go | 8 -------- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/pkg/telemetry/interceptor.go b/pkg/telemetry/interceptor.go index 5dbbff31c..08fba08f8 100644 --- a/pkg/telemetry/interceptor.go +++ b/pkg/telemetry/interceptor.go @@ -6,6 +6,14 @@ import ( "github.com/pion/rtcp" ) +func (t *TelemetryService) NewStatsInterceptorFactory(participantID, identity string) *StatsInterceptorFactory { + return &StatsInterceptorFactory{ + t: t, + participantID: participantID, + identity: identity, + } +} + type StatsInterceptorFactory struct { t *TelemetryService participantID string diff --git a/pkg/telemetry/service.go b/pkg/telemetry/service.go index b68ac10e6..118736c41 100644 --- a/pkg/telemetry/service.go +++ b/pkg/telemetry/service.go @@ -39,14 +39,6 @@ func NewTelemetryService(notifier webhook.Notifier) *TelemetryService { } } -func (t *TelemetryService) NewStatsInterceptorFactory(participantID, identity string) *StatsInterceptorFactory { - return &StatsInterceptorFactory{ - t: t, - participantID: participantID, - identity: identity, - } -} - func (t *TelemetryService) OnDownstreamPacket(participantID string, bytes int) { t.RLock() w := t.workers[participantID]