Merge pull request #87 from brendandburns/logs

Add an initial logs utility class.

Author: mbohlool

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

@@ -0,0 +1,52 @@
+/*
+Copyright 2017 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.examples;
+
+import io.kubernetes.client.ApiClient;
+import io.kubernetes.client.ApiException;
+import io.kubernetes.client.Configuration;
+import io.kubernetes.client.PodLogs;
+import io.kubernetes.client.apis.CoreV1Api;
+import io.kubernetes.client.models.V1Pod;
+import io.kubernetes.client.models.V1PodList;
+import io.kubernetes.client.util.Config;
+
+import com.google.common.io.ByteStreams;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.IOException;
+import java.io.OutputStream;
+
+/**
+ * A simple example of how to use the Java API
+ * 
+ * Easiest way to run this:
+ *   mvn exec:java -Dexec.mainClass="io.kubernetes.client.examples.LogsExample"
+ * 
+ * From inside $REPO_DIR/examples
+ */
+public class LogsExample {
+    public static void main(String[] args) throws IOException, ApiException, InterruptedException {
+        ApiClient client = Config.defaultClient();
+        Configuration.setDefaultApiClient(client);
+        CoreV1Api coreApi = new CoreV1Api(client);
+
+        PodLogs logs = new PodLogs();
+        V1Pod pod = coreApi.listNamespacedPod("default", "false", null, null, null, null, null, null, null, null).getItems().get(0);
+
+        InputStream is = logs.streamNamespacedPodLog(pod);
+        ByteStreams.copy(is, System.out);
+    }
+}

util/src/main/java/io/kubernetes/client/PodLogs.java

@@ -0,0 +1,86 @@
+/*
+Copyright 2017 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;
+
+import io.kubernetes.client.Configuration;
+import io.kubernetes.client.apis.CoreV1Api;
+import io.kubernetes.client.models.V1Pod;
+import io.kubernetes.client.util.WebSockets;
+import io.kubernetes.client.util.WebSocketStreamHandler;
+
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.Reader;
+
+import org.apache.commons.lang.StringUtils;
+
+import com.squareup.okhttp.Call;
+import com.squareup.okhttp.Response;
+
+/**
+ * Utility class offering streaming access to Pod logs.
+ */
+public class PodLogs {
+    private ApiClient apiClient;
+    private CoreV1Api coreClient;
+
+    /**
+     * Simple PodLogs API constructor, uses default configuration
+     */
+    public PodLogs() {
+        this(Configuration.getDefaultApiClient());
+    }
+
+    /**
+     * PodLogs API Constructor
+     * @param apiClient The api client to use.
+     */
+    public PodLogs(ApiClient apiClient) {
+        this.apiClient = apiClient;
+        this.coreClient = new CoreV1Api(apiClient);
+    }
+
+    /**
+     * Get the API client for these Logs operations.
+     * @return The API client that will be used.
+     */
+    public ApiClient getApiClient() {
+        return apiClient;
+    }
+
+    public InputStream streamNamespacedPodLog(V1Pod pod) throws ApiException, IOException {
+        return streamNamespacedPodLog(pod.getMetadata().getNamespace(), pod.getMetadata().getName(),
+                                      pod.getSpec().getContainers().get(0).getName());
+    }
+
+    // Important note. You must close this stream or else you can leak connections.
+    public InputStream streamNamespacedPodLog(String namespace, String name, String container) throws ApiException, IOException {
+        return streamNamespacedPodLog(namespace, name, container, null, null, false);
+    }
+
+
+    // Important note. You must close this stream or else you can leak connections.
+    public InputStream streamNamespacedPodLog(String namespace, String name, String container,
+                                              Integer sinceSeconds, Integer tailLines, boolean timestamps) throws ApiException, IOException {
+        Call call = coreClient.readNamespacedPodLogCall(name, namespace, container, true, null, "false", false, sinceSeconds, tailLines, timestamps, null, null);
+        Response response = call.execute();
+        if (!response.isSuccessful()) {
+            throw new ApiException("Logs request failed: " + response.code());
+        }
+        return response.body().byteStream();
+    }
+}