Merge pull request #591 from oracle/domain-status

Improvements on watch tuning and domain status

Author: rjeberhard

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

@@ -8,6 +8,7 @@
 import io.kubernetes.client.models.V1ConfigMap;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicBoolean;
+import oracle.kubernetes.operator.TuningParameters.WatchTuning;
 import oracle.kubernetes.operator.builders.WatchBuilder;
 import oracle.kubernetes.operator.builders.WatchI;
 import oracle.kubernetes.operator.watcher.WatchListener;
@@ -23,20 +24,22 @@ public static ConfigMapWatcher create(
       ThreadFactory factory,
       String ns,
       String initialResourceVersion,
+      WatchTuning tuning,
       WatchListener<V1ConfigMap> listener,
       AtomicBoolean isStopping) {
     ConfigMapWatcher watcher =
-        new ConfigMapWatcher(ns, initialResourceVersion, listener, isStopping);
+        new ConfigMapWatcher(ns, initialResourceVersion, tuning, listener, isStopping);
     watcher.start(factory);
     return watcher;
   }
 
   private ConfigMapWatcher(
       String ns,
       String initialResourceVersion,
+      WatchTuning tuning,
       WatchListener<V1ConfigMap> listener,
       AtomicBoolean isStopping) {
-    super(initialResourceVersion, isStopping, listener);
+    super(initialResourceVersion, tuning, isStopping, listener);
     this.ns = ns;
   }
 

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

@@ -33,4 +33,6 @@ public void makeRightDomainPresence(
   public void dispatchConfigMapWatch(Watch.Response<V1ConfigMap> item);
 
   public void dispatchEventWatch(Watch.Response<V1Event> item);
+
+  public void stopNamespace(String ns);
 }