feat(vke): add example

Author: xpofei

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/CreateCluster.java

@@ -0,0 +1,88 @@
+package com.volcengine.vke.example;
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.*;
+
+import java.util.Collections;
+
+public class CreateCluster {
+    public static String Call(VkeApi vkeApi, final Option opt) throws ApiException {
+        CreateClusterRequest request = new CreateClusterRequest().
+                clusterConfig(new ClusterConfigForCreateClusterInput().
+                        apiServerPublicAccessEnabled(false).
+                        subnetIds(Collections.singletonList(opt.getSubnetID()))
+                ).
+                name(opt.getClusterName()).
+                podsConfig(new PodsConfigForCreateClusterInput().
+                        podNetworkMode(opt.getNetworkMode())).
+                servicesConfig(new ServicesConfigForCreateClusterInput().
+                        serviceCidrsv4(Collections.singletonList(opt.getServiceCidr())));
+
+        if (opt.getNetworkMode() == PodsConfigForCreateClusterInput.PodNetworkModeEnum.FLANNEL) {
+            request.getPodsConfig().flannelConfig(new FlannelConfigForCreateClusterInput().
+                    podCidrs(Collections.singletonList(opt.getPodCidr())).
+                    maxPodsPerNode(64));
+        } else if (opt.getNetworkMode() == PodsConfigForCreateClusterInput.PodNetworkModeEnum.VPCCNISHARED) {
+            request.getPodsConfig().vpcCniConfig(new VpcCniConfigForCreateClusterInput().
+                    subnetIds(Collections.singletonList(opt.getSubnetID())));
+        }
+
+        CreateClusterResponse response = vkeApi.createCluster(request);
+        return response.getId();
+    }
+
+    public static class Option {
+        private String clusterName;
+        private String subnetID;
+        private String podCidr;
+        private String serviceCidr;
+        private PodsConfigForCreateClusterInput.PodNetworkModeEnum networkMode;
+
+        public String getClusterName() {
+            return clusterName;
+        }
+
+        public Option setClusterName(String clusterName) {
+            this.clusterName = clusterName;
+            return this;
+        }
+
+        public String getSubnetID() {
+            return subnetID;
+        }
+
+        public Option setSubnetID(String subnetID) {
+            this.subnetID = subnetID;
+            return this;
+        }
+
+        public String getPodCidr() {
+            return podCidr;
+        }
+
+        public Option setPodCidr(String podCidr) {
+            this.podCidr = podCidr;
+            return this;
+        }
+
+        public String getServiceCidr() {
+            return serviceCidr;
+        }
+
+        public Option setServiceCidr(String serviceCidr) {
+            this.serviceCidr = serviceCidr;
+            return this;
+        }
+
+        public PodsConfigForCreateClusterInput.PodNetworkModeEnum getNetworkMode() {
+            return networkMode;
+        }
+
+        public Option setNetworkMode(PodsConfigForCreateClusterInput.PodNetworkModeEnum networkMode) {
+            this.networkMode = networkMode;
+            return this;
+        }
+
+    }
+}

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/CreateNodePool.java

