More tuning parameters

Author: rjeberhard

src/main/java/oracle/kubernetes/operator/Main.java

@@ -96,7 +96,14 @@ public class Main {
   private static final int statusUpdateTimeoutSeconds = (int) readTuningParameter("statusUpdateTimeoutSeconds", 10);
   private static final int unchangedCountToDelayStatusRecheck = (int) readTuningParameter("unchangedCountToDelayStatusRecheck", 10); 
   private static final long initialShortDelay = readTuningParameter("initialShortDelay", 3); 
-  private static final long eventualLongDelay = readTuningParameter("eventualLongDelay", 30); 
+  private static final long eventualLongDelay = readTuningParameter("eventualLongDelay", 30);
+  
+  static {
+    int callRequestLimit = (int) readTuningParameter("callRequestLimit", 500);
+    int callMaxRetryCount = (int) readTuningParameter("callMaxRetryCount", 5);
+    int callTimeoutSeconds = (int) readTuningParameter("callTimeoutSeconds", 10);
+    CallBuilder.setTuningParameters(callRequestLimit, callMaxRetryCount, callTimeoutSeconds);
+  }
 
   private static final ConcurrentMap<String, Boolean> initialized = new ConcurrentHashMap<>();
   private static final AtomicBoolean stopping = new AtomicBoolean(false);

src/main/java/oracle/kubernetes/operator/helpers/CallBuilder.java

@@ -48,10 +48,20 @@
  * 
  */
 public class CallBuilder {
-  static final String RESPONSE_COMPONENT_NAME = "response";
-
   private static final LoggingFacade LOGGER = LoggingFactory.getLogger("Operator", "Operator");
 
+  static final String RESPONSE_COMPONENT_NAME = "response";
+
+  private static int callRequestLimit = 500;
+  private static int callMaxRetryCount = 5;
+  private static int callTimeoutSeconds = 10;
+  
+  public static void setTuningParameters(int callRequestLimit, int callMaxRetryCount, int callTimeoutSeconds) {
+    CallBuilder.callRequestLimit = callRequestLimit;
+    CallBuilder.callMaxRetryCount = callMaxRetryCount;
+    CallBuilder.callTimeoutSeconds = callTimeoutSeconds;
+  }
+  
   /**
    * HTTP status code for "Not Found"
    */
@@ -65,9 +75,10 @@ public class CallBuilder {
   public String fieldSelector = "";
   public Boolean includeUninitialized = Boolean.FALSE;
   public String labelSelector = "";
-  public Integer limit = 500;
+  public Integer limit = callRequestLimit;
   public String resourceVersion = "";
-  public Integer timeoutSeconds = 30;
+  public Integer timeoutSeconds = callTimeoutSeconds;
+  public Integer maxRetryCount = callMaxRetryCount;
   public Boolean watch = Boolean.FALSE;
   public Boolean exact = Boolean.FALSE;
   public Boolean export = Boolean.FALSE;
@@ -1446,7 +1457,7 @@ public NextAction doPotentialRetry(Step conflictStep, Packet packet, ApiExceptio
         }
 
         NextAction na = new NextAction();
-        if (statusCode == 0 && retryCount <= 2) {
+        if (statusCode == 0 && retryCount <= maxRetryCount) {
           na.invoke(retryStep, packet);
         } else {
           LOGGER.info(MessageKeys.ASYNC_RETRY, String.valueOf(waitTime));