support watchPodsOnLocalNode

Author: syswu

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>io.github.kubesys</groupId>
 	<artifactId>client-java</artifactId>
-	<version>0.9.3</version>
+	<version>0.9.4</version>
 	<packaging>jar</packaging>
 
 	<name>client-java</name>

src/main/java/io/github/kubesys/client/KubernetesClient.java

@@ -11,6 +11,7 @@
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.math.BigInteger;
+import java.net.InetAddress;
 import java.security.KeyFactory;
 import java.security.KeyStore;
 import java.security.KeyStoreException;
@@ -66,8 +67,10 @@
 import io.github.kubesys.client.utils.URLUtil;
 
 /**
- * This class is used for creating a connection between users' application and Kubernetes server.
- * It provides an easy-to-use way to Create, Update, Delete, Get, List and Watch all Kubernetes resources.
+ * Kubernetes的客户端，根据https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.27/的
+ * URL规则生产URL
+ * 
+ * 对于JSON参数，可参见https://kubernetes.io/docs/reference/kubernetes-api/
  * 
  * @author wuheng@iscas.ac.cn
  * @since  2.0.0
@@ -676,6 +679,7 @@ public Thread watchResources(String kind, String namespace, KubernetesWatcher wa
 				+ (namespace == null || "".equals(namespace) ? "all-namespaces" : namespace);
 		return watchResources(watchName, kind, namespace, watcher);
 	}
+	
 
 	/**
 	 * watch a Kubernetes resources using kind, namespace, and WebSocketListener
@@ -694,6 +698,23 @@ public Thread watchResources(String watchName, String kind, String namespace, Ku
 		thread.start();
 		return thread;
 	}
+	
+	/**
+	 * watch a Kubernetes resources using kind, namespace, and WebSocketListener
+	 * 
+	 * @param watcher   watcher
+	 * @return thread thread
+	 * @throws Exception Kubernetes cannot parsing this jsonStr
+	 */
+	public Thread watchPodsOnLocalNode(KubernetesWatcher watcher)
+			throws Exception {
+		String hostname = InetAddress.getLocalHost().getHostName().toLowerCase();
+		watcher.setRequest(ReqUtil.get(requester, analyzer.getConvertor()
+					.watchAllUrlWithFieldSelector("Pod", "", "spec.nodeName=" + hostname)));
+		Thread thread = new Thread(watcher, "watch-pods-by-hostname");
+		thread.start();
+		return thread;
+	}
 
 	/**
 	 * for Scheduler

src/main/java/io/github/kubesys/client/KubernetesConstants.java

@@ -6,6 +6,7 @@
 /**
  * @author wuheng@iscas.ac.cn
  *
+ * 
  */
 public final class KubernetesConstants {
 

src/main/java/io/github/kubesys/client/core/KubernetesConvertor.java

@@ -162,6 +162,19 @@ public String watchAllUrl(String kind, String ns) throws NullPointerException {
 				KubernetesConstants.HTTP_QUERY_WATCHER_ENABLE);
 	}
 
+	/**
+	 * @param kind kind
+	 * @param ns   ns
+	 * @return Url
+	 * @throws NullPointerException exception
+	 */
+	public String watchAllUrlWithFieldSelector(String kind, String ns, String fieldSelector) throws NullPointerException {
+		String fullKind = fullkind(kind);
+		return URLUtil.join(baseUrl(fullKind, ns, true),
+				KubernetesConstants.HTTP_QUERY_WATCHER_ENABLE)
+					+ "&fieldSelector=" + fieldSelector;
+	}
+	
 
 	/*******************************************
 	 * 

src/test/java/io/github/kubesys/client/core/ConvertorTest.java

@@ -214,4 +214,7 @@ void testValidWatchAllUrlURL() {
 		assertEquals("https://39.100.71.73:6443/apis/networking.k8s.io/v1/watch/ingressclasses?watch=true&timeoutSeconds=315360000", convertor.watchAllUrl("networking.k8s.io.IngressClass", ""));
 	}
 
+	public static void main() {
+		
+	}
 }