Merge pull request #21 from brendandburns/exec

Initial implementation of Exec.

Author: mbohlool

examples/pom.xml

@@ -19,24 +19,29 @@
 			<artifactId>client-java-util</artifactId>
 			<version>1.0-SNAPSHOT</version>
 		</dependency>
-		    <!-- test dependencies -->
-    <dependency>
-      <groupId>junit</groupId>
-      <artifactId>junit</artifactId>
-      <version>${junit-version}</version>
-      <scope>test</scope>
-    </dependency>
+		<dependency>
+			<groupId>com.google.guava</groupId>
+			<artifactId>guava</artifactId>
+			<version>22.0</version>
+		</dependency>
+		<!-- test dependencies -->
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>${junit-version}</version>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
-	  <properties>
-    <java.version>1.7</java.version>
-    <maven.compiler.source>${java.version}</maven.compiler.source>
-    <maven.compiler.target>${java.version}</maven.compiler.target>
-    <swagger-core-version>1.5.12</swagger-core-version>
-    <okhttp-version>2.7.5</okhttp-version>
-    <gson-version>2.6.2</gson-version>
-    <jodatime-version>2.9.3</jodatime-version>
-    <maven-plugin-version>1.0.0</maven-plugin-version>
-    <junit-version>4.12</junit-version>
-    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-  </properties>
+	<properties>
+		<java.version>1.7</java.version>
+		<maven.compiler.source>${java.version}</maven.compiler.source>
+		<maven.compiler.target>${java.version}</maven.compiler.target>
+		<swagger-core-version>1.5.12</swagger-core-version>
+		<okhttp-version>2.7.5</okhttp-version>
+		<gson-version>2.6.2</gson-version>
+		<jodatime-version>2.9.3</jodatime-version>
+		<maven-plugin-version>1.0.0</maven-plugin-version>
+		<junit-version>4.12</junit-version>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
 </project>

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

@@ -0,0 +1,68 @@
+package io.kubernetes.client.examples;
+
+import io.kubernetes.client.ApiClient;
+import io.kubernetes.client.ApiException;
+import io.kubernetes.client.Configuration;
+import io.kubernetes.client.Exec;
+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.InputStreamReader;
+import java.io.IOException;
+import java.io.OutputStream;
+
+/**
+ * A simple example of how to use the Java API
+ * 
+ * Requires kubectl proxy running
+ * 
+ * Easiest way to run this:
+ *   mvn exec:java -Dex.mainClass="io.kubernetes.client.examples.Example"
+ * 
+ * From inside $REPO_DIR/kubernetes
+ */
+public class ExecExample {
+    public static void main(String[] args) throws IOException, ApiException, InterruptedException {
+        ApiClient client = Config.defaultClient();
+        Configuration.setDefaultApiClient(client);
+
+        Exec exec = new Exec();
+        final Process proc = exec.exec("default", "nginx-2371676037-czqx3", new String[] {"sh", "-c", "echo foo"}, true);
+
+        new Thread(new Runnable() {
+            public void run() {
+                BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
+                OutputStream output = proc.getOutputStream();
+                try {
+                    while (true) {
+                        String line = in.readLine();
+                        output.write(line.getBytes());
+                        output.write('\n');
+                        output.flush();
+                    }
+                } catch (IOException ex) {
+                    ex.printStackTrace();
+                }
+            }
+        }).start();
+
+        new Thread(new Runnable() {
+            public void run() {
+                try {
+                    ByteStreams.copy(proc.getInputStream(), System.out);
+                } catch (IOException ex) {
+                    ex.printStackTrace();
+                }
+            }
+        }).start();
+
+        proc.waitFor();
+
+        System.exit(0);
+    }
+}

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

@@ -18,6 +18,7 @@
 import io.kubernetes.client.util.WebSockets;
 
 import java.io.BufferedReader;
+import java.io.Closeable;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.Reader;
@@ -26,7 +27,7 @@ public class WebSocketsExample {
     public static void main(String... args) throws ApiException, IOException {
         final ApiClient client = Config.defaultClient();
         WebSockets.stream(args[0], "GET", client, new WebSockets.SocketListener() {
-            public void open() {}
+            public void open(String protocol, Closeable close) {}
             public void close() {
                 // Trigger shutdown of the dispatcher's executor so this process can exit cleanly.
                 client.getHttpClient().getDispatcher().getExecutorService().shutdown();

util/pom.xml

@@ -24,6 +24,11 @@
 			<artifactId>commons-codec</artifactId>
 			<version>1.10</version>
 		</dependency>
+		<dependency>
+			<groupId>commons-lang</groupId>
+			<artifactId>commons-lang</artifactId>
+			<version>2.6</version>
+		</dependency>
 		<dependency>
 			<groupId>com.squareup.okhttp</groupId>
 			<artifactId>okhttp-ws</artifactId>