Merge pull request #1416 from tony-clarke-amdocs/master

Allow controller builder to set ready timeout

Author: k8s-ci-robot

extended/src/main/java/io/kubernetes/client/extended/controller/builder/DefaultControllerBuilder.java

@@ -13,14 +13,18 @@
 package io.kubernetes.client.extended.controller.builder;
 
 import io.kubernetes.client.common.KubernetesObject;
-import io.kubernetes.client.extended.controller.*;
+import io.kubernetes.client.extended.controller.Controller;
+import io.kubernetes.client.extended.controller.ControllerWatch;
+import io.kubernetes.client.extended.controller.Controllers;
+import io.kubernetes.client.extended.controller.DefaultController;
 import io.kubernetes.client.extended.controller.reconciler.Reconciler;
 import io.kubernetes.client.extended.controller.reconciler.Request;
 import io.kubernetes.client.extended.workqueue.DefaultRateLimitingQueue;
 import io.kubernetes.client.extended.workqueue.RateLimitingQueue;
 import io.kubernetes.client.extended.workqueue.WorkQueue;
 import io.kubernetes.client.informer.SharedIndexInformer;
 import io.kubernetes.client.informer.SharedInformerFactory;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.Executors;
@@ -33,6 +37,7 @@ public class DefaultControllerBuilder {
   private int workerCount;
   private String controllerName;
   private RateLimitingQueue<Request> workQueue;
+  private Duration readyTimeout;
 
   private SharedInformerFactory informerFactory;
   private List<Supplier<Boolean>> readyFuncs;
@@ -114,6 +119,11 @@ public DefaultControllerBuilder withReadyFunc(Supplier<Boolean> readyFunc) {
     return this;
   }
 
+  public DefaultControllerBuilder withReadyTimeout(Duration readyTimeout) {
+    this.readyTimeout = readyTimeout;
+    return this;
+  }
+
   /**
    * Overrides worker thread counts of the controller.
    *
@@ -154,6 +164,9 @@ public Controller build() throws IllegalStateException {
             this.workQueue,
             this.readyFuncs.stream().toArray(Supplier[]::new));
 
+    if (this.readyTimeout != null) {
+      controller.setReadyTimeout(this.readyTimeout);
+    }
     controller.setWorkerCount(this.workerCount);
     controller.setWorkerThreadPool(
         Executors.newScheduledThreadPool(