wip

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java

@@ -46,18 +46,24 @@ public class InformerManager<T extends HasMetadata, C extends ResourceConfigurat
   private ResourceEventHandler<T> eventHandler;
   private final Map<String, Function<T, List<String>>> indexers = new HashMap<>();
 
+  public InformerManager(MixedOperation<T, KubernetesResourceList<T>, Resource<T>> client,
+                         C configuration,
+                         ResourceEventHandler<T> eventHandler) {
+    this.client = client;
+    this.configuration = configuration;
+    this.eventHandler = eventHandler;
+  }
+
   @Override
   public void start() throws OperatorException {
+    initSources();
     // make sure informers are all started before proceeding further
     sources.values().parallelStream().forEach(InformerWrapper::start);
   }
 
-  void initSources(MixedOperation<T, KubernetesResourceList<T>, Resource<T>> client,
-      C configuration, ResourceEventHandler<T> eventHandler) {
+  private void initSources() {
+    sources.clear();
     cloner = ConfigurationServiceProvider.instance().getResourceCloner();
-    this.configuration = configuration;
-    this.client = client;
-    this.eventHandler = eventHandler;
 
     final var targetNamespaces = configuration.getEffectiveNamespaces();
     if (ResourceConfiguration.allNamespacesWatched(targetNamespaces)) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/ManagedInformerEventSource.java

@@ -37,14 +37,14 @@ public abstract class ManagedInformerEventSource<R extends HasMetadata, P extend
   private static final Logger log = LoggerFactory.getLogger(ManagedInformerEventSource.class);
 
   protected TemporaryResourceCache<R> temporaryResourceCache;
-  protected InformerManager<R, C> cache = new InformerManager<>();
+  protected InformerManager<R, C> cache;
   protected C configuration;
 
   protected ManagedInformerEventSource(
       MixedOperation<R, KubernetesResourceList<R>, Resource<R>> client, C configuration) {
     super(configuration.getResourceClass());
     temporaryResourceCache = new TemporaryResourceCache<>(this);
-    manager().initSources(client, configuration, this);
+    cache = new InformerManager<>(client,configuration,this);
     this.configuration = configuration;
   }