Support file-ish objects in config loading

config/kube_config.py

@@ -19,6 +19,7 @@
 import json
 import logging
 import os
+import io
 import platform
 import subprocess
 import tempfile
@@ -667,19 +668,31 @@ def __init__(self, paths):
         self.paths = []
         self.config_files = {}
         self.config_merged = None
-
-        for path in paths.split(ENV_KUBECONFIG_PATH_SEPARATOR):
-            if path:
-                path = os.path.expanduser(path)
-                if os.path.exists(path):
-                    self.paths.append(path)
-                    self.load_config(path)
-        self.config_saved = copy.deepcopy(self.config_files)
+        if hasattr(paths, 'read'):
+            self.load_config_from_fileish(paths)
+        else:
+            for path in paths.split(ENV_KUBECONFIG_PATH_SEPARATOR):
+                if path:
+                    path = os.path.expanduser(path)
+                    if os.path.exists(path):
+                        self.paths.append(path)
+                        self.load_config(path)
+            self.config_saved = copy.deepcopy(self.config_files)
 
     @property
     def config(self):
         return self.config_merged
 
+    def load_config_from_fileish(self, string):
+        if hasattr(string, 'getvalue'):
+            config = yaml.safe_load(string.getvalue())
+        else:
+            config = yaml.safe_load(string.read())
+
+        if self.config_merged is None:
+            self.config_merged = copy.deepcopy(config)
+        # doesn't need to do any further merging
+
     def load_config(self, path):
         with open(path) as f:
             config = yaml.safe_load(f)

config/kube_config_test.py

@@ -16,6 +16,7 @@
 import datetime
 import json
 import os
+import io
 import shutil
 import tempfile
 import unittest
@@ -1257,6 +1258,15 @@ def test_load_kube_config(self):
                          client_configuration=actual)
         self.assertEqual(expected, actual)
 
+    def test_load_kube_config_from_fileish(self):
+        expected = FakeConfig(host=TEST_HOST,
+                              token=BEARER_TOKEN_FORMAT % TEST_DATA_BASE64)
+        config_fileish = io.StringIO()
+        config_fileish.write(yaml.safe_dump(self.TEST_KUBE_CONFIG))
+        actual = FakeConfig()
+        load_kube_config(config_file=config_fileish, context="simple_token", client_configuration=actual)
+        self.assertEqual(expected, actual)
+
     def test_load_kube_config_from_dict(self):
         expected = FakeConfig(host=TEST_HOST,
                               token=BEARER_TOKEN_FORMAT % TEST_DATA_BASE64)
@@ -1660,6 +1670,7 @@ def test_new_client_from_config(self):
         self.assertEqual(BEARER_TOKEN_FORMAT % TEST_DATA_BASE64,
                          client.configuration.api_key['authorization'])
 
+
     def test_save_changes(self):
         kubeconfigs = self._create_multi_config()