feat: initialization context provides access to ConfigurationService (#776)

Author: metacosm

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/EventSourceInitializationContext.java

@@ -1,6 +1,7 @@
 package io.javaoperatorsdk.operator.api.reconciler;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.config.ConfigurationService;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
 import io.javaoperatorsdk.operator.processing.event.source.ResourceCache;
 
@@ -12,9 +13,12 @@
 public class EventSourceInitializationContext<P extends HasMetadata> {
 
   private final ResourceCache<P> primaryCache;
+  private final ConfigurationService configurationService;
 
-  public EventSourceInitializationContext(ResourceCache<P> primaryCache) {
+  public EventSourceInitializationContext(ResourceCache<P> primaryCache,
+      ConfigurationService configurationService) {
     this.primaryCache = primaryCache;
+    this.configurationService = configurationService;
   }
 
   /**
@@ -25,4 +29,17 @@ public EventSourceInitializationContext(ResourceCache<P> primaryCache) {
   public ResourceCache<P> getPrimaryCache() {
     return primaryCache;
   }
+
+  /**
+   * Retrieves the {@link ConfigurationService} associated with the operator. This allows, in
+   * particular, to lookup global configuration information such as the configured
+   * {@link io.javaoperatorsdk.operator.api.monitoring.Metrics} or
+   * {@link io.javaoperatorsdk.operator.api.config.Cloner} implementations, which could be useful to
+   * event sources.
+   * 
+   * @return the {@link ConfigurationService} associated with the operator
+   */
+  public ConfigurationService getConfigurationService() {
+    return configurationService;
+  }
 }

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

@@ -173,7 +173,8 @@ public void start() throws OperatorException {
       if (reconciler instanceof EventSourceInitializer) {
         ((EventSourceInitializer<R>) reconciler)
             .prepareEventSources(new EventSourceInitializationContext<>(
-                eventSourceManager.getControllerResourceEventSource().getResourceCache()))
+                eventSourceManager.getControllerResourceEventSource().getResourceCache(),
+                configuration.getConfigurationService()))
             .forEach(eventSourceManager::registerEventSource);
       }
       if (failOnMissingCurrentNS()) {