in config_operator/config_operator/k8s/K8sConfigMap.py [0:0]
def __init__(self, configmap_name: str,
namespace: str,
external_config: Union[LocalDirConfig, RemoteGitConfig],
api_instance: ApiClient = None,
api_core_v1_instance: CoreV1Api = None):
self._git_remote_config = external_config
self._namespace = namespace
self._configmap_name = configmap_name
if api_core_v1_instance is None:
# test is this runs inside kubernetes cluster
if os.getenv('KUBERNETES_SERVICE_HOST'):
config.load_incluster_config()
else:
config.load_kube_config()
configuration = client.Configuration()
api_instance = client.ApiClient(configuration)
api_core_v1_instance = client.CoreV1Api(api_instance)
self._api_instance = api_instance
self._api_core_v1_instance = api_core_v1_instance
self.publish()