initial implementation for java infomer portal

Author: yue9944882

util/pom.xml

@@ -139,8 +139,8 @@
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
                 <configuration>
-                    <source>1.7</source>
-                    <target>1.7</target>
+                    <source>8</source>
+                    <target>8</target>
                 </configuration>
             </plugin>
             <plugin>

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

@@ -0,0 +1,5 @@
+package io.kubernetes.client.informer;
+
+public interface BasicInformer<T> {
+  SharedIndexInformer<T> informer();
+}

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

@@ -0,0 +1,5 @@
+package io.kubernetes.client.informer;
+
+public interface ClusterScopeInformer<T> extends BasicInformer<T> {
+  ClusterScopeLister<T> lister();
+}

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

@@ -0,0 +1,10 @@
+package io.kubernetes.client.informer;
+
+import java.util.List;
+
+public interface ClusterScopeLister<T> {
+
+  List<T> list();
+
+  T get(String name);
+}

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

@@ -0,0 +1,28 @@
+package io.kubernetes.client.informer;
+
+public enum EventType {
+  ADDED,
+
+  MODIFIED,
+
+  DELETED,
+
+  ERROR;
+
+  /**
+   * getByType returns the corresponding EventType by type.
+   *
+   * @param type specific code
+   * @return corresponding EventType
+   */
+  public static EventType getByType(String type) {
+    if (type != null && type.length() > 0) {
+      for (EventType eventType : EventType.values()) {
+        if (eventType.name().equalsIgnoreCase(type)) {
+          return eventType;
+        }
+      }
+    }
+    return null;
+  }
+}

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

@@ -0,0 +1,14 @@
+package io.kubernetes.client.informer;
+
+import java.util.List;
+
+public interface Lister<T> {
+
+  List<T> list();
+
+  T get(String name);
+
+  List<T> list(String namespace);
+
+  T get(String namespace, String name);
+}

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

@@ -0,0 +1,12 @@
+package io.kubernetes.client.informer;
+
+import io.kubernetes.client.ApiException;
+import io.kubernetes.client.util.Watch;
+import java.util.Map;
+
+public interface ListerWatcher<T> {
+
+  ResourceList<T> list(Map<String, Object> params) throws ApiException;
+
+  Watch<T> watch(Map<String, Object> params) throws ApiException;
+}

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

@@ -0,0 +1,5 @@
+package io.kubernetes.client.informer;
+
+public interface NamespacedInformer<T> extends BasicInformer<T> {
+  NamespacedLister<T> lister();
+}

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

@@ -0,0 +1,10 @@
+package io.kubernetes.client.informer;
+
+import java.util.List;
+
+public interface NamespacedLister<T> {
+
+  List<T> list(String namespace);
+
+  T get(String namespace, String name);
+}

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

@@ -0,0 +1,10 @@
+package io.kubernetes.client.informer;
+
+public interface ResourceEventHandler<T> {
+
+  void onAdd(T obj);
+
+  void onUpdate(T oldObj, T newObj);
+
+  void onDelete(T obj);
+}

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

@@ -0,0 +1,35 @@
+package io.kubernetes.client.informer;
+
+import io.kubernetes.client.ApiResponse;
+import io.kubernetes.client.models.V1ListMeta;
+import java.lang.reflect.Method;
+import java.util.List;
+
+public class ResourceList<T> {
+
+  private Object listObject;
+
+  public <T> ResourceList(ApiResponse<T> apiResponse) {
+    listObject = apiResponse.getData();
+  }
+
+  public List<T> getItems() {
+    try {
+      Method getItemsMethod = listObject.getClass().getMethod("getItems");
+      return (List<T>) getItemsMethod.invoke(listObject);
+    } catch (Exception e) {
+      e.printStackTrace();
+      throw new RuntimeException(e);
+    }
+  }
+
+  public V1ListMeta getListMeta() {
+    try {
+      Method getItemsMethod = listObject.getClass().getMethod("getMetadata");
+      return (V1ListMeta) getItemsMethod.invoke(listObject);
+    } catch (Exception e) {
+      e.printStackTrace();
+      throw new RuntimeException(e);
+    }
+  }
+}

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

@@ -0,0 +1,32 @@
+package io.kubernetes.client.informer;
+
+import io.kubernetes.client.informer.cache.Store;
+import io.kubernetes.client.informer.cache.function.ResyncFunc;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ResyncRunnable<T> implements Runnable {
+
+  private static final Logger log = LoggerFactory.getLogger(ResyncRunnable.class);
+
+  private Store store;
+  private ResyncFunc resyncFunc;
+
+  public ResyncRunnable(Store<T> store, ResyncFunc resyncFunc) {
+    this.store = store;
+    this.resyncFunc = resyncFunc;
+  }
+
+  public void run() {
+    if (log.isDebugEnabled()) {
+      log.debug("ResyncRunnable#resync ticker tick");
+    }
+
+    if (resyncFunc == null || resyncFunc.shouldResync()) {
+      if (log.isDebugEnabled()) {
+        log.debug("ResyncRunnable#force resync");
+      }
+      this.store.resync();
+    }
+  }
+}

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

@@ -0,0 +1,22 @@
+package io.kubernetes.client.informer;
+
+import io.kubernetes.client.informer.cache.Indexer;
+import io.kubernetes.client.informer.cache.function.IndexFunc;
+import java.util.Map;
+
+public interface SharedIndexInformer<T> extends SharedInformer<T> {
+
+  /**
+   * Add indexers.
+   *
+   * @param indexers the indexers
+   */
+  void addIndexers(Map<String, IndexFunc> indexers);
+
+  /**
+   * getIndexer returns the internal indexer store.
+   *
+   * @return the internal indexer store
+   */
+  Indexer<T> getIndexer();
+}

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

@@ -0,0 +1,40 @@
+package io.kubernetes.client.informer;
+
+public interface SharedInformer<T> {
+
+  /**
+   * Add event handler.
+   *
+   * @param handler the handler
+   */
+  void addEventHandler(ResourceEventHandler<T> handler);
+
+  /**
+   * addEventHandlerWithResyncPeriod adds an event handler to the shared informer using the
+   * specified resync period. Events to a single handler are delivered sequentially, but there is no
+   * coordination between different handlers.
+   *
+   * @param handler the event handler
+   * @param resyncPeriod the specific resync period
+   */
+  void addEventHandlerWithResyncPeriod(ResourceEventHandler<T> handler, long resyncPeriod);
+
+  /** run starts the shared informer, which will be stopped until stop() is called. */
+  void run();
+
+  /** stop stops the shared informer. */
+  void stop();
+
+  /** hasSynced returns true if the shared informer's store has synced. */
+  boolean hasSynced();
+
+  /**
+   * Last sync resource version string.
+   *
+   * @return the string
+   */
+  // LastSyncResourceVersion is the resource version observed when last synced with the underlying
+  // store. The value returned is not synchronized with access to the underlying store and is not
+  // thread-safe.
+  String lastSyncResourceVersion();
+}