Update slo architecture

Author: vgvoleg

tests/slo/src/core/__init__.py

@@ -0,0 +1 @@
+# Core utilities

tests/slo/src/core/dummy_metrics.py

@@ -0,0 +1,7 @@
+class DummyMetrics:
+
+    def start(self, labels):
+        return 0
+
+    def stop(self, labels, start_time, attempts=1, error=None):
+        pass

tests/slo/src/generator.py renamed to tests/slo/src/core/generator.py

@@ -0,0 +1 @@
+# Job modules

tests/slo/src/metrics.py renamed to tests/slo/src/core/metrics.py

@@ -0,0 +1,31 @@
+from abc import ABC, abstractmethod
+import threading
+import time
+
+
+class BaseJobManager(ABC):
+
+    def __init__(self, driver, args, metrics):
+        self.driver = driver
+        self.args = args
+        self.metrics = metrics
+
+    @abstractmethod
+    def run_tests(self):
+        pass
+
+    def _run_metric_job(self):
+        if not self.args.prom_pgw:
+            return []
+
+        future = threading.Thread(
+            name="slo_metrics_sender",
+            target=self._metric_sender,
+        )
+        future.start()
+        return [future]
+
+    def _metric_sender(self):
+        while True:
+            time.sleep(10)
+            self.metrics.push()