feat(controller): add canary support

Author: duanhongyi

rootfs/api/management/commands/load_db_state_to_k8s.py

@@ -17,6 +17,24 @@ class Command(BaseCommand):
     """Management command for publishing Drycc platform state from the database
     to k8s.
     """
+
+    def _deploy(self, app, release):
+        if release.build is None:
+            print('WARNING: {} has no build associated with '
+                  'its latest release. Skipping deployment...'.format(app))
+            return
+
+        try:
+            app.deploy(release)
+        except AlreadyExists as error:
+            logger.debug(error)
+            print('WARNING: {} has a deployment in progress. '
+                  'Skipping deployment...'.format(app))
+        except DryccException as error:
+            logger.exception(error)
+            print('ERROR: There was a problem deploying {} '
+                  'due to {}'.format(app, str(error)))
+
     def handle(self, *args, **options):
         """Publishes Drycc platform state from the database to kubernetes."""
         print("Publishing DB state to kubernetes...")
@@ -29,26 +47,13 @@ def handle(self, *args, **options):
                 domain = get_object_or_404(Domain, domain=domain)
                 cert.attach_in_kubernetes(domain)
 
-        # deploy applications
+        # deploy apps
         print("Deploying available applications")
-        for application in App.objects.all():
-            rel = application.release_set.filter(failed=False).latest()
-            if rel.build is None:
-                print('WARNING: {} has no build associated with '
-                      'its latest release. Skipping deployment...'.format(application))
-                continue
-
-            try:
-                application.deploy(rel)
-            except AlreadyExists as error:
-                logger.debug(error)
-                print('WARNING: {} has a deployment in progress. '
-                      'Skipping deployment...'.format(application))
-                continue
-            except DryccException as error:
-                logger.exception(error)
-                print('ERROR: There was a problem deploying {} '
-                      'due to {}'.format(application, str(error)))
+        for app in App.objects.all():
+            release = app.release_set.filter(failed=False).latest()
+            if release.canary:
+                self._deploy(app, app.release_set.filter(failed=False, canary=False).latest())
+            self._deploy(app, release)
 
         print("Done Publishing DB state to kubernetes.")
 

rootfs/api/migrations/0001_initial.py

@@ -1,8 +1,9 @@
-# Generated by Django 4.1.7 on 2023-05-05 03:32
+# Generated by Django 4.2.1 on 2023-05-31 02:30
 
 import api.models.app
 import api.models.certificate
 import api.models.key
+import api.models.tls
 import api.utils
 from django.conf import settings
 import django.contrib.auth.models
@@ -185,7 +186,7 @@ class Migration(migrations.Migration):
                 ('uuid', models.UUIDField(auto_created=True, default=uuid.uuid4, editable=False, primary_key=True, serialize=False, unique=True, verbose_name='UUID')),
                 ('created', models.DateTimeField(auto_now_add=True)),
                 ('updated', models.DateTimeField(auto_now=True)),
-                ('issuer', models.JSONField(default={'email': 'anonymous@cert-manager.io', 'key_id': '', 'key_secret': '', 'server': 'https://acme-v02.api.letsencrypt.org/directory'})),
+                ('issuer', models.JSONField(default=api.models.tls.default_issuer)),
                 ('https_enforced', models.BooleanField(null=True)),
                 ('certs_auto_enabled', models.BooleanField(null=True)),
                 ('app', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='api.app')),
@@ -204,6 +205,7 @@ class Migration(migrations.Migration):
                 ('created', models.DateTimeField(auto_now_add=True)),
                 ('updated', models.DateTimeField(auto_now=True)),
                 ('ports', models.JSONField(default=list)),
+                ('canary', models.BooleanField(default=False)),
                 ('procfile_type', models.TextField()),
                 ('app', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='api.app')),
                 ('owner', models.ForeignKey(on_delete=django.db.models.deletion.PROTECT, to=settings.AUTH_USER_MODEL)),
@@ -266,6 +268,7 @@ class Migration(migrations.Migration):
                 ('version', models.PositiveIntegerField()),
                 ('summary', models.TextField(blank=True, null=True)),
                 ('failed', models.BooleanField(default=False)),
+                ('canary', models.BooleanField(default=False)),
                 ('exception', models.TextField(blank=True, null=True)),
                 ('app', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='api.app')),
                 ('build', models.ForeignKey(null=True, on_delete=django.db.models.deletion.CASCADE, to='api.build')),
@@ -318,6 +321,7 @@ class Migration(migrations.Migration):
                 ('uuid', models.UUIDField(auto_created=True, default=uuid.uuid4, editable=False, primary_key=True, serialize=False, unique=True, verbose_name='UUID')),
                 ('created', models.DateTimeField(auto_now_add=True)),
                 ('updated', models.DateTimeField(auto_now=True)),
+                ('canaries', models.JSONField(default=list)),
                 ('routable', models.BooleanField(default=True)),
                 ('autoscale', models.JSONField(blank=True, default=dict)),
                 ('label', models.JSONField(blank=True, default=dict)),
@@ -331,4 +335,3 @@ class Migration(migrations.Migration):
             },
         ),
     ]
-