add persistence

Author: matheuscmelo

Diff for: kubejobs/__init__.py

@@ -164,7 +164,6 @@ def monitoring_application(self):
 
     def validate(self, data):
         data_model = {
-            "datasource_type": six.string_types,
             "enable_visualizer": bool,
             "expected_time": int,
             "number_of_jobs": int,

Diff for: monitor/cli/main.py

@@ -16,9 +16,10 @@
 from flask import Flask
 from monitor.api.v10 import rest
 from monitor.service import api
-
+from monitor.utils.logger import configure_logging
 
 def main():
     app = Flask(__name__)
+    configure_logging()
     app.register_blueprint(rest)
     app.run(host='0.0.0.0', port=api.port, debug=True)

Diff for: monitor/service/api/v10.py

@@ -34,11 +34,18 @@ def start_monitoring(data, app_id):
         API_LOG.log("Missing parameters in request")
         raise ex.BadRequestException()
 
-    plugin = data['plugin']
+    plugin = data['plugin']['name']
     plugin_info = data['plugin_info']
 
     if app_id not in monitored_apps:
-        executor = plugin_service.get_plugin(plugin)(app_id, plugin_info)
+        try:
+            executor = plugin_service.get_plugin(plugin)(app_id, plugin_info)
+        except ImportError:
+            plugin_data = data['plugin']
+            plugin_service.install_plugin(plugin_data['source'],
+                                          plugin_data['plugin_source'])
+            executor = plugin_service.get_plugin(plugin)(app_id, plugin_info)
+
         monitored_apps[app_id] = executor
         executor.start()