refactor: remove EventSourceManager from Context

Author: metacosm

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

@@ -2,13 +2,10 @@
 
 import io.fabric8.kubernetes.client.CustomResource;
 import io.javaoperatorsdk.operator.processing.event.EventList;
-import io.javaoperatorsdk.operator.processing.event.EventSourceManager;
 import java.util.Optional;
 
 public interface Context<T extends CustomResource> {
 
-  EventSourceManager getEventSourceManager();
-
   EventList getEvents();
 
   Optional<RetryInfo> getRetryInfo();

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

@@ -2,25 +2,16 @@
 
 import io.fabric8.kubernetes.client.CustomResource;
 import io.javaoperatorsdk.operator.processing.event.EventList;
-import io.javaoperatorsdk.operator.processing.event.EventSourceManager;
 import java.util.Optional;
 
 public class DefaultContext<T extends CustomResource> implements Context<T> {
 
   private final RetryInfo retryInfo;
   private final EventList events;
-  private final EventSourceManager eventSourceManager;
 
-  public DefaultContext(
-      EventSourceManager eventSourceManager, EventList events, RetryInfo retryInfo) {
+  public DefaultContext(EventList events, RetryInfo retryInfo) {
     this.retryInfo = retryInfo;
     this.events = events;
-    this.eventSourceManager = eventSourceManager;
-  }
-
-  @Override
-  public EventSourceManager getEventSourceManager() {
-    return eventSourceManager;
   }
 
   @Override

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

@@ -85,7 +85,6 @@ public void close() {
 
   public void setEventSourceManager(DefaultEventSourceManager eventSourceManager) {
     this.eventSourceManager = eventSourceManager;
-    eventDispatcher.setEventSourceManager(eventSourceManager);
   }
 
   @Override

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

@@ -15,21 +15,19 @@
 import io.javaoperatorsdk.operator.api.ResourceController;
 import io.javaoperatorsdk.operator.api.UpdateControl;
 import io.javaoperatorsdk.operator.processing.event.EventList;
-import io.javaoperatorsdk.operator.processing.event.EventSourceManager;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
  * Dispatches events to the Controller and handles Finalizers for a single type of Custom Resource.
  */
-public class EventDispatcher<R extends CustomResource> {
+class EventDispatcher<R extends CustomResource> {
 
   private static final Logger log = LoggerFactory.getLogger(EventDispatcher.class);
 
   private final ResourceController<R> controller;
   private final String resourceFinalizer;
   private final CustomResourceFacade<R> customResourceFacade;
-  private EventSourceManager eventSourceManager;
 
   EventDispatcher(
       ResourceController<R> controller,
@@ -47,10 +45,6 @@ public EventDispatcher(
     this(controller, finalizer, new CustomResourceFacade<>(client));
   }
 
-  public void setEventSourceManager(EventSourceManager eventSourceManager) {
-    this.eventSourceManager = eventSourceManager;
-  }
-
   public PostExecutionControl handleExecution(ExecutionScope<R> executionScope) {
     try {
       return handleDispatch(executionScope);
@@ -87,9 +81,7 @@ private PostExecutionControl handleDispatch(ExecutionScope<R> executionScope) {
     }
     Context<R> context =
         new DefaultContext<>(
-            eventSourceManager,
-            new EventList(executionScope.getEvents()),
-            executionScope.getRetryInfo());
+            new EventList(executionScope.getEvents()), executionScope.getRetryInfo());
     if (resource.isMarkedForDeletion()) {
       return handleDelete(resource, context);
     } else {