INNER CODE UNIT · Go
kubeInformerFactory
inlets/inlets-operator · main.go:115
kubeInformerFactory := kubeinformers.NewSharedInformerFactory(kubeClient, time.Second*30)
tunnelsInformerFactory := informers.NewSharedInformerFactory(operatorClient, time.Second*30)
controller := NewController(kubeClient, operatorClient,
kubeInformerFactory.Apps().V1().Deployments(),
tunnelsInformerFactory.Operator().V1alpha1().Tunnels(),
kubeInformerFactory.Core().V1().Services(),
infra)
// notice that there is no need to run Start methods in a separate goroutine. (i.e. go kubeInformerFactory.Start(stopCh)
// Start method is non-blocking and runs all registered informers in a dedicated goroutine.
kubeInformerFactory.Start(stopCh)
tunnelsInformerFactory.Start(stopCh)
if err = controller.Run(2, stopCh); err != nil {
klog.Fatalf("Error running controller: %s", err.Error())
}
}