Consistently reread on conflict and add support for updating operator target namespaces while running

Author: rjeberhard

operator/src/main/java/oracle/kubernetes/operator/DomainStatusUpdater.java

@@ -297,7 +297,8 @@ public NextAction apply(Packet packet) {
         madeChange = true;
       }
 
-      // This will control if we need to re-check states soon or if we can slow down checks
+      // This will control if we need to re-check states soon or if we can slow down
+      // checks
       packet.put(ProcessingConstants.STATUS_UNCHANGED, Boolean.valueOf(!madeChange));
 
       if (madeChange) {
@@ -658,7 +659,12 @@ public NextAction onFailure(
                     if (statusCode == CallBuilder.NOT_FOUND) {
                       return doNext(packet); // Just ignore update
                     }
-                    return super.onFailure(conflictStep, packet, e, statusCode, responseHeaders);
+                    return super.onFailure(
+                        getRereadDomainConflictStep(factory, info, meta, conflictStep),
+                        packet,
+                        e,
+                        statusCode,
+                        responseHeaders);
                   }
 
                   @Override
@@ -675,6 +681,38 @@ public NextAction onSuccess(
     return na;
   }
 
+  private static Step getRereadDomainConflictStep(
+      CallBuilderFactory factory, DomainPresenceInfo info, V1ObjectMeta meta, Step next) {
+    return factory
+        .create()
+        .readDomainAsync(
+            meta.getName(),
+            meta.getNamespace(),
+            new ResponseStep<Domain>(next) {
+              @Override
+              public NextAction onFailure(
+                  Packet packet,
+                  ApiException e,
+                  int statusCode,
+                  Map<String, List<String>> responseHeaders) {
+                if (statusCode == CallBuilder.NOT_FOUND) {
+                  return doNext(packet);
+                }
+                return super.onFailure(packet, e, statusCode, responseHeaders);
+              }
+
+              @Override
+              public NextAction onSuccess(
+                  Packet packet,
+                  Domain result,
+                  int statusCode,
+                  Map<String, List<String>> responseHeaders) {
+                info.setDomain(result);
+                return doNext(packet);
+              }
+            });
+  }
+
   /**
    * Asynchronous step to set Domain condition to Failed
    *