Commit 0ab928c9 authored by Michael Taufen's avatar Michael Taufen

export metrics from node lifecycle controller workqueues

parent dc9261bc
...@@ -306,7 +306,7 @@ func NewNodeLifecycleController( ...@@ -306,7 +306,7 @@ func NewNodeLifecycleController(
runTaintManager: runTaintManager, runTaintManager: runTaintManager,
useTaintBasedEvictions: useTaintBasedEvictions && runTaintManager, useTaintBasedEvictions: useTaintBasedEvictions && runTaintManager,
taintNodeByCondition: taintNodeByCondition, taintNodeByCondition: taintNodeByCondition,
nodeUpdateQueue: workqueue.New(), nodeUpdateQueue: workqueue.NewNamed("node_lifecycle_controller"),
} }
if useTaintBasedEvictions { if useTaintBasedEvictions {
klog.Infof("Controller is using taint based evictions.") klog.Infof("Controller is using taint based evictions.")
......
...@@ -185,8 +185,8 @@ func NewNoExecuteTaintManager(c clientset.Interface, getPod GetPodFunc, getNode ...@@ -185,8 +185,8 @@ func NewNoExecuteTaintManager(c clientset.Interface, getPod GetPodFunc, getNode
getNode: getNode, getNode: getNode,
taintedNodes: make(map[string][]v1.Taint), taintedNodes: make(map[string][]v1.Taint),
nodeUpdateQueue: workqueue.New(), nodeUpdateQueue: workqueue.NewNamed("noexec_taint_node"),
podUpdateQueue: workqueue.New(), podUpdateQueue: workqueue.NewNamed("noexec_taint_pod"),
} }
tm.taintEvictionQueue = CreateWorkerQueue(deletePodHandler(c, tm.emitPodDeletionEvent)) tm.taintEvictionQueue = CreateWorkerQueue(deletePodHandler(c, tm.emitPodDeletionEvent))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment