Add slo Factory

theodolite-quarkus/src/main/kotlin/theodolite/evaluation/ExternalSLOChecker.kt → theodolite-quarkus/src/main/kotlin/theodolite/evaluation/ExternalSloChecker.kt

@@ -6,7 +6,7 @@ import java.net.ConnectException
 import java.time.Duration
 import java.time.Instant
 
-class ExternalSLOChecker(
+class ExternalSloChecker(
     private val prometheusURL: String,
     private val query: String,
     private val externalSlopeURL: String,

theodolite-quarkus/src/main/kotlin/theodolite/evaluation/SloCheckerFactory.kt

+package theodolite.evaluation
+
+import java.time.Duration
+
+class SloCheckerFactory {
+
+    fun create(
+        slotype: String,
+        prometheusURL: String,
+        query: String,
+        externalSlopeURL: String,
+        threshold: Int,
+        offset: Duration,
+        warmup: Int
+    ): SloChecker {
+
+        return when (slotype) {
+            "lag trend" -> ExternalSloChecker(
+                prometheusURL = prometheusURL,
+                query = query,
+                externalSlopeURL = externalSlopeURL,
+                threshold = threshold,
+                offset = offset,
+                warmup = warmup
+            )
+            else -> throw IllegalArgumentException("Slotype $slotype not found.")
+        }
+    }
+}

theodolite-quarkus/src/main/kotlin/theodolite/execution/BenchmarkExecutorImpl.kt

@@ -3,7 +3,7 @@ package theodolite.execution
 import mu.KotlinLogging
 import theodolite.benchmark.Benchmark
 import theodolite.benchmark.BenchmarkExecution
-import theodolite.evaluation.ExternalSLOChecker
+import theodolite.evaluation.SloCheckerFactory
 import theodolite.util.ConfigurationOverride
 import theodolite.util.LoadDimension
 import theodolite.util.Resource
@@ -26,17 +26,17 @@ class BenchmarkExecutorImpl(
         benchmarkDeployment.setup()
         this.waitAndLog()
         benchmarkDeployment.teardown()
-        // todo evaluate
 
         var result = false
         try {
-            result = ExternalSLOChecker(
-                slo.prometheusUrl,
-                "sum by(group)(kafka_consumergroup_group_lag >= 0)",
-                slo.externalSloUrl,
-                slo.threshold,
-                Duration.ofHours(slo.offset.toLong()),
-                slo.warmup
+            result = SloCheckerFactory().create(
+                slotype = slo.sloType,
+                prometheusURL = slo.prometheusUrl,
+                query = "sum by(group)(kafka_consumergroup_group_lag >= 0)",
+                externalSlopeURL = slo.externalSloUrl,
+                threshold = slo.threshold,
+                offset = Duration.ofHours(slo.offset.toLong()),
+                warmup = slo.warmup
             )
                 .evaluate(
                     Instant.now().minus(executionDuration),

theodolite-quarkus/src/main/resources/yaml/BenchmarkExecution.yaml

@@ -9,7 +9,7 @@ resources:
   resourceValues:
     - 1
 slos:
-  - sloType: "slo type"
+  - sloType: "lag trend"
     threshold: 1000
     prometheusUrl: "http://localhost:32656"
     externalSloUrl: "http://localhost:80/evaluate-slope"