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 1741df4
Showing 1 changed file with 10 additions and 0 deletions.
10 changes: 10 additions & 0 deletions pkg/metrics/workqueue.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,10 +95,20 @@ func init() {
Registry.MustRegister(unfinished)
Registry.MustRegister(longestRunningProcessor)
Registry.MustRegister(retries)
}

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

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

type workqueueMetricsProvider struct{}

func (workqueueMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
Expand Down

0 comments on commit 1741df4

Please sign in to comment.