@@ -0,0 +1,80 @@
+package com.volcengine.vke.example;
+
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.*;
+
+import java.util.Collections;
+
+public class CreateNodePool {
+    public static String Call(VkeApi vkeApi, final Option opt) throws ApiException {
+        CreateNodePoolRequest request = new CreateNodePoolRequest().
+                clusterId(opt.getClusterId()).
+                name(opt.getNodePoolName()).
+                nodeConfig(new NodeConfigForCreateNodePoolInput().
+                        systemVolume(new SystemVolumeForCreateNodePoolInput().
+                                size(40).
+                                type(SystemVolumeForCreateNodePoolInput.TypeEnum.ESSD_PL0)).
+                        instanceTypeIds(Collections.singletonList(opt.getInstanceType())).
+                        security(new SecurityForCreateNodePoolInput().
+                                login(new LoginForCreateNodePoolInput().password(opt.getPassword()))).
+                        subnetIds(Collections.singletonList(opt.getSubnetID())));
+
+        CreateNodePoolResponse response = vkeApi.createNodePool(request);
+        return response.getId();
+    }
+
+    public static class Option {
+        private String clusterId;
+        private String nodePoolName;
+        private String instanceType;
+        private String password;
+        private String subnetID;
+
+        public String getClusterId() {
+            return clusterId;
+        }
+
+        public Option setClusterId(String clusterId) {
+            this.clusterId = clusterId;
+            return this;
+        }
+
+        public String getNodePoolName() {
+            return nodePoolName;
+        }
+
+        public Option setNodePoolName(String nodePoolName) {
+            this.nodePoolName = nodePoolName;
+            return this;
+        }
+
+        public String getInstanceType() {
+            return instanceType;
+        }
+
+        public Option setInstanceType(String instanceType) {
+            this.instanceType = instanceType;
+            return this;
+        }
+
+        public String getPassword() {
+            return password;
+        }
+
+        public Option setPassword(String password) {
+            this.password = password;
+            return this;
+        }
+
+        public String getSubnetID() {
+            return subnetID;
+        }
+
+        public Option setSubnetID(String subnetID) {
+            this.subnetID = subnetID;
+            return this;
+        }
+    }
+}

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/GetCluster.java

@@ -0,0 +1,43 @@
+package com.volcengine.vke.example;
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.FilterForListClustersInput;
+import com.volcengine.vke.model.ItemForListClustersOutput;
+import com.volcengine.vke.model.ListClustersRequest;
+import com.volcengine.vke.model.ListClustersResponse;
+
+import java.util.Collections;
+
+public class GetCluster {
+    public static ItemForListClustersOutput Call(VkeApi vkeApi, final Option opt) throws ApiException, ItemsCountException {
+        ListClustersRequest request = new ListClustersRequest()
+                .filter(new FilterForListClustersInput()
+                        .ids(Collections.singletonList(opt.getClusterId())));
+
+        ListClustersResponse response = vkeApi.listClusters(request);
+        if (response.getItems().size() != 1) {
+            throw new ItemsCountException("get cluster resp items must be 1");
+        }
+        return response.getItems().get(0);
+    }
+
+    public static class Option {
+        private String clusterId;
+
+        public String getClusterId() {
+            return clusterId;
+        }
+
+        public Option setClusterId(String clusterId) {
+            this.clusterId = clusterId;
+            return this;
+        }
+    }
+
+    static class ItemsCountException extends Exception {
+        public ItemsCountException(String msg) {
+            super(msg);
+        }
+    }
+}

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/GetNodePool.java

@@ -0,0 +1,43 @@
+package com.volcengine.vke.example;
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.FilterForListNodePoolsInput;
+import com.volcengine.vke.model.ItemForListNodePoolsOutput;
+import com.volcengine.vke.model.ListNodePoolsRequest;
+import com.volcengine.vke.model.ListNodePoolsResponse;
+
+import java.util.Collections;
+
+public class GetNodePool {
+    public static ItemForListNodePoolsOutput Call(VkeApi vkeApi, final Option opt) throws ApiException, ItemsCountException {
+        ListNodePoolsRequest request = new ListNodePoolsRequest()
+                .filter(new FilterForListNodePoolsInput()
+                        .ids(Collections.singletonList(opt.getNodePoolId())));
+
+        ListNodePoolsResponse response = vkeApi.listNodePools(request);
+        if (response.getItems().size() != 1) {
+            throw new ItemsCountException("get node pool resp items must be 1");
+        }
+        return response.getItems().get(0);
+    }
+
+    public static class Option {
+        private String nodePoolId;
+
+        public String getNodePoolId() {
+            return nodePoolId;
+        }
+
+        public Option setNodePoolId(String nodePoolId) {
+            this.nodePoolId = nodePoolId;
+            return this;
+        }
+    }
+
+    static class ItemsCountException extends Exception {
+        public ItemsCountException(String msg) {
+            super(msg);
+        }
+    }
+}

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/InstallAddon.java

