Update the expected response layout for kubernetes config
This commit is contained in:
parent
76e56d4fca
commit
ef459a2d18
2 changed files with 45 additions and 2 deletions
|
@ -57,16 +57,22 @@ class KubernetesConfigProvider(FileConfigProvider):
|
|||
|
||||
def volume_file_exists(self, filename):
|
||||
secret = self._lookup_secret()
|
||||
if not secret:
|
||||
return False
|
||||
return filename in secret
|
||||
|
||||
|
||||
def list_volume_directory(self, path):
|
||||
secret = self._lookup_secret()
|
||||
|
||||
if not secret:
|
||||
return []
|
||||
|
||||
paths = []
|
||||
for filename in secret:
|
||||
if filename.startswith(path):
|
||||
paths.append(filename[len(path) + 1:])
|
||||
return paths
|
||||
|
||||
def remove_volume_file(self, filename):
|
||||
super(KubernetesConfigProvider, self).remove_volume_file(filename)
|
||||
|
@ -126,8 +132,10 @@ class KubernetesConfigProvider(FileConfigProvider):
|
|||
response = self._execute_k8s_api('GET', secret_url)
|
||||
if response.status_code != 200:
|
||||
return None
|
||||
|
||||
return json.loads(response.text)
|
||||
secret_resp = json.loads(response.text)
|
||||
if "data" not in secret_resp:
|
||||
return secret_resp
|
||||
return secret_resp["data"]
|
||||
|
||||
def _execute_k8s_api(self, method, relative_url, data=None):
|
||||
headers = {
|
||||
|
|
Reference in a new issue