func setupControllers()

in main.go [190:239]
44 lines of code
8 McCabe index (conditional complexity)

func setupControllers(mgr ctrl.Manager, cCache *cache.Cache, queues *queue.Manager, certsReady chan struct{}, cfg *config.Configuration) {
	// The controllers won't work until the webhooks are operating, and the webhook won't work until the
	// certs are all in place.
	setupLog.Info("Waiting for certificate generation to complete")
	<-certsReady
	setupLog.Info("Certs ready")

	if failedCtrl, err := core.SetupControllers(mgr, queues, cCache, cfg); err != nil {
		setupLog.Error(err, "Unable to create controller", "controller", failedCtrl)
		os.Exit(1)
	}
	manageJobsWithoutQueueName := cfg.ManageJobsWithoutQueueName

	if failedWebhook, err := webhooks.Setup(mgr); err != nil {
		setupLog.Error(err, "Unable to create webhook", "webhook", failedWebhook)
		os.Exit(1)
	}

	opts := []jobframework.Option{
		jobframework.WithManageJobsWithoutQueueName(manageJobsWithoutQueueName),
		jobframework.WithWaitForPodsReady(waitForPodsReady(cfg)),
	}
	err := jobframework.ForEachIntegration(func(name string, cb jobframework.IntegrationCallbacks) error {
		log := setupLog.WithValues("jobFrameworkName", name)
		if isFrameworkEnabled(cfg, name) {
			if err := cb.NewReconciler(mgr.GetScheme(),
				mgr.GetClient(),
				mgr.GetEventRecorderFor(fmt.Sprintf("%s-%s-controller", name, constants.KueueName)),
				opts...,
			).SetupWithManager(mgr); err != nil {
				log.Error(err, "unable to create controller")
				return err
			}
			if err := cb.SetupWebhook(mgr, opts...); err != nil {
				log.Error(err, "Unable to create webhook")
				return err
			}
		} else {
			if err := noop.SetupWebhook(mgr, cb.JobType); err != nil {
				log.Error(err, "Unable to create noop webhook")
				return err
			}
		}
		return nil
	})
	if err != nil {
		os.Exit(1)
	}
	// +kubebuilder:scaffold:builder
}