Merge pull request #1138 from brendandburns/kubectl

Implement Kubectl Log

Author: k8s-ci-robot

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

@@ -14,9 +14,11 @@
 
 import static io.kubernetes.client.extended.kubectl.Kubectl.exec;
 import static io.kubernetes.client.extended.kubectl.Kubectl.label;
+import static io.kubernetes.client.extended.kubectl.Kubectl.log;
 import static io.kubernetes.client.extended.kubectl.Kubectl.scale;
 import static io.kubernetes.client.extended.kubectl.Kubectl.version;
 
+import com.google.common.io.ByteStreams;
 import io.kubernetes.client.common.KubernetesObject;
 import io.kubernetes.client.extended.kubectl.KubectlExec;
 import io.kubernetes.client.extended.kubectl.exception.KubectlException;
@@ -82,6 +84,12 @@ public static void main(String[] args)
     String name = null;
 
     switch (verb) {
+      case "log":
+        name = args[1];
+        ByteStreams.copy(
+            log().name(name).namespace(ns).container(cli.getOptionValue("c", "")).execute(),
+            System.out);
+        System.exit(0);
       case "scale":
         kind = args[1];
         name = args[2];

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

@@ -136,6 +136,25 @@ public static KubectlExec exec() {
     return exec(Configuration.getDefaultApiClient());
   }
 
+  /**
+   * Equivalent for `kubectl log`
+   *
+   * @param apiClient The api client instance
+   * @return the kubectl log operator
+   */
+  public static KubectlLog log(ApiClient apiClient) {
+    return new KubectlLog(apiClient);
+  }
+
+  /**
+   * Equivalent for `kubectl log`
+   *
+   * @return the kubectl log operator
+   */
+  public static KubectlLog log() {
+    return log(Configuration.getDefaultApiClient());
+  }
+
   /**
    * Executable executes a kubectl helper.
    *

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

@@ -0,0 +1,58 @@
+/*
+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 static com.google.common.base.Strings.isNullOrEmpty;
+
+import io.kubernetes.client.PodLogs;
+import io.kubernetes.client.extended.kubectl.exception.KubectlException;
+import io.kubernetes.client.openapi.ApiClient;
+import io.kubernetes.client.openapi.ApiException;
+import io.kubernetes.client.openapi.models.V1Pod;
+import java.io.IOException;
+import java.io.InputStream;
+
+public class KubectlLog extends Kubectl.ResourceAndContainerBuilder<V1Pod, KubectlLog>
+    implements Kubectl.Executable<InputStream> {
+  private InputStream result;
+
+  KubectlLog(ApiClient client) {
+    super(client, V1Pod.class);
+  }
+
+  @Override
+  public InputStream execute() throws KubectlException {
+    validate();
+
+    PodLogs logs = new PodLogs(apiClient);
+    String ns = (this.namespace == null ? "default" : this.namespace);
+    try {
+      return logs.streamNamespacedPodLog(this.name, ns, this.container);
+    } catch (ApiException | IOException ex) {
+      throw new KubectlException(ex);
+    }
+  }
+
+  private void validate() throws KubectlException {
+    StringBuilder msg = new StringBuilder();
+    if (isNullOrEmpty(name)) {
+      msg.append("missing name! ");
+    }
+    if (isNullOrEmpty(container)) {
+      msg.append("missing container!");
+    }
+    if (msg.length() > 0) {
+      throw new KubectlException(msg.toString());
+    }
+  }
+}