func()

in pkg/datasource/k8s/controllers/hotspotrules_controller.go [53:109]

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

func (r *HotspotRulesReconciler) 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
	}

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

	var hotspotRules []*hotspot.Rule
	if hotspotRulesCR != nil {
		log.Info("Receive datasourcev1.HotspotRules", "rules:", hotspotRulesCR.Spec.Rules)
		hotspotRules = r.assembleHotspotRules(hotspotRulesCR)
	}

	_, err := hotspot.LoadRules(hotspotRules)
	if err != nil {
		log.Error(err, "Fail to Load hotspot.Rules")
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, err
	}

	return ctrl.Result{}, nil
}