INNER CODE UNIT · Go

setupControllers

OT-CONTAINER-KIT/redis-operator · internal/cmd/manager/cmd.go:239

func setupControllers(mgr ctrl.Manager, k8sClient kubernetes.Interface, maxConcurrentReconciles int) error {
	// Get max concurrent reconciles from environment
	maxConcurrentReconciles = envs.GetMaxConcurrentReconciles(maxConcurrentReconciles)

	healer := redis.NewHealer(k8sClient)

	if err := (&rediscontroller.Reconciler{
		Client:      mgr.GetClient(),
		K8sClient:   k8sClient,
		StatefulSet: k8sutils.NewStatefulSetService(k8sClient),
	}).SetupWithManager(mgr, controller.Options{MaxConcurrentReconciles: maxConcurrentReconciles}); err != nil {
		setupLog.Error(err, "unable to create controller", "controller", "Redis")
		return err
	}
	if err := (&redisclustercontroller.Reconciler{
		Client:      mgr.GetClient(),
		K8sClient:   k8sClient,
		Healer:      healer,

View source record →