Standardize logging

[osm/N2VC.git] / n2vc / k8s_conn.py

diff --git a/n2vc/k8s_conn.py b/n2vc/k8s_conn.py
index f9aefa7..e49e497 100644 (file)
--- a/n2vc/k8s_conn.py
+++ b/n2vc/k8s_conn.py
@@ -50,13 +50,13 @@ class K8sConnector(abc.ABC, Loggable):
         # parent class
         Loggable.__init__(self, log=log, log_to_console=True, prefix='\nK8S')
 
         # parent class
         Loggable.__init__(self, log=log, log_to_console=True, prefix='\nK8S')
 

-        self.info('Initializing generic K8S connector')
+        self.log.info('Initializing generic K8S connector')

 
         # the database and update callback
         self.db = db
         self.on_update_db = on_update_db
 
 
         # the database and update callback
         self.db = db
         self.on_update_db = on_update_db
 

-        self.info('K8S generic connector initialized')
+        self.log.info('K8S generic connector initialized')

 
     @abc.abstractmethod
     async def init_env(
 
     @abc.abstractmethod
     async def init_env(


@@ -122,6 +122,20 @@ class K8sConnector(abc.ABC, Loggable):
         :return: True if successful
         """
 
         :return: True if successful
         """
 

+    @abc.abstractmethod
+    async def synchronize_repos(
+            self,
+            cluster_uuid: str,
+            name: str
+    ):
+        """
+        Synchronizes the list of repositories created in the cluster with
+        the repositories added by the NBI
+
+        :param cluster_uuid: the cluster
+        :return: List of repositories deleted from the cluster and dictionary with repos added
+        """
+

     @abc.abstractmethod
     async def reset(
             self,
     @abc.abstractmethod
     async def reset(
             self,


@@ -319,7 +333,7 @@ class K8sConnector(abc.ABC, Loggable):
             self.warning('No db_dict => No database write')
             return False
 
             self.warning('No db_dict => No database write')
             return False
 

-        self.debug('status={}'.format(status))
+        self.log.debug('status={}'.format(status))

 
         try:
 
 
         try:
 


@@ -352,5 +366,5 @@ class K8sConnector(abc.ABC, Loggable):
             return True
 
         except Exception as e:
             return True
 
         except Exception as e:

-            self.info('Exception writing status to database: {}'.format(e))
+            self.log.info('Exception writing status to database: {}'.format(e))

             return False
             return False