func()

in pkg/datasource/k8s/controllers/circuitbreakerrules_controller.go [53:107]

• 51 lines of code
• 8 McCabe index (conditional complexity)

func (r *CircuitBreakerRulesReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
	ctx := context.Background()
	log := r.Logger.WithValues("expectedNamespace", r.Namespace, "expectedCrName", r.ExpectedCrName, "req", req.String())

	if req.Namespace != r.Namespace {
		log.V(int(logging.DebugLevel)).Info("ignore unmatched namespace")
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, nil
	}

	if req.Name != r.ExpectedCrName {
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, nil
	}

	cbRulesCR := &datasourcev1.CircuitBreakerRules{}
	if err := r.Get(ctx, req.NamespacedName, cbRulesCR); err != nil {
		k8sApiErr, ok := err.(*k8sApiError.StatusError)
		if !ok {
			log.Error(err, "Fail to get datasourcev1.CircuitBreakerRules.")
			return ctrl.Result{
				Requeue:      false,
				RequeueAfter: 0,
			}, nil
		}
		if k8sApiErr.Status().Code != http.StatusNotFound {
			log.Error(err, "Fail to get datasourcev1.CircuitBreakerRules.")
			return ctrl.Result{
				Requeue:      false,
				RequeueAfter: 0,
			}, nil
		}
		log.Info("datasourcev1.CircuitBreakerRules had been deleted.")
		cbRulesCR = nil
	}

	var cbRules []*circuitbreaker.Rule
	if cbRulesCR != nil {
		log.Info("Get datasourcev1.CircuitBreakerRules", "rules:", cbRulesCR.Spec.Rules)
		cbRules = r.assembleCircuitBreakerRules(cbRulesCR)
	}
	_, err := circuitbreaker.LoadRules(cbRules)
	if err != nil {
		log.Error(err, "Fail to Load circuitbreaker.Rules")
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, err
	}
	return ctrl.Result{}, nil
}