projects
/
osm
/
N2VC.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix black issues
[osm/N2VC.git]
/
n2vc
/
k8s_helm_conn.py
diff --git
a/n2vc/k8s_helm_conn.py
b/n2vc/k8s_helm_conn.py
index
b1ad379
..
c8c95ee
100644
(file)
--- a/
n2vc/k8s_helm_conn.py
+++ b/
n2vc/k8s_helm_conn.py
@@
-132,18
+132,19
@@
class K8sHelmConnector(K8sHelmBaseConnector):
:param kwargs: Additional parameters (None yet)
:return: True if successful
"""
:param kwargs: Additional parameters (None yet)
:return: True if successful
"""
- self.log.debug("installing {} in cluster {}".format(kdu_model, cluster_uuid))
+ _, cluster_id = self._get_namespace_cluster_id(cluster_uuid)
+ self.log.debug("installing {} in cluster {}".format(kdu_model, cluster_id))
# sync local dir
# sync local dir
- self.fs.sync(from_path=cluster_
uu
id)
+ self.fs.sync(from_path=cluster_id)
# init env, paths
paths, env = self._init_paths_env(
# init env, paths
paths, env = self._init_paths_env(
- cluster_name=cluster_
uu
id, create_if_not_exist=True
+ cluster_name=cluster_id, create_if_not_exist=True
)
await self._install_impl(
)
await self._install_impl(
- cluster_
uu
id,
+ cluster_id,
kdu_model,
paths,
env,
kdu_model,
paths,
env,
@@
-157,13
+158,12
@@
class K8sHelmConnector(K8sHelmBaseConnector):
)
# sync fs
)
# sync fs
- self.fs.reverse_sync(from_path=cluster_
uu
id)
+ self.fs.reverse_sync(from_path=cluster_id)
self.log.debug("Returning kdu_instance {}".format(kdu_instance))
return True
async def inspect_kdu(self, kdu_model: str, repo_url: str = None) -> str:
self.log.debug("Returning kdu_instance {}".format(kdu_instance))
return True
async def inspect_kdu(self, kdu_model: str, repo_url: str = None) -> str:
-
self.log.debug(
"inspect kdu_model {} from (optional) repo: {}".format(kdu_model, repo_url)
)
self.log.debug(
"inspect kdu_model {} from (optional) repo: {}".format(kdu_model, repo_url)
)
@@
-234,7
+234,6
@@
class K8sHelmConnector(K8sHelmBaseConnector):
return paths, env
async def _get_services(self, cluster_id, kdu_instance, namespace, kubeconfig):
return paths, env
async def _get_services(self, cluster_id, kdu_instance, namespace, kubeconfig):
-
# init config, env
paths, env = self._init_paths_env(
cluster_name=cluster_id, create_if_not_exist=True
# init config, env
paths, env = self._init_paths_env(
cluster_name=cluster_id, create_if_not_exist=True
@@
-301,8
+300,8
@@
class K8sHelmConnector(K8sHelmBaseConnector):
)
command = (
)
command = (
- "{} --kubeconfig={} --tiller-namespace={} --home={} --service-account {} "
- " {}
init
"
+ "{}
init
--kubeconfig={} --tiller-namespace={} --home={} --service-account {} "
+ " {}"
).format(
self._helm_command,
paths["kube_config"],
).format(
self._helm_command,
paths["kube_config"],
@@
-325,8
+324,8
@@
class K8sHelmConnector(K8sHelmBaseConnector):
):
self.log.info("Initializing helm in client: {}".format(cluster_id))
command = (
):
self.log.info("Initializing helm in client: {}".format(cluster_id))
command = (
- "{} --kubeconfig={} --tiller-namespace={} "
- "--home={}
init
--client-only {} "
+ "{}
init
--kubeconfig={} --tiller-namespace={} "
+ "--home={} --client-only {} "
).format(
self._helm_command,
paths["kube_config"],
).format(
self._helm_command,
paths["kube_config"],
@@
-342,13
+341,15
@@
class K8sHelmConnector(K8sHelmBaseConnector):
else:
self.log.info("Helm client already initialized")
else:
self.log.info("Helm client already initialized")
- repo_list = await self.repo_list(cluster_id)
+ # remove old stable repo and add new one
+ cluster_uuid = "{}:{}".format(namespace, cluster_id)
+ repo_list = await self.repo_list(cluster_uuid)
for repo in repo_list:
if repo["name"] == "stable" and repo["url"] != self._stable_repo_url:
self.log.debug("Add new stable repo url: {}")
for repo in repo_list:
if repo["name"] == "stable" and repo["url"] != self._stable_repo_url:
self.log.debug("Add new stable repo url: {}")
- await self.repo_remove(cluster_id, "stable")
+ await self.repo_remove(cluster_
uu
id, "stable")
if self._stable_repo_url:
if self._stable_repo_url:
- await self.repo_add(cluster_id, "stable", self._stable_repo_url)
+ await self.repo_add(cluster_
uu
id, "stable", self._stable_repo_url)
break
return n2vc_installed_sw
break
return n2vc_installed_sw
@@
-405,13
+406,8
@@
class K8sHelmConnector(K8sHelmBaseConnector):
output, _rc = await self._local_async_exec(
command=command, raise_exception_on_error=False, env=env
)
output, _rc = await self._local_async_exec(
command=command, raise_exception_on_error=False, env=env
)
- command = (
- "{} --kubeconfig={} --namespace {} delete serviceaccount/{}".format(
- self.kubectl_command,
- paths["kube_config"],
- namespace,
- self.service_account,
- )
+ command = "{} --kubeconfig={} --namespace kube-system delete serviceaccount/{}".format(
+ self.kubectl_command, paths["kube_config"], self.service_account
)
output, _rc = await self._local_async_exec(
command=command, raise_exception_on_error=False, env=env
)
output, _rc = await self._local_async_exec(
command=command, raise_exception_on_error=False, env=env
@@
-421,7
+417,6
@@
class K8sHelmConnector(K8sHelmBaseConnector):
self.log.debug("namespace not found")
async def _instances_list(self, cluster_id):
self.log.debug("namespace not found")
async def _instances_list(self, cluster_id):
-
# init paths, env
paths, env = self._init_paths_env(
cluster_name=cluster_id, create_if_not_exist=True
# init paths, env
paths, env = self._init_paths_env(
cluster_name=cluster_id, create_if_not_exist=True
@@
-460,7
+455,6
@@
class K8sHelmConnector(K8sHelmBaseConnector):
yaml_format: bool = False,
show_error_log: bool = False,
) -> Union[str, dict]:
yaml_format: bool = False,
show_error_log: bool = False,
) -> Union[str, dict]:
-
self.log.debug(
"status of kdu_instance: {}, namespace: {} ".format(kdu_instance, namespace)
)
self.log.debug(
"status of kdu_instance: {}, namespace: {} ".format(kdu_instance, namespace)
)
@@
-597,7
+591,6
@@
class K8sHelmConnector(K8sHelmBaseConnector):
timeout,
kubeconfig,
) -> str:
timeout,
kubeconfig,
) -> str:
-
timeout_str = ""
if timeout:
timeout_str = "--timeout {}".format(timeout)
timeout_str = ""
if timeout:
timeout_str = "--timeout {}".format(timeout)
@@
-643,7
+636,6
@@
class K8sHelmConnector(K8sHelmBaseConnector):
timeout,
kubeconfig,
) -> str:
timeout,
kubeconfig,
) -> str:
-
timeout_str = ""
if timeout:
timeout_str = "--timeout {}".format(timeout)
timeout_str = ""
if timeout:
timeout_str = "--timeout {}".format(timeout)