override

Author: csviri

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

@@ -19,7 +19,9 @@ public class ConfigurationServiceOverrider {
   private Config clientConfig;
   private Boolean checkCR;
   private Integer concurrentReconciliationThreads;
+  private Integer minConcurrentReconciliationThreads;
   private Integer concurrentWorkflowExecutorThreads;
+  private Integer minConcurrentWorkflowExecutorThreads;
   private Cloner cloner;
   private Integer timeoutSeconds;
   private Boolean closeClientOnStop;
@@ -56,6 +58,16 @@ public ConfigurationServiceOverrider withConcurrentWorkflowExecutorThreads(int t
     return this;
   }
 
+  public ConfigurationServiceOverrider withMinConcurrentReconciliationThreads(int threadNumber) {
+    this.minConcurrentReconciliationThreads = threadNumber;
+    return this;
+  }
+
+  public ConfigurationServiceOverrider withMinConcurrentWorkflowExecutorThreads(int threadNumber) {
+    this.minConcurrentWorkflowExecutorThreads = threadNumber;
+    return this;
+  }
+
   public ConfigurationServiceOverrider withResourceCloner(Cloner cloner) {
     this.cloner = cloner;
     return this;
@@ -149,6 +161,18 @@ public int concurrentWorkflowExecutorThreads() {
             : original.concurrentWorkflowExecutorThreads();
       }
 
+      @Override
+      public int minConcurrentReconciliationThreads() {
+        return minConcurrentReconciliationThreads != null ? minConcurrentReconciliationThreads
+            : original.minConcurrentReconciliationThreads();
+      }
+
+      @Override
+      public int minConcurrentWorkflowExecutorThreads() {
+        return minConcurrentWorkflowExecutorThreads != null ? minConcurrentWorkflowExecutorThreads
+            : original.minConcurrentWorkflowExecutorThreads();
+      }
+
       @Override
       public int getTerminationTimeoutSeconds() {
         return timeoutSeconds != null ? timeoutSeconds : original.getTerminationTimeoutSeconds();