func()

in pkg/datasource/k8s/controllers/flowrules_controller.go [58:114]

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

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

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

	var flowRules []*flow.Rule
	if flowRulesCR != nil {
		log.Info("Receive datasourcev1.FlowRules", "rules:", flowRulesCR.Spec.Rules)
		flowRules = r.assembleFlowRules(flowRulesCR)
	}
	_, err := flow.LoadRules(flowRules)
	if err != nil {
		log.Error(err, "Fail to Load flow.Rules")
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, nil
	}
	return ctrl.Result{}, nil
}