Merge pull request #149 from brendandburns/namespace

Add code for extracting the current namespace.

Author: brendandburns

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

@@ -48,6 +48,7 @@ public class KubeConfig {
     Map<String, Object> currentContext;
     Map<String, Object> currentCluster;
     Map<String, Object> currentUser;
+    String currentNamespace;
 
     private static final Logger log = Logger.getLogger(KubeConfig.class);
 
@@ -112,7 +113,7 @@ public boolean setContext(String context) {
         }
         String cluster = (String) currentContext.get("cluster");
         String user = (String) currentContext.get("user");
-
+        currentNamespace = (String) currentContext.get("namespace");
         if (cluster != null) {
             Map<String, Object> obj = findObject(clusters, cluster);
             if (obj != null) {
@@ -128,6 +129,10 @@ public boolean setContext(String context) {
         return true;
     }
 
+    public String getNamespace() {
+        return currentNamespace;
+    }
+
     public String getServer() {
         return getData(currentCluster, "server");
     }
@@ -175,7 +180,6 @@ public String getAccessToken() {
             if (authConfig != null) {
                 String name = (String) authProviderMap.get("name");
                 Authenticator auth = authenticators.get(name);
-                System.out.println(auth + " for " + name);                
                 if (auth != null) {
                     if (auth.isExpired(authConfig)) {
                         authConfig = auth.refresh(authConfig);

util/src/test/java/io/kubernetes/client/util/KubeConfigTest.java

@@ -49,7 +49,8 @@ public class KubeConfigTest {
         "  name: foo\n" + 
         "contexts:\n" + 
         "- context:\n" +
-        "    cluster: foo\n" + 
+        "    cluster: foo\n" +
+        "    namespace: some_namespace\n" +
         "    user: foo\n" +
         "  name: foo-context\n" +
         "current-context: foo-context\n";
@@ -110,4 +111,16 @@ public void testGCPAuthProvider() {
             fail("Unexpected exception: " + ex);
         }
     }
+
+    @Test
+    public void testNamespace() {
+        KubeConfig config = KubeConfig.loadKubeConfig(new StringReader(KUBECONFIG_TOKEN));
+        assertEquals(config.getNamespace(), "some_namespace");
+    }
+
+    @Test
+    public void testNullNamespace() {
+        KubeConfig config = KubeConfig.loadKubeConfig(new StringReader(GCP_CONFIG));
+        assertNull(config.getNamespace());
+    }
 }