Added example for create StatefulSet from file

seongwon-kang · yue9944882 · seongwon-kang · commit 9f429decd9d2 · 2019-10-23T21:54:22.000+09:00
Update README.md

Co-Authored-By: Min Kim &lt;291271447@qq.com&gt;
diff --git a/README.md b/README.md
@@ -76,6 +76,8 @@ We prepared a few examples for common use-cases which are shown below:
   Patch resource objects in various supported patch formats, equal to `kubectl patch`.
   - [FluentExample](https://github.com/kubernetes-client/java/blob/master/examples/src/main/java/io/kubernetes/client/examples/FluentExample.java): 
   Construct arbitrary resource in a fluent builder style.
+  - [YamlExample](https://github.com/kubernetes-client/java/blob/master/examples/src/main/java/io/kubernetes/client/examples/YamlExample.java): 
+  Suggested way to load or dump resource in Yaml.
 - __Streaming__:
   - [WatchExample](https://github.com/kubernetes-client/java/blob/master/examples/src/main/java/io/kubernetes/client/examples/WatchExample.java): 
   Subscribe watch events from certain resources, equal to `kubectl get <resource> -w`.
diff --git a/examples/src/main/java/io/kubernetes/client/examples/YamlExample.java b/examples/src/main/java/io/kubernetes/client/examples/YamlExample.java
@@ -12,13 +12,20 @@
 */
 package io.kubernetes.client.examples;
 
+import io.kubernetes.client.ApiClient;
 import io.kubernetes.client.ApiException;
+import io.kubernetes.client.Configuration;
+import io.kubernetes.client.apis.CoreV1Api;
 import io.kubernetes.client.custom.IntOrString;
+import io.kubernetes.client.models.V1DeleteOptions;
 import io.kubernetes.client.models.V1Pod;
 import io.kubernetes.client.models.V1PodBuilder;
 import io.kubernetes.client.models.V1Service;
 import io.kubernetes.client.models.V1ServiceBuilder;
+import io.kubernetes.client.models.V1Status;
+import io.kubernetes.client.util.Config;
 import io.kubernetes.client.util.Yaml;
+import java.io.File;
 import java.io.IOException;
 import java.util.HashMap;
 
@@ -67,5 +74,36 @@ public static void main(String[] args) throws IOException, ApiException, ClassNo
             .endSpec()
             .build();
     System.out.println(Yaml.dump(svc));
+
+    // Read yaml configuration file, and deploy it
+    ApiClient client = Config.defaultClient();
+    Configuration.setDefaultApiClient(client);
+
+    //  See issue #474. Not needed at most cases, but it is needed if you are using war
+    //  packging or running this on JUnit.
+    Yaml.addModelMap("v1", "Service", V1Service.class);
+
+    // Example yaml file can be found in $REPO_DIR/test-svc.yaml
+    File file = new File("test-svc.yaml");
+    V1Service yamlSvc = (V1Service) Yaml.load(file);
+
+    // Deployment and StatefulSet is defined in apps/v1, so you should use AppsV1Api instead of
+    // CoreV1API
+    CoreV1Api api = new CoreV1Api();
+    V1Service createResult = api.createNamespacedService("default", yamlSvc, null, null, null);
+
+    System.out.println(createResult);
+
+    V1Status deleteResult =
+        api.deleteNamespacedService(
+            yamlSvc.getMetadata().getName(),
+            "default",
+            null,
+            new V1DeleteOptions(),
+            null,
+            null,
+            null,
+            null);
+    System.out.println(deleteResult);
   }
 }
diff --git a/examples/test-svc.yaml b/examples/test-svc.yaml
@@ -0,0 +1,11 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: test-service
+spec:
+  type: ClusterIP
+  selector:
+    app: test-service
+  ports:
+  - name: port-of-container
+    port: 8080
