Merge pull request #1256 from brendandburns/replace

Add kubectl replace.

Author: k8s-ci-robot

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

@@ -107,6 +107,7 @@ public static void main(String[] args)
     String name = null;
 
     switch (verb) {
+        // TODO: add support for create and replace here.
       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> KubectlReplace<ApiType> replace(
+      Class<ApiType> clazz) {
+    return new KubectlReplace<ApiType>(clazz);
+  }
+
   /**
    * Equivalent for `kubectl apply`
    *

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

@@ -0,0 +1,91 @@
+/*
+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 io.kubernetes.client.util.generic.options.UpdateOptions;
+import org.apache.commons.lang.StringUtils;
+
+public class KubectlReplace<ApiType extends KubernetesObject>
+    extends Kubectl.ResourceBuilder<ApiType, KubectlReplace<ApiType>>
+    implements Kubectl.Executable<ApiType> {
+  ApiType updateObject;
+  UpdateOptions options;
+
+  KubectlReplace(Class<ApiType> apiTypeClass) {
+    super(apiTypeClass);
+  }
+
+  public KubectlReplace<ApiType> resource(ApiType resource) {
+    this.updateObject = resource;
+    return this;
+  }
+
+  public KubectlReplace<ApiType> options(UpdateOptions options) {
+    this.options = options;
+    return this;
+  }
+
+  @Override
+  public ApiType execute() throws KubectlException {
+    verifyArguments();
+    refreshDiscovery();
+
+    if (isNamespaced(apiTypeClass)) {
+      try {
+        return getGenericApi()
+            .update(updateObject, options)
+            .onFailure(
+                errorStatus -> {
+                  throw new ApiException(errorStatus.toString());
+                })
+            .getObject();
+      } catch (ApiException e) {
+        throw new KubectlException(e);
+      }
+    } else {
+      try {
+        return getGenericApi()
+            .update(updateObject, options)
+            .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");
+    }
+    if (null == updateObject) {
+      throw new KubectlException("missing new resource");
+    }
+  }
+}