progess

Signed-off-by: Attila Mészáros <csviri@gmail.com>

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/GenericKubernetesDependentStandaloneIT.java

@@ -1,13 +1,22 @@
 package io.javaoperatorsdk.operator;
 
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
 
 import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
 import io.fabric8.kubernetes.client.KubernetesClientBuilder;
 import io.fabric8.kubernetes.client.informers.ResourceEventHandler;
+import io.javaoperatorsdk.operator.junit.LocallyRunOperatorExtension;
+import io.javaoperatorsdk.operator.sample.generickubernetesdependentstandalone.GenericKubernetesDependentStandaloneReconciler;
 
 public class GenericKubernetesDependentStandaloneIT {
 
+  @RegisterExtension
+  LocallyRunOperatorExtension operator =
+      LocallyRunOperatorExtension.builder()
+          .withConfigurationService(o -> o.withCloseClientOnStop(false))
+          .withReconciler(new GenericKubernetesDependentStandaloneReconciler())
+          .build();
 
   @Test
   void testInformer() {
@@ -36,5 +45,4 @@ public void onDelete(GenericKubernetesResource genericKubernetesResource, boolea
     }
   }
 
-
 }

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/generickubernetesdependentstandalone/GenericKubernetesDependentStandaloneReconciler.java

@@ -1,28 +1,31 @@
 package io.javaoperatorsdk.operator.sample.generickubernetesdependentstandalone;
 
+import java.util.Map;
+
 import io.javaoperatorsdk.operator.api.reconciler.*;
-import io.javaoperatorsdk.operator.sample.bulkdependent.CRUDConfigMapBulkDependentResource;
-import io.javaoperatorsdk.operator.sample.bulkdependent.ConfigMapDeleterBulkDependentResource;
+import io.javaoperatorsdk.operator.processing.event.source.EventSource;
 
 @ControllerConfiguration
 public class GenericKubernetesDependentStandaloneReconciler
-    implements Reconciler<GenericKubernetesDependentStandaloneCustomResource> {
-
+    implements Reconciler<GenericKubernetesDependentStandaloneCustomResource>,
+    EventSourceInitializer<GenericKubernetesDependentStandaloneCustomResource> {
 
-  private final ConfigMapDeleterBulkDependentResource dependent;
+  private final ConfigMapGenericKubernetesDependent dependent =
+      new ConfigMapGenericKubernetesDependent();
 
-  public GenericKubernetesDependentStandaloneReconciler() {
-    dependent = new CRUDConfigMapBulkDependentResource();
-  }
+  public GenericKubernetesDependentStandaloneReconciler() {}
 
   @Override
   public UpdateControl<GenericKubernetesDependentStandaloneCustomResource> reconcile(
       GenericKubernetesDependentStandaloneCustomResource resource,
       Context<GenericKubernetesDependentStandaloneCustomResource> context) {
 
-
-
     return UpdateControl.noUpdate();
   }
 
+  @Override
+  public Map<String, EventSource> prepareEventSources(
+      EventSourceContext<GenericKubernetesDependentStandaloneCustomResource> context) {
+    return EventSourceInitializer.nameEventSources(dependent.eventSource(context).orElseThrow());
+  }
 }