support start informer factory from a controller-manager

Author: yue9944882

examples/src/main/java/io/kubernetes/client/examples/ControllerExample.java

@@ -86,7 +86,9 @@ public static void main(String[] args) throws IOException {
 
     // Use builder library to manage one or multiple controllers.
     ControllerManager controllerManager =
-        ControllerBuilder.controllerManagerBuilder().addController(controller).build();
+        ControllerBuilder.controllerManagerBuilder(informerFactory)
+            .addController(controller)
+            .build();
 
     LeaderElectingController leaderElectingController =
         new LeaderElectingController(

extended/src/main/java/io/kubernetes/client/extended/controller/ControllerManager.java

@@ -1,24 +1,30 @@
 package io.kubernetes.client.extended.controller;
 
+import io.kubernetes.client.informer.SharedInformerFactory;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/** The type Controller manager manages a set of controllers' lifecycle. */
+/**
+ * The type Controller manager manages a set of controllers' lifecycle and also their informer
+ * factory.
+ */
 public class ControllerManager implements Controller {
   private static final Logger log = LoggerFactory.getLogger(DefaultController.class);
   private Controller[] controllers;
   private ExecutorService controllerThreadPool;
+  private SharedInformerFactory informerFactory;
 
   /**
    * Instantiates a new Controller manager.
    *
    * @param controllers the controllers to be managed.
    */
-  public ControllerManager(Controller... controllers) {
+  public ControllerManager(SharedInformerFactory factory, Controller... controllers) {
     this.controllers = controllers;
+    this.informerFactory = factory;
   }
 
   @Override
@@ -29,13 +35,15 @@ public void shutdown() {
     if (controllerThreadPool != null) {
       this.controllerThreadPool.shutdown();
     }
+    this.informerFactory.stopAllRegisteredInformers();
   }
 
   @Override
   public void run() {
     if (controllers.length == 0) {
       throw new RuntimeException("no controller registered in the manager..");
     }
+    this.informerFactory.startAllRegisteredInformers();
     CountDownLatch latch = new CountDownLatch(controllers.length);
     this.controllerThreadPool = Executors.newFixedThreadPool(controllers.length);
     for (Controller controller : this.controllers) {

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

@@ -19,9 +19,10 @@ public static DefaultControllerBuilder defaultBuilder(SharedInformerFactory fact
   /**
    * Controller manager builder is for building controller-manager .
    *
+   * @param factory the informer factory
    * @return the controller mananger builder
    */
-  public static ControllerManangerBuilder controllerManagerBuilder() {
-    return new ControllerManangerBuilder();
+  public static ControllerManangerBuilder controllerManagerBuilder(SharedInformerFactory factory) {
+    return new ControllerManangerBuilder(factory);
   }
 }

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

@@ -2,14 +2,18 @@
 
 import io.kubernetes.client.extended.controller.Controller;
 import io.kubernetes.client.extended.controller.ControllerManager;
+import io.kubernetes.client.informer.SharedInformerFactory;
 import java.util.ArrayList;
 import java.util.List;
 
 /** The type Controller mananger builder. */
 public class ControllerManangerBuilder {
 
+  private SharedInformerFactory informerFactory;
+
   /** Instantiates a new Controller mananger builder. */
-  ControllerManangerBuilder() {
+  ControllerManangerBuilder(SharedInformerFactory factory) {
+    this.informerFactory = factory;
     this.controllerList = new ArrayList<>();
   }
 
@@ -32,6 +36,7 @@ public ControllerManangerBuilder addController(Controller controller) {
    * @return the controller manager
    */
   public ControllerManager build() {
-    return new ControllerManager(controllerList.stream().toArray(Controller[]::new));
+    return new ControllerManager(
+        informerFactory, controllerList.stream().toArray(Controller[]::new));
   }
 }

extended/src/test/java/io/kubernetes/client/extended/controller/ControllerManagerTest.java

@@ -2,6 +2,7 @@
 
 import static org.junit.Assert.*;
 
+import io.kubernetes.client.informer.SharedInformerFactory;
 import org.junit.Test;
 
 public class ControllerManagerTest {
@@ -11,7 +12,7 @@ public void testControllerStartShutdown() {
     DummyController dummy1 = new DummyController();
     DummyController dummy2 = new DummyController();
 
-    ControllerManager cm = new ControllerManager(dummy1, dummy2);
+    ControllerManager cm = new ControllerManager(new SharedInformerFactory(), dummy1, dummy2);
 
     cm.run();
     assertTrue(dummy1.started);

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

@@ -79,7 +79,7 @@ public synchronized <ApiType, ApiListType> SharedIndexInformer<ApiType> sharedIn
     SharedIndexInformer<ApiType> informer =
         new DefaultSharedIndexInformer<ApiType, ApiListType>(
             apiTypeClass, listerWatcher, resyncPeriodInMillis);
-    this.informers.put(TypeToken.get(apiTypeClass).getType(), informer);
+    this.informers.putIfAbsent(TypeToken.get(apiTypeClass).getType(), informer);
     return informer;
   }