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
}