Skip to content

Commit

Permalink
Enable prometheus provider for workqueue metrics
Browse files Browse the repository at this point in the history
  • Loading branch information
cartermckinnon committed Dec 1, 2023
1 parent ca6c03d commit 31343a1
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions pkg/controllers/tagging/tagging_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,14 @@ import (
opt "k8s.io/cloud-provider-aws/pkg/controllers/options"
awsv1 "k8s.io/cloud-provider-aws/pkg/providers/v1"
nodehelpers "k8s.io/cloud-provider/node/helpers"
_ "k8s.io/component-base/metrics/prometheus/workqueue" // enable prometheus provider for workqueue metrics
"k8s.io/klog/v2"
)

func init() {
registerMetrics()
}

// workItem contains the node and an action for that node
type workItem struct {
node *v1.Node
Expand Down Expand Up @@ -126,14 +131,13 @@ func NewTaggingController(
rateLimitEnabled = false
}

registerMetrics()
tc := &Controller{
nodeInformer: nodeInformer,
kubeClient: kubeClient,
cloud: awsCloud,
tags: tags,
resources: resources,
workqueue: workqueue.NewNamedRateLimitingQueue(rateLimiter, "Tagging"),
workqueue: workqueue.NewNamedRateLimitingQueue(rateLimiter, TaggingControllerClientName),
nodesSynced: nodeInformer.Informer().HasSynced,
nodeMonitorPeriod: nodeMonitorPeriod,
rateLimitEnabled: rateLimitEnabled,
Expand Down

0 comments on commit 31343a1

Please sign in to comment.