feat: add config option for informerListLimit (#669)

Co-authored-by: Chris Laprun <[email protected]>

Author: csviri

core/deployment/src/main/java/io/quarkiverse/operatorsdk/deployment/QuarkusControllerConfigurationBuildStep.java

@@ -167,6 +167,7 @@ static QuarkusControllerConfiguration createConfiguration(
         Class<?> retryConfigurationClass = null;
         Class<? extends RateLimiter> rateLimiterClass = DefaultRateLimiter.class;
         Class<?> rateLimiterConfigurationClass = null;
+        Long nullableInformerListLimit = null;
         if (controllerAnnotation != null) {
             final var intervalFromAnnotation = ConfigurationUtils.annotationValueOrDefault(
                     controllerAnnotation, "maxReconciliationInterval", AnnotationValue::asNested,
@@ -202,6 +203,9 @@ static QuarkusControllerConfiguration createConfiguration(
             final var rateLimiterConfigurableInfo = configurableInfos.get(rateLimiterClass.getName());
             rateLimiterConfigurationClass = getConfigurationAnnotationClass(reconcilerInfo,
                     rateLimiterConfigurableInfo);
+            nullableInformerListLimit = ConfigurationUtils.annotationValueOrDefault(
+                    controllerAnnotation, "informerListLimit", AnnotationValue::asLong,
+                    () -> null);
         }
 
         // extract the namespaces
@@ -249,6 +253,7 @@ static QuarkusControllerConfiguration createConfiguration(
                 primaryAsResource.version(),
                 configExtractor.generationAware(),
                 resourceClass,
+                nullableInformerListLimit,
                 namespaces,
                 wereNamespacesSet,
                 getFinalizer(controllerAnnotation, resourceFullName),

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

@@ -66,6 +66,7 @@ public DefaultRateLimiter(Duration refreshPeriod, int limitForPeriod) {
     private final boolean generationAware;
     private final boolean statusPresentAndNotVoid;
     private final Class<R> resourceClass;
+    private final Optional<Long> informerListLimit;
     private final ResourceEventFilter<R> eventFilter;
     private final Optional<Duration> maxReconciliationInterval;
     private final Optional<OnAddFilter<? super R>> onAddFilter;
@@ -93,7 +94,9 @@ public QuarkusControllerConfiguration(
             String name,
             String resourceTypeName,
             String crVersion, boolean generationAware,
-            Class resourceClass, Set<String> namespaces,
+            Class resourceClass,
+            Long nullableInformerListLimit,
+            Set<String> namespaces,
             boolean wereNamespacesSet,
             String finalizerName, String labelSelector,
             boolean statusPresentAndNotVoid, ResourceEventFilter eventFilter,
@@ -109,6 +112,7 @@ public QuarkusControllerConfiguration(
         this.crVersion = crVersion;
         this.generationAware = generationAware;
         this.resourceClass = resourceClass;
+        this.informerListLimit = Optional.ofNullable(nullableInformerListLimit);
         this.dependentsMetadata = dependentsMetadata;
         this.workflow = workflow;
         this.retryConfiguration = ControllerConfiguration.super.getRetryConfiguration();
@@ -148,6 +152,17 @@ public Class<R> getResourceClass() {
         return resourceClass;
     }
 
+    @Override
+    public Optional<Long> getInformerListLimit() {
+        return informerListLimit;
+    }
+
+    @SuppressWarnings("unused")
+    // this is needed by Quarkus for the RecordableConstructor
+    public Long getNullableInformerListLimit() {
+        return informerListLimit.orElse(null);
+    }
+
     @Override
     public String getName() {
         return name;