dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-25 01:35:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

move NewStatsInterceptorFactory

Browse Source
This commit is contained in:
David Colburn
2021-11-12 20:21:54 -08:00
parent 92838d75a8
commit 4e16e4275c
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/telemetry/interceptor.go
+8
View File
@@ -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
pkg/telemetry/service.go
-8
View File
@@ -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]