chore(controller): add app.refresh func annotation

Author: jianxiaoguo

rootfs/api/models/app.py

@@ -208,6 +208,10 @@ def _refresh_ingress(self, hosts, tls_map, ssl_redirect, appsettings):
             raise ServiceUnavailable('Could not create Ingress in Kubernetes') from e
 
     def refresh(self, app_settings=None, tls=None, domains=None):
+        """
+        Read and write are separated, in transaction the read database is not updated.
+        When calling, the corresponding resource object needs
+        """
         if not getattr(self, 'refresh_enabled', True):
             return
         app_settings = app_settings if app_settings else self.appsettings_set.latest()

rootfs/api/models/appsettings.py

@@ -182,5 +182,6 @@ def save(self, *args, **kwargs):
         try:
             return super(AppSettings, self).save(**kwargs)
         finally:
+            # Read and write are separated, in transaction the read database is not updated
             self.app.refresh(app_settings=self)
         self.app.log('summary of app setting changes: {}'.format(summary), logging.DEBUG)

rootfs/api/models/domain.py

@@ -36,6 +36,7 @@ def save(self, *args, **kwargs):
             # Save to DB
             return super(Domain, self).save(*args, **kwargs)
         finally:
+            # Read and write are separated, in transaction the read database is not updated
             self.app.refresh(domains=domains)
 
     @transaction.atomic
@@ -50,6 +51,7 @@ def delete(self, *args, **kwargs):
             # Delete from DB
             return super(Domain, self).delete(*args, **kwargs)
         finally:
+            # Read and write are separated, in transaction the read database is not updated
             self.app.refresh(domains=domains)
 
     def __str__(self):

rootfs/api/models/tls.py

@@ -49,7 +49,9 @@ def save(self, *args, **kwargs):
             # Save to DB
             return super(TLS, self).save(*args, **kwargs)
         finally:
+            # Read and write are separated, in transaction the read database is not updated
             self.app.refresh(tls=self)
 
     def sync(self):
+        # Read and write are separated, in transaction the read database is not updated
         self.app.refresh(tls=self)