Add integration test for ttlcontroller.

This commit is contained in:
Wojciech Tyczynski
2017-02-09 13:52:53 +01:00
parent bc2849b644
commit dcf8a85fdf
4 changed files with 144 additions and 7 deletions

View File

@@ -16,9 +16,9 @@ go_library(
"//pkg/api:go_default_library",
"//pkg/api/v1:go_default_library",
"//pkg/client/clientset_generated/clientset:go_default_library",
"//pkg/client/informers/informers_generated/core/v1:go_default_library",
"//pkg/client/listers/core/v1:go_default_library",
"//pkg/controller:go_default_library",
"//pkg/controller/informers:go_default_library",
"//vendor:github.com/golang/glog",
"//vendor:k8s.io/apimachinery/pkg/api/errors",
"//vendor:k8s.io/apimachinery/pkg/types",

View File

@@ -44,9 +44,9 @@ import (
"k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/client/clientset_generated/clientset"
informers "k8s.io/kubernetes/pkg/client/informers/informers_generated/core/v1"
listers "k8s.io/kubernetes/pkg/client/listers/core/v1"
"k8s.io/kubernetes/pkg/controller"
"k8s.io/kubernetes/pkg/controller/informers"
"github.com/golang/glog"
)
@@ -198,10 +198,6 @@ func (ttlc *TTLController) enqueueNode(node *v1.Node) {
func (ttlc *TTLController) worker() {
for ttlc.processItem() {
if quit := ttlc.processItem(); quit {
glog.Infof("TTL controller worker shutting down")
return
}
}
}