INNER CODE UNIT · Go

kubeInformerFactory

senthilrch/kube-fledged · cmd/controller/main.go:77

	kubeInformerFactory := kubeinformers.NewSharedInformerFactory(kubeClient, time.Second*30)
	fledgedInformerFactory := informers.NewSharedInformerFactory(fledgedClient, time.Second*30)

	controller := app.NewController(kubeClient, fledgedClient, fledgedNameSpace,
		kubeInformerFactory.Core().V1().Nodes(),
		fledgedInformerFactory.Kubefledged().V1alpha2().ImageCaches(),
		imageCacheRefreshFrequency, imagePullDeadlineDuration, criClientImage,
		busyboxImage, imagePullPolicy, serviceAccountName, imageDeleteJobHostNetwork,
		jobPriorityClassName, canDeleteJob, criSocketPath, jobsMaxSurge)

	glog.Info("Starting pre-flight checks")
	if err = controller.PreFlightChecks(); err != nil {
		glog.Fatalf("Error running pre-flight checks: %s", err.Error())
	}
	glog.Info("Pre-flight checks completed")

	go kubeInformerFactory.Start(stopCh)
	go fledgedInformerFactory.Start(stopCh)

View source record →