Merge pull request #1255 from brendandburns/delete

Add kubectl delete.

Author: k8s-ci-robot

examples/src/main/java/io/kubernetes/client/examples/KubectlExample.java

@@ -15,6 +15,7 @@
 import static io.kubernetes.client.extended.kubectl.Kubectl.apiResources;
 import static io.kubernetes.client.extended.kubectl.Kubectl.copy;
 import static io.kubernetes.client.extended.kubectl.Kubectl.cordon;
+import static io.kubernetes.client.extended.kubectl.Kubectl.delete;
 import static io.kubernetes.client.extended.kubectl.Kubectl.drain;
 import static io.kubernetes.client.extended.kubectl.Kubectl.exec;
 import static io.kubernetes.client.extended.kubectl.Kubectl.label;
@@ -107,7 +108,10 @@ public static void main(String[] args)
     String name = null;
 
     switch (verb) {
-        // TODO: add support for create and replace here.
+      case "delete":
+        kind = args[1];
+        name = args[2];
+        delete(getClassForKind(kind)).namespace(ns).name(name).execute();
       case "drain":
         name = args[1];
         drain().apiClient(client).name(name).execute();

extended/src/main/java/io/kubernetes/client/extended/kubectl/Kubectl.java

@@ -52,6 +52,11 @@ public static KubectlCreate create() {
     return new KubectlCreate();
   }
 
+  public static <ApiType extends KubernetesObject> KubectlDelete<ApiType> delete(
+      Class<ApiType> clazz) {
+    return new KubectlDelete<ApiType>(clazz);
+  }
+
   public static <ApiType extends KubernetesObject> KubectlReplace<ApiType> replace(
       Class<ApiType> clazz) {
     return new KubectlReplace<ApiType>(clazz);

extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlDelete.java

@@ -0,0 +1,75 @@
+/*
+Copyright 2020 The Kubernetes Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+package io.kubernetes.client.extended.kubectl;
+
+import io.kubernetes.client.common.KubernetesObject;
+import io.kubernetes.client.extended.kubectl.exception.KubectlException;
+import io.kubernetes.client.openapi.ApiException;
+import io.kubernetes.client.util.ModelMapper;
+import org.apache.commons.lang.StringUtils;
+
+public class KubectlDelete<ApiType extends KubernetesObject>
+    extends Kubectl.ResourceBuilder<ApiType, KubectlDelete<ApiType>>
+    implements Kubectl.Executable<ApiType> {
+
+  KubectlDelete(Class<ApiType> apiTypeClass) {
+    super(apiTypeClass);
+  }
+
+  @Override
+  public ApiType execute() throws KubectlException {
+    verifyArguments();
+    refreshDiscovery();
+
+    if (isNamespaced(apiTypeClass)) {
+      try {
+        return getGenericApi()
+            .delete(namespace, name)
+            .onFailure(
+                errorStatus -> {
+                  throw new ApiException(errorStatus.toString());
+                })
+            .getObject();
+      } catch (ApiException e) {
+        throw new KubectlException(e);
+      }
+    } else {
+      try {
+        return getGenericApi()
+            .delete(name)
+            .onFailure(
+                errorStatus -> {
+                  throw new ApiException(errorStatus.toString());
+                })
+            .getObject();
+      } catch (ApiException e) {
+        throw new KubectlException(e);
+      }
+    }
+  }
+
+  public boolean isNamespaced(Class<ApiType> apiTypeClass) {
+    Boolean isNamespaced = ModelMapper.isNamespaced(apiTypeClass);
+    if (isNamespaced == null) { // unknown
+      return false;
+    }
+
+    return isNamespaced || !StringUtils.isEmpty(namespace);
+  }
+
+  private void verifyArguments() throws KubectlException {
+    if (null == name) {
+      throw new KubectlException("missing name argument");
+    }
+  }
+}