func()

in pkg/controllers/egressrules_controller.go [59:72]


func (r *AzureFirewallRulesReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
	_ = log.FromContext(ctx)

	node := &corev1.Node{}
	err := r.Get(ctx, req.NamespacedName, node)

	if (err != nil && req.NamespacedName.Namespace != "kube-system") || (err == nil && !a.CheckIfNodeNotReady(node)) {
		go r.AzClient.UpdateFirewallPolicy(ctx, req)
	} else if a.CheckIfNodeNotReady(node) {
		go r.AzClient.AddTaints(ctx, req)
	}

	return ctrl.Result{}, nil
}