From 431069af95da2e7e274e13b134f39b3c9ea2123c Mon Sep 17 00:00:00 2001 From: David Zhao Date: Tue, 19 Apr 2022 22:22:58 -0700 Subject: [PATCH] Rename StatsUpdateFrequency -> StatsUpdateInterval --- pkg/config/config.go | 2 +- pkg/telemetry/prometheus/node.go | 2 +- pkg/telemetry/telemetryservice.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/config/config.go b/pkg/config/config.go index 023ae9f54..857eae4c4 100644 --- a/pkg/config/config.go +++ b/pkg/config/config.go @@ -23,7 +23,7 @@ const ( CongestionControlProbeModePadding CongestionControlProbeMode = "padding" CongestionControlProbeModeMedia CongestionControlProbeMode = "media" - StatsUpdateFrequency = time.Second * 10 + StatsUpdateInterval = time.Second * 10 ) type Config struct { diff --git a/pkg/telemetry/prometheus/node.go b/pkg/telemetry/prometheus/node.go index d3516ad7f..d9e84c8df 100644 --- a/pkg/telemetry/prometheus/node.go +++ b/pkg/telemetry/prometheus/node.go @@ -69,7 +69,7 @@ func GetUpdatedNodeStats(prev *livekit.NodeStats, prevAverage *livekit.NodeStats updatedAt := time.Now().Unix() elapsed := updatedAt - prevAverage.UpdatedAt // include sufficient buffer to be sure a stats update had taken place - computeAverage := elapsed > int64(config.StatsUpdateFrequency.Seconds()+2) + computeAverage := elapsed > int64(config.StatsUpdateInterval.Seconds()+2) if bytesInNow != prevAverage.BytesIn || bytesOutNow != prevAverage.BytesOut || packetsInNow != prevAverage.PacketsIn || diff --git a/pkg/telemetry/telemetryservice.go b/pkg/telemetry/telemetryservice.go index 403f5ddbc..436867295 100644 --- a/pkg/telemetry/telemetryservice.go +++ b/pkg/telemetry/telemetryservice.go @@ -56,7 +56,7 @@ func NewTelemetryService(notifier webhook.Notifier, analytics AnalyticsService) } func (t *telemetryService) run() { - ticker := time.NewTicker(config.StatsUpdateFrequency) + ticker := time.NewTicker(config.StatsUpdateInterval) defer ticker.Stop() for { <-ticker.C