feat: inject leader election / informer stopped handler into config

Requires operator-framework/java-operator-sdk#1493

Author: metacosm

core/runtime/src/main/java/io/quarkiverse/operatorsdk/runtime/ConfigurationServiceRecorder.java

@@ -9,6 +9,8 @@
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.fabric8.kubernetes.client.utils.Serialization;
 import io.javaoperatorsdk.operator.api.config.ConfigurationService;
+import io.javaoperatorsdk.operator.api.config.InformerStoppedHandler;
+import io.javaoperatorsdk.operator.api.config.LeaderElectionConfiguration;
 import io.javaoperatorsdk.operator.api.monitoring.Metrics;
 import io.quarkus.arc.Arc;
 import io.quarkus.jackson.ObjectMapperCustomizer;
@@ -46,21 +48,24 @@ public Supplier<QuarkusConfigurationService> configurationServiceSupplier(Versio
             // customize fabric8 mapper
             final var mapper = Serialization.jsonMapper();
             mapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
-            Arc.container().select(ObjectMapperCustomizer.class, KubernetesClientSerializationCustomizer.Literal.INSTANCE)
+            final var container = Arc.container();
+            container.select(ObjectMapperCustomizer.class, KubernetesClientSerializationCustomizer.Literal.INSTANCE)
                     .stream()
                     .sorted()
                     .forEach(c -> c.customize(mapper));
 
             return new QuarkusConfigurationService(
                     version,
                     configurations.values(),
-                    Arc.container().instance(KubernetesClient.class).get(),
+                    container.instance(KubernetesClient.class).get(),
                     crdInfo,
                     maxThreads,
                     timeout,
-                    Arc.container().instance(Metrics.class).get(),
+                    container.instance(Metrics.class).get(),
                     shouldStartOperator(buildTimeConfiguration.startOperator, launchMode),
-                    mapper);
+                    mapper,
+                    container.instance(LeaderElectionConfiguration.class).orElse(null),
+                    container.instance(InformerStoppedHandler.class).orElse(null));
         };
     }
 

core/runtime/src/main/java/io/quarkiverse/operatorsdk/runtime/QuarkusConfigurationService.java

@@ -4,6 +4,7 @@
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Optional;
 import java.util.stream.Stream;
 
 import org.slf4j.Logger;
@@ -18,6 +19,8 @@
 import io.javaoperatorsdk.operator.api.config.AbstractConfigurationService;
 import io.javaoperatorsdk.operator.api.config.Cloner;
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
+import io.javaoperatorsdk.operator.api.config.InformerStoppedHandler;
+import io.javaoperatorsdk.operator.api.config.LeaderElectionConfiguration;
 import io.javaoperatorsdk.operator.api.config.Version;
 import io.javaoperatorsdk.operator.api.config.dependent.DependentResourceSpec;
 import io.javaoperatorsdk.operator.api.monitoring.Metrics;
@@ -38,14 +41,17 @@ public class QuarkusConfigurationService extends AbstractConfigurationService {
     private final Map<String, String> reconcilerClassToName;
     private final Metrics metrics;
     private final boolean startOperator;
+    private final LeaderElectionConfiguration leaderElectionConfiguration;
+    private final InformerStoppedHandler informerStoppedHandler;
 
     @SuppressWarnings({ "rawtypes", "unchecked" })
     public QuarkusConfigurationService(
             Version version,
             Collection<QuarkusControllerConfiguration> configurations,
             KubernetesClient client,
             CRDGenerationInfo crdInfo, int maxThreads,
-            int timeout, Metrics metrics, boolean startOperator, ObjectMapper mapper) {
+            int timeout, Metrics metrics, boolean startOperator, ObjectMapper mapper,
+            LeaderElectionConfiguration leaderElectionConfiguration, InformerStoppedHandler informerStoppedHandler) {
         super(version);
         final var cloner = new Cloner() {
             @Override
@@ -73,6 +79,8 @@ public <R extends HasMetadata> R clone(R r) {
         this.crdInfo = crdInfo;
         this.concurrentReconciliationThreads = maxThreads;
         this.terminationTimeout = timeout;
+        this.informerStoppedHandler = informerStoppedHandler;
+        this.leaderElectionConfiguration = leaderElectionConfiguration;
     }
 
     @Override
@@ -171,4 +179,14 @@ public DependentResourceFactory dependentResourceFactory() {
     public Stream<ControllerConfiguration> controllerConfigurations() {
         return super.controllerConfigurations();
     }
+
+    @Override
+    public Optional<LeaderElectionConfiguration> getLeaderElectionConfiguration() {
+        return Optional.ofNullable(leaderElectionConfiguration);
+    }
+
+    @Override
+    public Optional<InformerStoppedHandler> getInformerStoppedHandler() {
+        return Optional.ofNullable(informerStoppedHandler);
+    }
 }

pom.xml

@@ -13,7 +13,7 @@
   <name>Quarkus - Operator SDK - Parent</name>
   <properties>
     <quarkus.version>2.13.1.Final</quarkus.version>
-    <java-operator-sdk.version>3.2.1</java-operator-sdk.version>
+    <java-operator-sdk.version>3.2.3-SNAPSHOT</java-operator-sdk.version>
   </properties>
 
   <profiles>