replace in old example

Author: mingjie-li

examples/src/main/java/io/kubernetes/client/examples/spring/SpringControllerExample.java renamed to examples/src/main/java/io/kubernetes/client/examples/SpringControllerExample.java

@@ -10,7 +10,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 */
-package io.kubernetes.client.examples.spring;
+package io.kubernetes.client.examples;
 
 import io.kubernetes.client.extended.controller.Controller;
 import io.kubernetes.client.extended.controller.reconciler.Reconciler;
@@ -25,17 +25,20 @@
 import io.kubernetes.client.openapi.models.V1Pod;
 import io.kubernetes.client.openapi.models.V1PodList;
 import io.kubernetes.client.spring.extended.controller.KubernetesInformerConfigurer;
-import io.kubernetes.client.spring.extended.controller.KubernetesReconcilerConfigurer;
 import io.kubernetes.client.spring.extended.controller.annotation.*;
+import io.kubernetes.client.spring.extended.controller.factory.KubernetesControllerFactory;
 import io.kubernetes.client.util.ClientBuilder;
 import java.io.IOException;
 import java.time.Duration;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
 
 @SpringBootApplication
 public class SpringControllerExample {
@@ -68,11 +71,11 @@ public KubernetesInformerConfigurer kubernetesInformerConfigurer(ApiClient apiCl
     }
 
     // *REQUIRED*
-    // Configurer components that registers reconciler to the controller-manager in the context.
-    @Bean
-    public KubernetesReconcilerConfigurer kubernetesReconcilerConfigurer(
-        SharedInformerFactory sharedInformerFactory) {
-      return new KubernetesReconcilerConfigurer(sharedInformerFactory);
+    // factorybean to crete controller
+    @Bean("node-printing-controller")
+    public KubernetesControllerFactory kubernetesReconcilerConfigurer(
+        SharedInformerFactory sharedInformerFactory, Reconciler reconciler) {
+      return new KubernetesControllerFactory(sharedInformerFactory, reconciler);
     }
 
     // *OPTIONAL*
@@ -91,12 +94,6 @@ public ApiClient myApiClient() throws IOException {
     public SharedInformerFactory sharedInformerFactory() {
       return new MySharedInformerFactory();
     }
-
-    @Bean
-    public NodePrintingReconciler nodePrintingReconciler(
-        Lister<V1Pod> podLister, Lister<V1Node> nodeLister, SharedInformer<V1Node> nodeInformer) {
-      return new NodePrintingReconciler(podLister, nodeLister, nodeInformer);
-    }
   }
 
   @KubernetesInformers({ // Defining what resources is the informer-factory actually watching.
@@ -128,32 +125,33 @@ public static class MySharedInformerFactory extends SharedInformerFactory {}
                 resyncPeriodMillis = 60 * 1000L // fully resync every 1 minute
                 ),
           }))
+  @Component
   public static class NodePrintingReconciler implements Reconciler {
 
-    public NodePrintingReconciler(
-        Lister<V1Pod> podLister, Lister<V1Node> nodeLister, SharedInformer<V1Node> nodeInformer) {
-      this.nodeLister = nodeLister;
-      this.podLister = podLister;
-      this.nodeInformer = nodeInformer;
-    }
+    @Value("${namespace}")
+    private String namespace;
 
-    private SharedInformer<V1Node> nodeInformer;
-
-    private Lister<V1Node> nodeLister;
-
-    private Lister<V1Pod> podLister;
+    @Autowired private SharedInformer<V1Node> nodeInformer;
+    @Autowired private SharedInformer<V1Pod> podInformer;
+    @Autowired private Lister<V1Node> nodeLister;
+    @Autowired private Lister<V1Pod> podLister;
 
     // *OPTIONAL*
     // If you feed like hold the controller from running util some condition..
-    // need to be a public function
     @KubernetesReconcilerReadyFunc
     public boolean informerReady() {
-      return nodeInformer.hasSynced();
+      return podInformer.hasSynced() && nodeInformer.hasSynced();
     }
 
     @Override
     public Result reconcile(Request request) {
       V1Node node = nodeLister.get(request.getName());
+
+      System.out.println("get all pods in namespace " + namespace);
+      podLister.namespace(namespace).list().stream()
+          .map(pod -> pod.getMetadata().getName())
+          .forEach(System.out::println);
+
       System.out.println("triggered reconciling " + node.getMetadata().getName());
       return new Result(false);
     }