@@ -0,0 +1,36 @@
+package com.volcengine.vke.example;
+
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.CreateAddonRequest;
+
+public class InstallAddon {
+    public static void Call(VkeApi vkeApi, final Option opt) throws ApiException, InterruptedException {
+        vkeApi.createAddon(new CreateAddonRequest().
+                clusterId(opt.clusterId).
+                name("metrics-server"));
+        Thread.sleep(5 * 1000);
+        vkeApi.createAddon(new CreateAddonRequest().
+                clusterId(opt.clusterId).
+                name("core-dns"));
+        Thread.sleep(5 * 1000);
+        vkeApi.createAddon(new CreateAddonRequest().
+                clusterId(opt.clusterId).
+                name("cluster-autoscaler").
+                config("{\"Expander\":\"random\"}"));
+    }
+
+    public static class Option {
+        private String clusterId;
+
+        public String getClusterId() {
+            return clusterId;
+        }
+
+        public Option setClusterId(String clusterId) {
+            this.clusterId = clusterId;
+            return this;
+        }
+    }
+}

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/ListNodes.java

@@ -0,0 +1,33 @@
+package com.volcengine.vke.example;
+
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.FilterForListNodesInput;
+import com.volcengine.vke.model.ListNodesRequest;
+import com.volcengine.vke.model.ListNodesResponse;
+
+import java.util.Collections;
+
+public class ListNodes {
+    public static ListNodesResponse Call(VkeApi vkeApi, final Option opt) throws ApiException {
+        ListNodesRequest request = new ListNodesRequest()
+                .filter(new FilterForListNodesInput()
+                        .nodePoolIds(Collections.singletonList(opt.getNodePoolId())));
+
+        return vkeApi.listNodes(request);
+    }
+
+    public static class Option {
+        private String nodePoolId;
+
+        public String getNodePoolId() {
+            return nodePoolId;
+        }
+
+        public Option setNodePoolId(String nodePoolId) {
+            this.nodePoolId = nodePoolId;
+            return this;
+        }
+    }
+}

volcengine-java-sdk-vke/src/main/java/com/volcengine/vke/example/UpdateNodePool.java

@@ -0,0 +1,51 @@
+package com.volcengine.vke.example;
+
+import com.volcengine.ApiException;
+import com.volcengine.vke.VkeApi;
+import com.volcengine.vke.model.AutoScalingForUpdateNodePoolConfigInput;
+import com.volcengine.vke.model.UpdateNodePoolConfigRequest;
+
+public class UpdateNodePool {
+    public static void Call(VkeApi vkeApi, final Option opt) throws ApiException {
+        Integer num = opt.autoScaling ? 0 : 1;
+        vkeApi.updateNodePoolConfig(new UpdateNodePoolConfigRequest().
+                clusterId(opt.getClusterId()).
+                id(opt.getNodePoolId()).
+                autoScaling(new AutoScalingForUpdateNodePoolConfigInput().
+                        enabled(opt.isAutoScaling()).
+                        desiredReplicas(num)));
+    }
+
+    public static class Option {
+        private String clusterId;
+        private String nodePoolId;
+        private Boolean autoScaling;
+
+        public String getClusterId() {
+            return clusterId;
+        }
+
+        public Option setClusterId(String clusterId) {
+            this.clusterId = clusterId;
+            return this;
+        }
+
+        public String getNodePoolId() {
+            return nodePoolId;
+        }
+
+        public Option setNodePoolId(String nodePoolId) {
+            this.nodePoolId = nodePoolId;
+            return this;
+        }
+
+        public Boolean isAutoScaling() {
+            return autoScaling;
+        }
+
+        public Option setAutoScaling(Boolean autoScaling) {
+            this.autoScaling = autoScaling;
+            return this;
+        }
+    }
+}