feat: provide KubernetesClient access from context

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.fabric8.kubernetes.client.KubernetesClient;
 import io.javaoperatorsdk.operator.api.config.ConfigurationService;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
 import io.javaoperatorsdk.operator.processing.event.source.ResourceCache;
@@ -14,11 +15,13 @@ public class EventSourceInitializationContext<P extends HasMetadata> {
 
   private final ResourceCache<P> primaryCache;
   private final ConfigurationService configurationService;
+  private final KubernetesClient client;
 
   public EventSourceInitializationContext(ResourceCache<P> primaryCache,
-      ConfigurationService configurationService) {
+      ConfigurationService configurationService, KubernetesClient client) {
     this.primaryCache = primaryCache;
     this.configurationService = configurationService;
+    this.client = client;
   }
 
   /**
@@ -42,4 +45,15 @@ public ResourceCache<P> getPrimaryCache() {
   public ConfigurationService getConfigurationService() {
     return configurationService;
   }
+
+  /**
+   * Provides access to the {@link KubernetesClient} used by the current
+   * {@link io.javaoperatorsdk.operator.Operator} instance.
+   * 
+   * @return the {@link KubernetesClient} used by the current
+   *         {@link io.javaoperatorsdk.operator.Operator} instance.
+   */
+  public KubernetesClient getClient() {
+    return client;
+  }
 }

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

@@ -46,7 +46,7 @@ public Controller(Reconciler<R> reconciler,
     eventSourceManager = new EventSourceManager<>(this);
     final var context = new EventSourceInitializationContext<>(
         eventSourceManager.getControllerResourceEventSource().getResourceCache(),
-        configurationService());
+        configurationService(), kubernetesClient);
     prepareEventSources(context).forEach(eventSourceManager::registerEventSource);
   }