now controller can be registered to watch all namespaces

Author: csviri

operator-framework/src/main/java/com/github/containersolutions/operator/Operator.java

@@ -33,7 +33,16 @@ public Operator(KubernetesClient k8sClient) {
         this.k8sClient = k8sClient;
     }
 
+    public <R extends CustomResource> void registerControllerForAllNamespaces(ResourceController<R> controller) throws OperatorException {
+        registerController(controller, true);
+    }
+
     public <R extends CustomResource> void registerController(ResourceController<R> controller, String... targetNamespaces) throws OperatorException {
+        registerController(controller, false, targetNamespaces);
+    }
+
+    private <R extends CustomResource> void registerController(ResourceController<R> controller,
+                                                               boolean watchAllNamespaces, String... targetNamespaces) throws OperatorException {
         Class<R> resClass = getCustomResourceClass(controller);
         Optional<CustomResourceDefinition> crd = getCustomResourceDefinitionForController(controller);
         String kind = ControllerUtils.getKind(controller);
@@ -47,17 +56,20 @@ public <R extends CustomResource> void registerController(ResourceController<R>
             EventDispatcher<R> eventDispatcher =
                     new EventDispatcher<>(controller, (CustomResourceOperationsImpl) client, client, k8sClient,
                             ControllerUtils.getDefaultFinalizer(controller));
-            registerWatches(controller, client, eventDispatcher, resClass, targetNamespaces);
+            registerWatches(controller, client, eventDispatcher, resClass, watchAllNamespaces, targetNamespaces);
         } else {
             throw new OperatorException("CRD '" + resClass.getSimpleName() + "' with version '"
                     + getVersion(controller) + "' not found");
         }
     }
 
     private <R extends CustomResource> void registerWatches(ResourceController<R> controller, MixedOperation client,
-                                                            EventDispatcher<R> eventDispatcher, Class<R> resClass, String[] targetNamespaces) {
+                                                            EventDispatcher<R> eventDispatcher, Class<R> resClass,
+                                                            boolean watchAllNamespaces, String[] targetNamespaces) {
         CustomResourceOperationsImpl crClient = (CustomResourceOperationsImpl) client;
-        if (targetNamespaces.length == 0) {
+        if (watchAllNamespaces) {
+            crClient.inAnyNamespace().watch(eventDispatcher);
+        } else if (targetNamespaces.length == 0) {
             client.watch(eventDispatcher);
         } else {
             for (String targetNamespace : targetNamespaces) {