INNER CODE UNIT · Go

kruisegameInformerFactory

openkruise/kruise-game · main.go:280

	kruisegameInformerFactory := kruisegamevisions.NewSharedInformerFactory(kruisegameclientset.NewForConfigOrDie(restConfig), 30*time.Second)
	metricsController, err := metrics.NewController(kruisegameInformerFactory)
	if err != nil {
		setupLog.Error(err, "unable to create metrics controller")
		os.Exit(1)
	}
	kruisegameInformerFactory.Start(signal.Done())
	go func() {
		if runErr := metricsController.Run(signal); runErr != nil {
			setupLog.Error(runErr, "unable to setup metrics controller")
			os.Exit(1)
		}
	}()

	externalScaler := externalscaler.NewExternalScaler(mgr.GetClient())
	go func() {
		grpcServer := grpc.NewServer()
		lis, err := net.Listen("tcp", scaleServerAddr)

View source record →