add some functions

Author: syswu

README.md

@@ -45,7 +45,7 @@ Add this dependency to your project's POM:
 <dependency>
   <groupId>io.github.kubesys</groupId>
   <artifactId>client-java</artifactId>
-  <version>1.0.1</version> 
+  <version>1.0.2</version> 
 </dependency>
 
 <repositories>

pom.xml

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

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

@@ -109,7 +109,18 @@ private KubernetesConstants() {
 
 	public static final String KUBE_KIND                    = "kind";
 
-	public static final String BINDING_KIND                 = "Binding";
+	
+	/*************************************
+	 * 
+	 * Kubernetes json structure
+	 * 
+	 *************************************/
+	
+	public static final String KUBD_KIND_BINDING                       = "Binding";
+	
+	public static final String KUBD_FULLKIND_CUSTOMRESOURCEDEFINITION  = "apiextensions.k8s.io.CustomResourceDefinition";
+	
+	public static final String KUBE_DEFAULT_KIND_VERBS                 = "[\"create\", \"delete\", \"deletecollection\", \"get\", \"list\", \"patch\", \"update\", \"watch\"]";
 
 	public static final String KUBE_APIVERSION_SPLIT        = "/";
 

src/main/java/io/github/kubesys/client/utils/KubeUtil.java

@@ -38,7 +38,7 @@ public static JsonNode toBinding(String podName, String podNamespace, String hos
 
 		ObjectNode binding = new ObjectMapper().createObjectNode();
 		binding.put(KubernetesConstants.KUBE_APIVERSION, KubernetesConstants.DEFAULT_APIVERSION);
-		binding.put(KubernetesConstants.KUBE_KIND, KubernetesConstants.BINDING_KIND);
+		binding.put(KubernetesConstants.KUBE_KIND, KubernetesConstants.KUBD_KIND_BINDING);
 
 		ObjectNode metadata = new ObjectMapper().createObjectNode();
 		metadata.put(KubernetesConstants.KUBE_METADATA_NAME, podName);
@@ -54,6 +54,68 @@ public static JsonNode toBinding(String podName, String podNamespace, String hos
 		return binding;
 	}
 
+	/**
+	 * json必须符合Kubernetes的CRD规范，这里不考虑异常情况
+	 * https://kubernetes.io/docs/concepts/overview/working-with-objects/
+	 * 
+	 * @param crd Kubernetes的CRD
+	 * @return 其中一个APIVERSION
+	 */
+	public static String getCrdApiversion(JsonNode crd) {
+		String group = crd.get(KubernetesConstants.KUBE_SPEC)
+						.get(KubernetesConstants.KUBE_SPEC_GROUP)
+						.asText();
+		String version = crd.get(KubernetesConstants.KUBE_SPEC)
+						.get(KubernetesConstants.KUBE_SPEC_VERSIONS)
+						.get(0)
+						.get(KubernetesConstants.KUBE_SPEC_VERSIONS_NAME)
+						.asText();
+		
+		return group + KubernetesConstants.KUBE_VALUE_SPLIT + version;
+	}
+	
+	/**
+	 * json必须符合Kubernetes的CRD规范，这里不考虑异常情况
+	 * https://kubernetes.io/docs/concepts/overview/working-with-objects/
+	 * 
+	 * @param crd Kubernetes的CRD
+	 * @return kind
+	 */
+	public static String getCrdKind(JsonNode crd) {
+		return crd.get(KubernetesConstants.KUBE_SPEC)
+						.get(KubernetesConstants.KUBE_SPEC_NAMES)
+						.get(KubernetesConstants.KUBE_SPEC_NAMES_KIND)
+						.asText();
+	}
+	
+	/**
+	 * json必须符合Kubernetes的CRD规范，这里不考虑异常情况
+	 * https://kubernetes.io/docs/concepts/overview/working-with-objects/
+	 * 
+	 * @param crd Kubernetes的CRD
+	 * @return kind
+	 */
+	public static String getCrdPlural(JsonNode crd) {
+		return crd.get(KubernetesConstants.KUBE_SPEC)
+						.get(KubernetesConstants.KUBE_SPEC_NAMES)
+						.get(KubernetesConstants.KUBE_SPEC_NAMES_PLURAL)
+						.asText();
+	}
+	
+	/**
+	 * json必须符合Kubernetes规范，这里不考虑异常情况
+	 * https://kubernetes.io/docs/concepts/overview/working-with-objects/
+	 * 
+	 * @param json Kubernetes对应kind的apiVersion
+	 * @return fullkind
+	 */
+	public static String getFullkind(JsonNode json) {
+		String group = getGroup(json);
+		String kind  = getKind(json);
+		return group.length() == 0 ? kind : group + 
+				KubernetesConstants.KUBE_VALUE_SPLIT + kind;
+	}
+	
 	/**
 	 * 不考虑apiVersion为空或者不符合Kuberneres资源定义的的情况
 	 * 否则抛出异常
@@ -80,6 +142,19 @@ public static String getName(JsonNode json) {
 		return json.get(KubernetesConstants.KUBE_METADATA).get(KubernetesConstants.KUBE_METADATA_NAME).asText();
 	}
 
+	
+	/**
+	 * 不考虑json为空或者不符合Kuberneres资源定义的的情况
+	 * 否则抛出异常
+	 * https://kubernetes.io/docs/concepts/overview/working-with-objects/
+	 * 
+	 * @param json   json
+	 * @return      获得kubernetes的kind
+	 */
+	public static String getKind(JsonNode json) {
+		return json.get(KubernetesConstants.KUBE_KIND).asText();
+	}
+	
 	/**
 	 * 不考虑json为空或者不符合Kuberneres资源定义的的情况
 	 * 否则抛出异常

src/test/java/io/github/kubesys/client/testcases/WatchKindTest.java

@@ -44,7 +44,7 @@ public void doClose() {
 			}
 
 		};
-		client.watchResources("Pod", KubernetesConstants.VALUE_ALL_NAMESPACES, watcher);
+		client.watchResources("apiextensions.k8s.io.CustomResourceDefinition", KubernetesConstants.VALUE_ALL_NAMESPACES, watcher);
 		// or
 //		client.watchResources("apps.Deployment", KubernetesConstants.VALUE_ALL_NAMESPACES, watcher);