@@ -16,7 +16,6 @@ import (
1616
1717 clientset "github.com/openfaas/faas-netes/pkg/client/clientset/versioned"
1818 informers "github.com/openfaas/faas-netes/pkg/client/informers/externalversions"
19- v1 "github.com/openfaas/faas-netes/pkg/client/informers/externalversions/openfaas/v1"
2019 "github.com/openfaas/faas-netes/pkg/config"
2120 "github.com/openfaas/faas-netes/pkg/handlers"
2221 "github.com/openfaas/faas-netes/pkg/k8s"
@@ -147,21 +146,10 @@ Version: %s Commit: %s
147146type customInformers struct {
148147 EndpointsInformer v1core.EndpointsInformer
149148 DeploymentInformer v1apps.DeploymentInformer
150- FunctionsInformer v1.FunctionInformer
151149}
152150
153151func startInformers (setup serverSetup , stopCh <- chan struct {}, operator bool ) customInformers {
154152 kubeInformerFactory := setup .kubeInformerFactory
155- faasInformerFactory := setup .faasInformerFactory
156-
157- var functions v1.FunctionInformer
158- if operator {
159- functions = faasInformerFactory .Openfaas ().V1 ().Functions ()
160- go functions .Informer ().Run (stopCh )
161- if ok := cache .WaitForNamedCacheSync ("faas-netes:functions" , stopCh , functions .Informer ().HasSynced ); ! ok {
162- log .Fatalf ("failed to wait for cache to sync" )
163- }
164- }
165153
166154 deployments := kubeInformerFactory .Apps ().V1 ().Deployments ()
167155 go deployments .Informer ().Run (stopCh )
@@ -178,7 +166,6 @@ func startInformers(setup serverSetup, stopCh <-chan struct{}, operator bool) cu
178166 return customInformers {
179167 EndpointsInformer : endpoints ,
180168 DeploymentInformer : deployments ,
181- FunctionsInformer : functions ,
182169 }
183170}
184171
0 commit comments