github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 09:22:44 +00:00
Code Issues Projects Releases Wiki Activity

start informers as a post-start-hook

Browse Source
This commit is contained in:
deads2k 2017-03-15 10:33:39 -04:00
parent 0afdcfcaf6
commit 5b08029e79
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/kube-apiserver/app/server.go
View File

@ -106,8 +106,11 @@ func RunServer(config *master.Config, sharedInformers informers.SharedInformerFa
if err != nil { if err != nil {
return err 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) return m.GenericAPIServer.PrepareRun().Run(stopCh)
} }

2
staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiserver.go
View File

@ -152,7 +152,7 @@ func (c completedConfig) New(stopCh <-chan struct{}) (*APIAggregator, error) {
apiserviceRegistrationController := NewAPIServiceRegistrationController(informerFactory.Apiregistration().InternalVersion().APIServices(), s) 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) informerFactory.Start(stopCh)
kubeInformers.Start(stopCh) kubeInformers.Start(stopCh)
return nil return nil