Skip to content

Commit

Permalink
Remove global metrics registration in init, add registration func
Browse files Browse the repository at this point in the history
Signed-off-by: austin ce <austin.cawley@gmail.com>
  • Loading branch information
austince committed Mar 14, 2023
1 parent 97acd64 commit ca0bf05
Showing 1 changed file with 11 additions and 1 deletion.
12 changes: 11 additions & 1 deletion pkg/metrics/workqueue.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,8 +95,18 @@ func init() {
Registry.MustRegister(unfinished)
Registry.MustRegister(longestRunningProcessor)
Registry.MustRegister(retries)
}

// SetDefaultGlobalWorkqueueMetricsProvider registers the GlobalWorkqueueMetricsProvider
// as the global workqueue.MetricsProvider.
func SetDefaultGlobalWorkqueueMetricsProvider() {
workqueue.SetProvider(GlobalWorkqueueMetricsProvider())
}

workqueue.SetProvider(workqueueMetricsProvider{})
// GlobalWorkqueueMetricsProvider constructs a workqueue.MetricsProvider
// that registers metrics in the global Registry.
func GlobalWorkqueueMetricsProvider() workqueue.MetricsProvider {
return workqueueMetricsProvider{}
}

type workqueueMetricsProvider struct{}
Expand Down

0 comments on commit ca0bf05

Please sign in to comment.