Implement evpa-controller

cmd/craned/app/manager.go

@@ -28,6 +28,7 @@ import (
 	"github.com/gocrane/crane/pkg/controller/analytics"
 	"github.com/gocrane/crane/pkg/controller/cnp"
 	"github.com/gocrane/crane/pkg/controller/ehpa"
+	"github.com/gocrane/crane/pkg/controller/evpa"
 	"github.com/gocrane/crane/pkg/controller/noderesource"
 	"github.com/gocrane/crane/pkg/controller/recommendation"
 	"github.com/gocrane/crane/pkg/controller/timeseriesprediction"
@@ -53,7 +54,6 @@ var (
 func init() {
 	utilruntime.Must(clientgoscheme.AddToScheme(scheme))
 	utilruntime.Must(predictionapi.AddToScheme(scheme))
-	utilruntime.Must(analysisapi.AddToScheme(scheme))
 	utilruntime.Must(ensuranceapi.AddToScheme(scheme))
 	//+kubebuilder:scaffold:scheme
 
@@ -116,41 +116,8 @@ func Run(ctx context.Context, opts *options.Options) error {
 		initializationWebhooks(mgr)
 	}
 	initializationControllers(ctx, mgr, opts)
-	klog.Info("Starting crane manager")
-
-	// initialization custom collector metrics
 	initializationMetricCollector(mgr)
-
-	var eg errgroup.Group
-
-	eg.Go(func() error {
-		if err := mgr.Start(ctx); err != nil {
-			klog.Error(err, "problem running crane manager")
-			klog.Exit(err)
-		}
-		return nil
-	})
-
-	eg.Go(func() error {
-		// Start the craned web server
-		serverConfig := serverconfig.NewServerConfig()
-		if err := opts.ApplyTo(serverConfig); err != nil {
-			klog.Exit(err)
-		}
-		// use controller runtime rest config, we can not refer kubeconfig option directly because it is unexported variable in vendor/sigs.k8s.io/controller-runtime/pkg/client/config/config.go
-		serverConfig.KubeRestConfig = mgr.GetConfig()
-		craneServer, err := server.NewServer(serverConfig)
-		if err != nil {
-			klog.Exit(err)
-		}
-		craneServer.Run(ctx)
-		return nil
-	})
-
-	// wait for all components exit
-	if err := eg.Wait(); err != nil {
-		klog.Fatal(err)
-	}
+	runAll(ctx, mgr, opts)
 
 	return nil
 }
@@ -221,6 +188,14 @@ func initializationControllers(ctx context.Context, mgr ctrl.Manager, opts *opti
 		}).SetupWithManager(mgr); err != nil {
 			klog.Exit(err, "unable to create controller", "controller", "HPAReplicasController")
 		}
+
+		if err := (&evpa.EffectiveVPAController{
+			Client:     mgr.GetClient(),
+			Scheme:     mgr.GetScheme(),
+			Recorder:   mgr.GetEventRecorderFor("effective-vpa-controller"),
+		}).SetupWithManager(mgr); err != nil {
+			klog.Exit(err, "unable to create controller", "controller", "EffectiveVPAController")
+		}
 	}
 
 	var dataSource providers.Interface
@@ -271,10 +246,11 @@ func initializationControllers(ctx context.Context, mgr ctrl.Manager, opts *opti
 		if err := tspController.SetupWithManager(mgr); err != nil {
 			klog.Exit(err, "unable to create controller", "controller", "TspController")
 		}
-
 	}
 
 	if analysis {
+		utilruntime.Must(analysisapi.AddToScheme(scheme))
+
 		if err := (&analytics.Controller{
 			Client:     mgr.GetClient(),
 			Scheme:     mgr.GetScheme(),
@@ -325,3 +301,36 @@ func initializationControllers(ctx context.Context, mgr ctrl.Manager, opts *opti
 		}
 	}
 }
+
+func runAll(ctx context.Context, mgr ctrl.Manager, opts *options.Options) {
+	var eg errgroup.Group
+
+	eg.Go(func() error {
+		if err := mgr.Start(ctx); err != nil {
+			klog.Error(err, "problem running crane manager")
+			klog.Exit(err)
+		}
+		return nil
+	})
+
+	eg.Go(func() error {
+		// Start the craned web server
+		serverConfig := serverconfig.NewServerConfig()
+		if err := opts.ApplyTo(serverConfig); err != nil {
+			klog.Exit(err)
+		}
+		// use controller runtime rest config, we can not refer kubeconfig option directly because it is unexported variable in vendor/sigs.k8s.io/controller-runtime/pkg/client/config/config.go
+		serverConfig.KubeRestConfig = mgr.GetConfig()
+		craneServer, err := server.NewServer(serverConfig)
+		if err != nil {
+			klog.Exit(err)
+		}
+		craneServer.Run(ctx)
+		return nil
+	})
+
+	// wait for all components exit
+	if err := eg.Wait(); err != nil {
+		klog.Fatal(err)
+	}
+}