fixes

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/informer/InformerConfiguration.java

@@ -164,7 +164,7 @@ public <P extends HasMetadata> InformerConfigurationBuilder<R> withNamespacesInh
     }
 
     /**
-     * Whether or not the associated informer should track changes made to the parent
+     * Whether the associated informer should track changes made to the parent
      * {@link io.javaoperatorsdk.operator.processing.Controller}'s namespaces configuration.
      *
      * @param followChanges {@code true} to reconfigure the associated informer when the parent

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

@@ -17,6 +17,7 @@
 import io.javaoperatorsdk.operator.processing.Controller;
 import io.javaoperatorsdk.operator.processing.LifecycleAware;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+import io.javaoperatorsdk.operator.processing.event.source.EventSourceStartPriority;
 import io.javaoperatorsdk.operator.processing.event.source.ResourceEventAware;
 import io.javaoperatorsdk.operator.processing.event.source.ResourceEventSource;
 import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource;
@@ -63,7 +64,12 @@ public void postProcessDefaultEventSourcesAfterProcessorInitializer() {
   @Override
   public synchronized void start() {
     startEventSource(eventSources.namedControllerResourceEventSource());
-    eventSources.additionalNamedEventSources().parallel().forEach(this::startEventSource);
+    eventSources.additionalNamedEventSources()
+        .filter(es -> es.priority().equals(EventSourceStartPriority.RESOURCE_STATE_LOADER))
+        .parallel().forEach(this::startEventSource);
+    eventSources.additionalNamedEventSources()
+        .filter(es -> es.priority().equals(EventSourceStartPriority.DEFAULT))
+        .parallel().forEach(this::startEventSource);
   }
 
   @Override

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/NamedEventSource.java

@@ -4,6 +4,7 @@
 
 import io.javaoperatorsdk.operator.OperatorException;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+import io.javaoperatorsdk.operator.processing.event.source.EventSourceStartPriority;
 
 class NamedEventSource implements EventSource {
 
@@ -57,4 +58,9 @@ public boolean equals(Object o) {
   public int hashCode() {
     return Objects.hash(original, name);
   }
+
+  @Override
+  public EventSourceStartPriority priority() {
+    return original.priority();
+  }
 }

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

@@ -6,7 +6,7 @@
 public abstract class AbstractEventSource implements EventSource {
   private EventHandler handler;
   private volatile boolean running = false;
-  private EventSourceStartPriority eventSourceStartPriority;
+  private EventSourceStartPriority eventSourceStartPriority = EventSourceStartPriority.DEFAULT;
 
   protected EventHandler getEventHandler() {
     return handler;

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/EventSourceManagerTest.java

@@ -12,6 +12,7 @@
 import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
 import io.javaoperatorsdk.operator.processing.Controller;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+import io.javaoperatorsdk.operator.processing.event.source.EventSourceStartPriority;
 import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource;
 import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
 import io.javaoperatorsdk.operator.processing.event.source.informer.ManagedInformerEventSource;
@@ -59,7 +60,9 @@ public void closeShouldCascadeToEventSources() {
   @Test
   public void startCascadesToEventSources() {
     EventSource eventSource = mock(EventSource.class);
+    when(eventSource.priority()).thenReturn(EventSourceStartPriority.DEFAULT);
     EventSource eventSource2 = mock(TimerEventSource.class);
+    when(eventSource2.priority()).thenReturn(EventSourceStartPriority.DEFAULT);
     eventSourceManager.registerEventSource(eventSource);
     eventSourceManager.registerEventSource(eventSource2);
 

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/externalstate/ExternalStateReconciler.java

@@ -58,6 +58,7 @@ private void createExternalResource(ExternalStateCustomResource resource) {
             .build())
         .withData(Map.of(ID_KEY, createdResource.getId()))
         .build();
+    configMap.addOwnerReference(resource);
     client.configMaps().resource(configMap).create();
 
     var primaryID = ResourceID.fromResource(resource);