Function main

cyclops-ctrl/cmd/main/main.go:50–169

()

}

func main() {
	var metricsAddr string
	var enableLeaderElection bool
	var probeAddr string
	flag.StringVar(&metricsAddr, "metrics-bind-address", ":8081", "The address the metric endpoint binds to.")
	flag.StringVar(&probeAddr, "health-probe-bind-address", ":8082", "The address the probe endpoint binds to.")
	flag.BoolVar(&enableLeaderElection, "leader-elect", false,
		"Enable leader election for controller manager. "+
			"Enabling this will ensure there is only one active controller manager.")
	opts := zap.Options{
		Development: true,
	}
	opts.BindFlags(flag.CommandLine)
	flag.Parse()

	ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))

	setupLog.Info("starting handler")

	telemetryClient, _ := telemetry.NewClient(
		getEnvBool("DISABLE_TELEMETRY"),
		os.Getenv("CYCLOPS_VERSION"),
		os.Getenv("INSTALL_MANAGER"),
		setupLog,
	)
	telemetryClient.InstanceStart()

	watchNamespace := getWatchNamespace()
	helmWatchNamespace := getHelmWatchNamespace()
	moduleTargetNamespace := getModuleTargetNamespace()

	k8sClient, err := k8sclient.New(
		watchNamespace,
		helmWatchNamespace,
		moduleTargetNamespace,
		zap.New(zap.UseFlagOptions(&opts)),
	)
	if err != nil {
		fmt.Println("error bootstrapping Kubernetes client", err)
		panic(err)
	}

	credsResolver := auth.NewTemplatesResolver(k8sClient)

	templatesRepo := template.NewRepo(
		credsResolver,
		cache.NewInMemoryTemplatesCache(),
	)

	monitor, err := prometheus.NewMonitor(setupLog)
	if err != nil {
		setupLog.Error(err, "failed to set up prom monitor")
	}

	renderer := render.NewRenderer(k8sClient)

	prometheus.StartCacheMetricsUpdater(&monitor, templatesRepo.ReturnCache(), 10*time.Second, setupLog)