Merge pull request #136 from Cryptophobia/master

feat(HPAs): resolves #135 recreate HPAs from db on load

Author: Cryptophobia

Makefile

@@ -1,6 +1,6 @@
 # If DEIS_REGISTRY is not set, try to populate it from legacy DEV_REGISTRY
 DEIS_REGISTRY ?= $(DEV_REGISTRY)
-IMAGE_PREFIX ?= deis
+IMAGE_PREFIX ?= hephy
 COMPONENT ?= controller
 SHORT_NAME ?= $(COMPONENT)
 

rootfs/api/management/commands/healthchecks.py

@@ -5,6 +5,7 @@
 
 class Command(BaseCommand):
     """Management command for healthchecks"""
+
     def handle(self, *args, **options):
         """Ensure DB and other things are alive"""
         print("Checking if database is alive")

rootfs/api/management/commands/load_db_state_to_k8s.py

@@ -1,14 +1,15 @@
 from django.core.management.base import BaseCommand
 from django.shortcuts import get_object_or_404
 
-from api.models import Key, App, Domain, Certificate, Service
+from api.models import Key, App, AppSettings, Domain, Certificate, Service
 from api.exceptions import DeisException, AlreadyExists
 
 
 class Command(BaseCommand):
     """Management command for publishing Deis platform state from the database
     to k8s.
     """
+
     def handle(self, *args, **options):
         """Publishes Deis platform state from the database to kubernetes."""
         print("Publishing DB state to kubernetes...")
@@ -40,6 +41,16 @@ def handle(self, *args, **options):
                 print('ERROR: There was a problem deploying {} '
                       'due to {}'.format(application, str(error)))
 
+            # deploy autoscaling HPAs for application
+            appsettings = AppSettings.objects.filter(app=application).order_by('-created')[0]
+            if appsettings.autoscale:
+                try:
+                    for proc_type in application.structure:
+                        application.autoscale(proc_type, appsettings.autoscale[proc_type])
+                except Exception as error:
+                    print('ERROR: There was a problem deploying HPAs for this {} proc_type '
+                          'of {} app due to error: {}'.format(proc_type, application, error))
+
         print("Done Publishing DB state to kubernetes.")
 
     def save_apps(self):