diff --git a/test/e2e/daemon_restart.go b/test/e2e/daemon_restart.go index 47a9a65dee8..498f74929a8 100644 --- a/test/e2e/daemon_restart.go +++ b/test/e2e/daemon_restart.go @@ -24,7 +24,7 @@ import ( "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/client/cache" client "k8s.io/kubernetes/pkg/client/unversioned" - controllerFramework "k8s.io/kubernetes/pkg/controller/framework" + controllerframework "k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/fields" "k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/master/ports" @@ -191,7 +191,7 @@ var _ = Describe("DaemonRestart", func() { existingPods := cache.NewStore(cache.MetaNamespaceKeyFunc) var ns string var config RCConfig - var controller *controllerFramework.Controller + var controller *controllerframework.Controller var newPods cache.Store var stopCh chan struct{} var tracker *podTracker @@ -219,7 +219,7 @@ var _ = Describe("DaemonRestart", func() { stopCh = make(chan struct{}) tracker = newPodTracker() - newPods, controller = controllerFramework.NewInformer( + newPods, controller = controllerframework.NewInformer( &cache.ListWatch{ ListFunc: func() (runtime.Object, error) { return framework.Client.Pods(ns).List(labelSelector, fields.Everything()) @@ -230,7 +230,7 @@ var _ = Describe("DaemonRestart", func() { }, &api.Pod{}, 0, - controllerFramework.ResourceEventHandlerFuncs{ + controllerframework.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { tracker.remember(obj.(*api.Pod), ADD) }, diff --git a/test/e2e/density.go b/test/e2e/density.go index 9f8e0266c1e..16d2831b9f6 100644 --- a/test/e2e/density.go +++ b/test/e2e/density.go @@ -29,7 +29,7 @@ import ( "k8s.io/kubernetes/pkg/api/unversioned" "k8s.io/kubernetes/pkg/client/cache" client "k8s.io/kubernetes/pkg/client/unversioned" - controllerFramework "k8s.io/kubernetes/pkg/controller/framework" + controllerframework "k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/fields" "k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/runtime" @@ -197,7 +197,7 @@ var _ = Describe("Density", func() { // Create a listener for events. events := make([](*api.Event), 0) - _, controller := controllerFramework.NewInformer( + _, controller := controllerframework.NewInformer( &cache.ListWatch{ ListFunc: func() (runtime.Object, error) { return c.Events(ns).List(labels.Everything(), fields.Everything()) @@ -208,7 +208,7 @@ var _ = Describe("Density", func() { }, &api.Event{}, 0, - controllerFramework.ResourceEventHandlerFuncs{ + controllerframework.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { events = append(events, obj.(*api.Event)) }, @@ -280,7 +280,7 @@ var _ = Describe("Density", func() { } additionalPodsPrefix = "density-latency-pod-" + string(util.NewUUID()) - _, controller := controllerFramework.NewInformer( + _, controller := controllerframework.NewInformer( &cache.ListWatch{ ListFunc: func() (runtime.Object, error) { return c.Pods(ns).List(labels.SelectorFromSet(labels.Set{"name": additionalPodsPrefix}), fields.Everything()) @@ -291,7 +291,7 @@ var _ = Describe("Density", func() { }, &api.Pod{}, 0, - controllerFramework.ResourceEventHandlerFuncs{ + controllerframework.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { p, ok := obj.(*api.Pod) Expect(ok).To(Equal(true))