fix: replace update with patch calls

Signed-off-by: Chris Laprun <[email protected]>
quarkiverse · Apr 25, 2024 · 2548b92 · 2548b92
1 parent 06d8f09
commit 2548b92
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 7 deletions.
diff --git a/integration-tests/src/main/java/io/quarkiverse/operatorsdk/it/SecretReconciler.java b/integration-tests/src/main/java/io/quarkiverse/operatorsdk/it/SecretReconciler.java
@@ -27,7 +27,7 @@ public UpdateControl<Secret> reconcile(Secret secret, Context context) {
                 final String foo = data.putIfAbsent("quarkus-operator-sdk.added-value",
                         Base64.getEncoder().encodeToString("quarkus-operator-sdk rocks!".getBytes()));
                 if (foo == null) {
-                    return UpdateControl.updateResource(secret);
+                    return UpdateControl.patchResource(secret);
                 }
             }
         }

diff --git a/samples/exposedapp/src/main/java/io/halkyon/ExposedAppReconciler.java b/samples/exposedapp/src/main/java/io/halkyon/ExposedAppReconciler.java
@@ -49,7 +49,7 @@ public UpdateControl<ExposedApp> reconcile(ExposedApp exposedApp, Context<Expose
                     context.getSecondaryResource(Ingress.class).orElseThrow());
             exposedApp.setStatus(new ExposedAppStatus(url, exposedApp.getSpec().getEndpoint()));
             log.info("App {} is exposed and ready to be used at {}", name, exposedApp.getStatus().getHost());
-            return UpdateControl.updateStatus(exposedApp);
+            return UpdateControl.patchStatus(exposedApp);
         } else {
             final var duration = Duration.ofSeconds(1);
             log.info("App {} is not ready yet, rescheduling reconciliation after {}s", name, duration.toSeconds());

diff --git a/...les/joke/src/main/java/io/quarkiverse/operatorsdk/samples/joke/JokeRequestReconciler.java b/...les/joke/src/main/java/io/quarkiverse/operatorsdk/samples/joke/JokeRequestReconciler.java
@@ -92,6 +92,6 @@ public UpdateControl<JokeRequest> reconcile(JokeRequest jr, Context<JokeRequest>
         }
 
         jr.setStatus(status);
-        return UpdateControl.updateStatus(jr);
+        return UpdateControl.patchStatus(jr);
     }
 }
diff --git a/...a/src/main/java/io/quarkiverse/operatorsdk/samples/mysqlschema/MySQLSchemaReconciler.java b/...a/src/main/java/io/quarkiverse/operatorsdk/samples/mysqlschema/MySQLSchemaReconciler.java
@@ -42,7 +42,7 @@ public UpdateControl<MySQLSchema> reconcile(MySQLSchema schema, Context<MySQLSch
                             updateStatusPojo(schema, secret.getMetadata().getName(),
                                     decode(secret.getData().get(MYSQL_SECRET_USERNAME)));
                             Log.infof("Schema %s created - updating CR status", s.getName());
-                            return UpdateControl.updateStatus(schema);
+                            return UpdateControl.patchStatus(schema);
                         }).orElse(UpdateControl.noUpdate()))
                 .orElse(UpdateControl.noUpdate());
     }
@@ -58,7 +58,7 @@ public ErrorStatusUpdateControl<MySQLSchema> updateErrorStatus(MySQLSchema schem
         status.setStatus("ERROR: " + e.getMessage());
         schema.setStatus(status);
 
-        return ErrorStatusUpdateControl.updateStatus(schema);
+        return ErrorStatusUpdateControl.patchStatus(schema);
     }
 
     private void updateStatusPojo(MySQLSchema schema, String secretName, String userName) {

diff --git a/...es/pingpong/src/main/java/io/quarkiverse/operatorsdk/samples/pingpong/PingReconciler.java b/...es/pingpong/src/main/java/io/quarkiverse/operatorsdk/samples/pingpong/PingReconciler.java
@@ -48,6 +48,6 @@ public UpdateControl<Ping> reconcile(Ping ping, Context<Ping> context) {
         }
 
         ping.setStatus(new Status(Status.State.PROCESSED));
-        return UpdateControl.updateStatus(ping);
+        return UpdateControl.patchStatus(ping);
     }
 }
diff --git a/...es/pingpong/src/main/java/io/quarkiverse/operatorsdk/samples/pingpong/PongReconciler.java b/...es/pingpong/src/main/java/io/quarkiverse/operatorsdk/samples/pingpong/PongReconciler.java
@@ -21,6 +21,7 @@
 import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
 import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
 
+@SuppressWarnings("unused")
 @ControllerConfiguration(namespaces = WATCH_CURRENT_NAMESPACE)
 public class PongReconciler implements Reconciler<Pong> {
 
@@ -32,6 +33,6 @@ public UpdateControl<Pong> reconcile(Pong pong, Context<Pong> context) {
         }
 
         pong.setStatus(new Status(Status.State.PROCESSED));
-        return UpdateControl.updateStatus(pong);
+        return UpdateControl.patchStatus(pong);
     }
 }