diff --git a/ttl/metrics/metrics.go b/ttl/metrics/metrics.go index 3389cf16f5d7f..6223b6219793e 100644 --- a/ttl/metrics/metrics.go +++ b/ttl/metrics/metrics.go @@ -73,6 +73,9 @@ func InitMetricsVars() { ScanningTaskCnt = metrics.TTLTaskStatus.With(prometheus.Labels{metrics.LblType: "scanning"}) DeletingTaskCnt = metrics.TTLTaskStatus.With(prometheus.Labels{metrics.LblType: "deleting"}) + + scanWorkerPhases = initWorkerPhases("scan_worker") + deleteWorkerPhases = initWorkerPhases("delete_worker") } func initWorkerPhases(workerType string) map[string]prometheus.Counter { @@ -89,8 +92,8 @@ func initWorkerPhases(workerType string) map[string]prometheus.Counter { } } -var scanWorkerPhases = initWorkerPhases("scan_worker") -var deleteWorkerPhases = initWorkerPhases("delete_worker") +var scanWorkerPhases map[string]prometheus.Counter +var deleteWorkerPhases map[string]prometheus.Counter // PhaseTracer is used to tracer the phases duration type PhaseTracer struct {