projects
/
osm
/
N2VC.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Reformat N2VC to standardized format
[osm/N2VC.git]
/
n2vc
/
k8s_conn.py
diff --git
a/n2vc/k8s_conn.py
b/n2vc/k8s_conn.py
index
f82e032
..
89805b3
100644
(file)
--- a/
n2vc/k8s_conn.py
+++ b/
n2vc/k8s_conn.py
@@
-33,6
+33,7
@@
class K8sConnector(abc.ABC, Loggable):
################################### P U B L I C ####################################
####################################################################################
"""
################################### P U B L I C ####################################
####################################################################################
"""
+
@staticmethod
def generate_kdu_instance_name(**kwargs):
raise NotImplementedError("Method not implemented")
@staticmethod
def generate_kdu_instance_name(**kwargs):
raise NotImplementedError("Method not implemented")
@@
-209,11
+210,12
@@
class K8sConnector(abc.ABC, Loggable):
@abc.abstractmethod
async def scale(
@abc.abstractmethod
async def scale(
- self, kdu_instance: str,
- scale: int,
- resource_name: str,
- total_timeout: float = 1800,
- **kwargs,
+ self,
+ kdu_instance: str,
+ scale: int,
+ resource_name: str,
+ total_timeout: float = 1800,
+ **kwargs,
) -> bool:
"""
Scales an application in KDU instance.
) -> bool:
"""
Scales an application in KDU instance.
@@
-230,10
+232,10
@@
class K8sConnector(abc.ABC, Loggable):
@abc.abstractmethod
async def get_scale_count(
@abc.abstractmethod
async def get_scale_count(
-
self,
-
resource_name: str,
-
kdu_instance: str,
-
**kwargs,
+ self,
+ resource_name: str,
+ kdu_instance: str,
+ **kwargs,
) -> int:
"""
Get an application scale count.
) -> int:
"""
Get an application scale count.
@@
-356,10
+358,9
@@
class K8sConnector(abc.ABC, Loggable):
"""
@abc.abstractmethod
"""
@abc.abstractmethod
- async def get_services(self,
- cluster_uuid: str,
- kdu_instance: str,
- namespace: str) -> list:
+ async def get_services(
+ self, cluster_uuid: str, kdu_instance: str, namespace: str
+ ) -> list:
"""
Returns a list of services defined for the specified kdu instance.
"""
Returns a list of services defined for the specified kdu instance.
@@
-377,10
+378,9
@@
class K8sConnector(abc.ABC, Loggable):
"""
@abc.abstractmethod
"""
@abc.abstractmethod
- async def get_service(self,
- cluster_uuid: str,
- service_name: str,
- namespace: str = None) -> object:
+ async def get_service(
+ self, cluster_uuid: str, service_name: str, namespace: str = None
+ ) -> object:
"""
Obtains the data of the specified service in the k8cluster.
"""
Obtains the data of the specified service in the k8cluster.