Add KubectlLog

Author: brendandburns

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

@@ -14,11 +14,14 @@
 
 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.KubectlLog;
 import io.kubernetes.client.extended.kubectl.exception.KubectlException;
 import io.kubernetes.client.openapi.ApiClient;
 import io.kubernetes.client.openapi.models.V1Deployment;
@@ -82,6 +85,12 @@ public static void main(String[] args)
     String name = null;
 
     switch (verb) {
+      case "log":
+        name = args[1];
+        KubectlLog log = log();
+        log.name(name).namespace(ns).container(cli.getOptionValue("c", "")).execute();
+        ByteStreams.copy(log.stream(), 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,59 @@
+/*
+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.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.V1ObjectMeta;
+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<V1Pod> {
+  private InputStream result;
+
+  KubectlLog(ApiClient client) {
+    super(client, V1Pod.class);
+  }
+
+  public InputStream stream() {
+    return result;
+  }
+
+  @Override
+  public V1Pod execute() throws KubectlException {
+    validate();
+    V1Pod pod = new V1Pod().metadata(new V1ObjectMeta().name(name).namespace(namespace));
+
+    PodLogs logs = new PodLogs(apiClient);
+    String ns = (this.namespace == null ? "default" : this.namespace);
+    try {
+      result = logs.streamNamespacedPodLog(this.name, ns, this.container);
+    } catch (ApiException | IOException ex) {
+      throw new KubectlException(ex);
+    }
+    return pod;
+  }
+
+  private void validate() throws KubectlException {
+    if (name == null || name.length() == 0) {
+      throw new KubectlException("missing name!");
+    }
+    if (container == null || name.length() == 0) {
+      throw new KubectlException("missing container!");
+    }
+  }
+}