From 5b08029e79078544f2698f14eb97334f469d7030 Mon Sep 17 00:00:00 2001 From: deads2k Date: Wed, 15 Mar 2017 10:33:39 -0400 Subject: [PATCH] start informers as a post-start-hook --- cmd/kube-apiserver/app/server.go | 5 ++++- .../src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/cmd/kube-apiserver/app/server.go b/cmd/kube-apiserver/app/server.go index 15926581840..e2668864cf3 100644 --- a/cmd/kube-apiserver/app/server.go +++ b/cmd/kube-apiserver/app/server.go @@ -106,8 +106,11 @@ func RunServer(config *master.Config, sharedInformers informers.SharedInformerFa if err != nil { return err } + m.GenericAPIServer.AddPostStartHook("start-kube-apiserver-informers", func(context genericapiserver.PostStartHookContext) error { + sharedInformers.Start(stopCh) + return nil + }) - sharedInformers.Start(stopCh) return m.GenericAPIServer.PrepareRun().Run(stopCh) } diff --git a/staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go b/staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go index 142882a89e8..fe68073cb78 100644 --- a/staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go +++ b/staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go @@ -152,7 +152,7 @@ func (c completedConfig) New(stopCh <-chan struct{}) (*APIAggregator, error) { apiserviceRegistrationController := NewAPIServiceRegistrationController(informerFactory.Apiregistration().InternalVersion().APIServices(), s) - s.GenericAPIServer.AddPostStartHook("start-informers", func(context genericapiserver.PostStartHookContext) error { + s.GenericAPIServer.AddPostStartHook("start-kube-aggregator-informers", func(context genericapiserver.PostStartHookContext) error { informerFactory.Start(stopCh) kubeInformers.Start(stopCh) return nil