feat(controller): Add retry on conflict wrapper around update and cre…

…ate ops

Signed-off-by: Michael Riesberg-Timmer <MichaelRT@pallid.dev>

controller.go

@@ -13,6 +13,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/intstr"
 	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/util/retry"
 )
 
 const (
@@ -222,7 +223,10 @@ func (n *PDBController) reconcilePDBs(ctx context.Context, desiredPDBs, managedP
 			managedPDB.Labels = desiredPDB.Labels
 			managedPDB.Spec = desiredPDB.Spec
 
-			_, err := n.PolicyV1().PodDisruptionBudgets(managedPDB.Namespace).Update(ctx, &managedPDB, metav1.UpdateOptions{})
+			err := retry.RetryOnConflict(retry.DefaultRetry, func() error {
+				_, err := n.PolicyV1().PodDisruptionBudgets(managedPDB.Namespace).Update(ctx, &managedPDB, metav1.UpdateOptions{})
+				return err
+			})
 			if err != nil {
 				log.Errorf("Failed to update PDB: %v", err)
 				continue
@@ -239,7 +243,10 @@ func (n *PDBController) reconcilePDBs(ctx context.Context, desiredPDBs, managedP
 
 	for key, desiredPDB := range desiredPDBs {
 		if _, ok := managedPDBs[key]; !ok {
-			_, err := n.PolicyV1().PodDisruptionBudgets(desiredPDB.Namespace).Create(ctx, &desiredPDB, metav1.CreateOptions{})
+			err := retry.RetryOnConflict(retry.DefaultRetry, func() error {
+				_, err := n.PolicyV1().PodDisruptionBudgets(desiredPDB.Namespace).Create(ctx, &desiredPDB, metav1.CreateOptions{})
+				return err
+			})
 			if err != nil {
 				log.Errorf("Failed to create PDB: %v", err)
 				continue