From 0ab928c9d6ee7ecc8bf53fa6b7c6c92a465fedb9 Mon Sep 17 00:00:00 2001 From: Michael Taufen Date: Mon, 3 Dec 2018 10:15:52 -0800 Subject: [PATCH] export metrics from node lifecycle controller workqueues --- pkg/controller/nodelifecycle/node_lifecycle_controller.go | 2 +- pkg/controller/nodelifecycle/scheduler/taint_manager.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/controller/nodelifecycle/node_lifecycle_controller.go b/pkg/controller/nodelifecycle/node_lifecycle_controller.go index f474b55df9e..fc31c2734ab 100644 --- a/pkg/controller/nodelifecycle/node_lifecycle_controller.go +++ b/pkg/controller/nodelifecycle/node_lifecycle_controller.go @@ -306,7 +306,7 @@ func NewNodeLifecycleController( runTaintManager: runTaintManager, useTaintBasedEvictions: useTaintBasedEvictions && runTaintManager, taintNodeByCondition: taintNodeByCondition, - nodeUpdateQueue: workqueue.New(), + nodeUpdateQueue: workqueue.NewNamed("node_lifecycle_controller"), } if useTaintBasedEvictions { klog.Infof("Controller is using taint based evictions.") diff --git a/pkg/controller/nodelifecycle/scheduler/taint_manager.go b/pkg/controller/nodelifecycle/scheduler/taint_manager.go index fbf683077f1..6d32bedfad8 100644 --- a/pkg/controller/nodelifecycle/scheduler/taint_manager.go +++ b/pkg/controller/nodelifecycle/scheduler/taint_manager.go @@ -185,8 +185,8 @@ func NewNoExecuteTaintManager(c clientset.Interface, getPod GetPodFunc, getNode getNode: getNode, taintedNodes: make(map[string][]v1.Taint), - nodeUpdateQueue: workqueue.New(), - podUpdateQueue: workqueue.New(), + nodeUpdateQueue: workqueue.NewNamed("noexec_taint_node"), + podUpdateQueue: workqueue.NewNamed("noexec_taint_pod"), } tm.taintEvictionQueue = CreateWorkerQueue(deletePodHandler(c, tm.emitPodDeletionEvent))