New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Bug 1825324: Use named queues for all controllers #95
Bug 1825324: Use named queues for all controllers #95
Conversation
adambkaplan
commented
Apr 24, 2020
- Add named queues for all ocm controllers
- This exposes the workqueue_* metrics to kube-state-metrics
* Add named queues for all ocm controllers * This exposes the workqueue_* metrics to kube-state-metrics
@adambkaplan: This pull request references Bugzilla bug 1825324, which is valid. The bug has been moved to the POST state. The bug has been updated to refer to the pull request using the external bug tracker. 3 validation(s) were run on this bug
In response to this:
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/hold cancel
Adding relevant team leads as an FYI - after this PR lands all controllers in OCM will have work queue metrics in Prometheus 😄
fyi @openshift/openshift-team-monitoring
@@ -39,7 +39,7 @@ func NewDeployerController( | |||
rn: kubeClientset.CoreV1(), | |||
pn: kubeClientset.CoreV1(), | |||
|
|||
queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()), | |||
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "deployer"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/cc @tnozicka
@@ -41,7 +41,7 @@ func NewDeploymentConfigController( | |||
appsClient: appsClientset.AppsV1(), | |||
kubeClient: kubeClientset.CoreV1(), | |||
|
|||
queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()), | |||
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "deploymentconfig"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/cc @tnozicka
@@ -41,7 +41,7 @@ type SignatureImportController struct { | |||
|
|||
func NewSignatureImportController(ctx context.Context, imageClient imagev1client.Interface, imageInformer imagev1informer.ImageInformer, resyncInterval, fetchTimeout time.Duration, limit int) *SignatureImportController { | |||
controller := &SignatureImportController{ | |||
queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()), | |||
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "image-signature-import"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/cc @dmage
@@ -38,7 +38,7 @@ func NewProjectFinalizerController(namespaces corev1informers.NamespaceInformer, | |||
c := &ProjectFinalizerController{ | |||
client: client, | |||
cacheSynced: namespaces.Informer().HasSynced, | |||
queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()), | |||
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "project-finalizer"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/cc @deads2k
@@ -88,7 +88,7 @@ func NewIngressIPController(services cache.SharedIndexInformer, kc kclientset.In | |||
|
|||
ic := &IngressIPController{ | |||
client: kc.CoreV1(), | |||
queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()), | |||
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "ingressip"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/cc @ironcladlou
@@ -88,7 +88,7 @@ func NewUnidlingController(scaleNS scale.ScalesGetter, mapper meta.RESTMapper, e | |||
scaleNamespacer: scaleNS, | |||
mapper: mapper, | |||
endpointsNamespacer: endptsNS, | |||
queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()), | |||
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "unidling"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/cc @deads2k
lgtm (just a clarification of wording though, "kube-state-metrics" is an external component, that converts kube API objects into Prometheus style metrics, it doesn't do anything within core components) |
@openshift/openshift-team-developer-experience this has thumbs up from the monitoring team - ptal. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/lgtm
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: adambkaplan, ricardomaraschini The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
@adambkaplan: All pull requests linked via external trackers have merged: openshift/openshift-controller-manager#95. Bugzilla bug 1825324 has been moved to the MODIFIED state. In response to this:
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. |
/cherry-pick release-4.4 |
@adambkaplan: new pull request created: #104 In response to this:
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. |
Move component to an appropriate upgrade order (generic)