func()

in controllers/flinkcluster/flinkcluster_reconciler.go [62:142]

• 64 lines of code
• 16 McCabe index (conditional complexity)

func (reconciler *ClusterReconciler) reconcile(ctx context.Context) (ctrl.Result, error) {
	var err error
	log := logr.FromContextOrDiscard(ctx)

	// Child resources of the cluster CR will be automatically reclaimed by K8S.
	if reconciler.observed.cluster == nil {
		log.Info("The cluster has been deleted, no action to take")
		return ctrl.Result{}, nil
	}

	if shouldUpdateCluster(&reconciler.observed) {
		log.Info("The cluster update is in progress")
	}

	err = reconciler.reconcileBatchScheduler()
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileConfigMap(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileHAConfigMap(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcilePodDisruptionBudget(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileJobManagerStatefulSet(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileJobManagerService(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileJobManagerIngress(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileTaskManagerStatefulSet(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileTaskManagerDeployment(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileHorizontalPodAutoscaler(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcileTaskManagerService(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	err = reconciler.reconcilePersistentVolumeClaims(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	result, err := reconciler.reconcileJob(ctx)
	if err != nil {
		return ctrl.Result{}, err
	}

	return result, nil
}