scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #71668 from mtaufen/node-lifecycle-metrics

Browse Source 
export metrics from node lifecycle controller workqueues
This commit is contained in:
Kubernetes Prow Robot
2019-01-07 20:24:12 -08:00
committed by GitHub
parent 35b17dd6d0 0ab928c9d6
commit c5616157a0
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/controller/nodelifecycle/node_lifecycle_controller.go
View File

@@ -288,7 +288,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.")

4
pkg/controller/nodelifecycle/scheduler/taint_manager.go
View File

@@ -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))