Merge pull request #662 from adohe/adjust_read_timeout

manually set OKHttpClient read timeout zero ensure client doesnot tim…

Author: k8s-ci-robot

util/src/main/java/io/kubernetes/client/informer/SharedInformerFactory.java

@@ -14,6 +14,7 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
 
 /** SharedInformerFactory class constructs and caches informers for api types. */
 public class SharedInformerFactory {
@@ -24,9 +25,16 @@ public class SharedInformerFactory {
 
   private ExecutorService informerExecutor;
 
+  private ApiClient apiClient;
+
   /** Constructor w/ default thread pool. */
   public SharedInformerFactory() {
-    this(Executors.newCachedThreadPool());
+    this(Configuration.getDefaultApiClient(), Executors.newCachedThreadPool());
+  }
+
+  /** Constructor w/ api client specified and default thread pool. */
+  public SharedInformerFactory(ApiClient apiClient) {
+    this(apiClient, Executors.newCachedThreadPool());
   }
 
   /**
@@ -35,6 +43,17 @@ public SharedInformerFactory() {
    * @param threadPool specified thread pool
    */
   public SharedInformerFactory(ExecutorService threadPool) {
+    this(Configuration.getDefaultApiClient(), threadPool);
+  }
+
+  /**
+   * Constructor w/ api client and thread pool specified.
+   *
+   * @param client specific api client
+   * @param threadPool specified thread pool
+   */
+  public SharedInformerFactory(ApiClient client, ExecutorService threadPool) {
+    apiClient = client;
     informerExecutor = threadPool;
     informers = new HashMap<>();
     startedInformers = new HashMap<>();
@@ -87,7 +106,8 @@ private <ApiType, ApiListType> ListerWatcher<ApiType, ApiListType> listerWatcher
       CallGenerator callGenerator,
       Class<ApiType> apiTypeClass,
       Class<ApiListType> apiListTypeClass) {
-    ApiClient apiClient = Configuration.getDefaultApiClient();
+    // set read timeout zero to ensure client doesn't time out
+    apiClient.getHttpClient().setReadTimeout(0, TimeUnit.MILLISECONDS);
     return new ListerWatcher<ApiType, ApiListType>() {
       @Override
       public ApiListType list(CallGeneratorParams params) throws ApiException {