projects
/
osm
/
N2VC.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Update python-libjuju version to 2.9.42.4
[osm/N2VC.git]
/
n2vc
/
k8s_helm_base_conn.py
diff --git
a/n2vc/k8s_helm_base_conn.py
b/n2vc/k8s_helm_base_conn.py
index
34d3129
..
a897e0e
100644
(file)
--- a/
n2vc/k8s_helm_base_conn.py
+++ b/
n2vc/k8s_helm_base_conn.py
@@
-1962,7
+1962,7
@@
class K8sHelmBaseConnector(K8sConnector):
self._init_paths_env(cluster_name=cluster_id, create_if_not_exist=True)
def get_random_number():
self._init_paths_env(cluster_name=cluster_id, create_if_not_exist=True)
def get_random_number():
- r = random.
randrange(start=1, stop=
99999999)
+ r = random.
SystemRandom().randint(1,
99999999)
s = str(r)
while len(s) < 10:
s = "0" + s
s = str(r)
while len(s) < 10:
s = "0" + s
@@
-2028,7
+2028,7
@@
class K8sHelmBaseConnector(K8sConnector):
name += "-"
def get_random_number():
name += "-"
def get_random_number():
- r = random.
randrange(start=1, stop=
99999999)
+ r = random.
SystemRandom().randint(1,
99999999)
s = str(r)
s = s.rjust(10, "0")
return s
s = str(r)
s = s.rjust(10, "0")
return s
@@
-2118,12
+2118,14
@@
class K8sHelmBaseConnector(K8sConnector):
self,
namespace,
cluster_uuid,
self,
namespace,
cluster_uuid,
+ labels,
):
"""
Create a namespace in a specific cluster
):
"""
Create a namespace in a specific cluster
- :param namespace:
n
amespace to be created
+ :param namespace:
N
amespace to be created
:param cluster_uuid: K8s cluster uuid used to retrieve kubeconfig
:param cluster_uuid: K8s cluster uuid used to retrieve kubeconfig
+ :param labels: Dictionary with labels for the new namespace
:returns: None
"""
paths, env = self._init_paths_env(
:returns: None
"""
paths, env = self._init_paths_env(
@@
-2132,6
+2134,7
@@
class K8sHelmBaseConnector(K8sConnector):
kubectl = Kubectl(config_file=paths["kube_config"])
await kubectl.create_namespace(
name=namespace,
kubectl = Kubectl(config_file=paths["kube_config"])
await kubectl.create_namespace(
name=namespace,
+ labels=labels,
)
async def delete_namespace(
)
async def delete_namespace(