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,6 @@
+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,42 @@
+from abc import ABC, abstractmethod
+import logging
+import threading
+import time
+from ratelimiter import RateLimiter
+
+logger = logging.getLogger(__name__)
+
+
+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 []
+
+        limiter = RateLimiter(max_calls=10**6 // self.args.report_period, period=1)
+
+        future = threading.Thread(
+            name="slo_metrics_sender",
+            target=self._metric_sender,
+            args=(limiter, self.args.time),
+        )
+        future.start()
+        return [future]
+
+    def _metric_sender(self, limiter, runtime):
+        start_time = time.time()
+        logger.info("Start push metrics")
+
+        while time.time() - start_time < runtime:
+            with limiter:
+                self.metrics.push()
+
+        logger.info("Stop push metrics")