diff --git a/helm/templates/theodolite/crd-execution.yaml b/helm/templates/theodolite/crd-execution.yaml
index f6305ad3eb01c41a44ee3e92cff100eb67321f65..163835e9b37aca774983d4f019cc61d4bde06510 100644
--- a/helm/templates/theodolite/crd-execution.yaml
+++ b/helm/templates/theodolite/crd-execution.yaml
@@ -60,9 +60,6 @@ spec:
prometheusUrl:
description: Connection string for Promehteus.
type: string
- query:
- description: The prometheus query string
- type: string
offset:
description: Hours by which the start and end timestamp will be shifted (for different timezones).
type: integer
diff --git a/theodolite/crd/crd-execution.yaml b/theodolite/crd/crd-execution.yaml
index 0debaa46dcc8cfb4e5a22ce3f8bd2d9247012fcd..d9cd41903bb2fdc18bd6640bdbe2eb764b2106ab 100644
--- a/theodolite/crd/crd-execution.yaml
+++ b/theodolite/crd/crd-execution.yaml
@@ -68,9 +68,6 @@ spec:
prometheusUrl:
description: Connection string for Promehteus.
type: string
- query:
- description: The prometheus query string
- type: string
offset:
description: Hours by which the start and end timestamp will be shifted (for different timezones).
type: integer
diff --git a/theodolite/src/main/kotlin/theodolite/benchmark/BenchmarkExecution.kt b/theodolite/src/main/kotlin/theodolite/benchmark/BenchmarkExecution.kt
index 6aeeb2c542f109ad36a62bddc0cab94c0f389159..f2dda487d390c5f771e4f47c0f9c7ebf2cf971e7 100644
--- a/theodolite/src/main/kotlin/theodolite/benchmark/BenchmarkExecution.kt
+++ b/theodolite/src/main/kotlin/theodolite/benchmark/BenchmarkExecution.kt
@@ -63,7 +63,6 @@ class BenchmarkExecution : KubernetesResource {
class Slo : KubernetesResource {
lateinit var sloType: String
lateinit var prometheusUrl: String
- lateinit var query: String
var offset by Delegates.notNull<Int>()
lateinit var properties: MutableMap<String, String>
}
diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt b/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt
index d1eadd0354de06000ca2c29522a1bc728c19581c..709dc9f0ae81ebebbf2b7863b874e41c3429f1c0 100644
--- a/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt
+++ b/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt
@@ -12,7 +12,6 @@ import java.util.*
import java.util.regex.Pattern
private val logger = KotlinLogging.logger {}
-private val RECORD_LAG_QUERY = "sum by(group)(kafka_consumergroup_group_lag >= 0)"
/**
* Contains the analysis. Fetches a metric from Prometheus, documents it, and evaluates it.
diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/SloCheckerFactory.kt b/theodolite/src/main/kotlin/theodolite/evaluation/SloCheckerFactory.kt
index 76b158a580102e209b13e247864dd7481b557638..e1ee4f4d25a095435634ebbd8c6d51ba459490b1 100644
--- a/theodolite/src/main/kotlin/theodolite/evaluation/SloCheckerFactory.kt
+++ b/theodolite/src/main/kotlin/theodolite/evaluation/SloCheckerFactory.kt
@@ -43,25 +43,25 @@ class SloCheckerFactory {
properties: MutableMap<String, String>,
load: LoadDimension
): SloChecker {
- return when (sloType) {
- "lag trend" -> ExternalSloChecker(
+ return when (sloType.toLowerCase()) {
+ SloTypes.LAG_TREND.value, SloTypes.DROPPED_RECORDS.value -> ExternalSloChecker(
externalSlopeURL = properties["externalSloUrl"]
?: throw IllegalArgumentException("externalSloUrl expected"),
threshold = properties["threshold"]?.toInt() ?: throw IllegalArgumentException("threshold expected"),
warmup = properties["warmup"]?.toInt() ?: throw IllegalArgumentException("warmup expected")
)
- "lag trend percent" -> {
+ SloTypes.LAG_TREND_PERCENTAGE.value, SloTypes.DROPPED_RECORDS_PERCENTAGE.value -> {
if (!properties["loadType"].equals("NumSensors")) {
throw IllegalArgumentException("Percent Threshold is only allowed with load type NumSensors")
}
- var thresholdPercent =
+ val thresholdPercent =
properties["percent"]?.toDouble()
?: throw IllegalArgumentException("percent for threshold expected")
if (thresholdPercent < 0.0 || thresholdPercent > 1.0) {
throw IllegalArgumentException("Threshold percent need to be an Double in the range between 0.0 and 1.0 (inclusive)")
}
// cast to int, as rounding is not really necessary
- var threshold = (load.get() * thresholdPercent).toInt()
+ val threshold = (load.get() * thresholdPercent).toInt()
ExternalSloChecker(
externalSlopeURL = properties["externalSloUrl"]
diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt b/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt
index 38f21f58654e604ace26f87005d096fd13b22b2b..27601878f59b5a30c9b6af0c649da326991c5e48 100644
--- a/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt
+++ b/theodolite/src/main/kotlin/theodolite/evaluation/SloConfigHandler.kt
@@ -1,19 +1,15 @@
package theodolite.evaluation
import theodolite.util.InvalidPatcherConfigurationException
-import theodolite.util.TheodoliteConfig
-import javax.inject.Inject
-
-class SloConfigHandler {
+import javax.enterprise.context.ApplicationScoped
+@ApplicationScoped
+class SloConfigHandler() {
companion object {
- @Inject
- lateinit var config: TheodoliteConfig
-
fun getQueryString(sloType: String): String {
- return when (sloType){
- "Lag Trend" -> config.PROM_RECORD_LAG_QUERY
- "Dropped Records" -> config.PROM_DROPPED_RECORDS_QUERY
+ return when (sloType.toLowerCase()) {
+ SloTypes.LAG_TREND.value, SloTypes.LAG_TREND_PERCENTAGE.value -> "sum by(group)(kafka_consumergroup_group_lag >= 0)"
+ SloTypes.DROPPED_RECORDS.value, SloTypes.DROPPED_RECORDS_PERCENTAGE.value -> "sum by(job) (kafka_streams_stream_task_metrics_dropped_records_total>=0)"
else -> throw InvalidPatcherConfigurationException("Could not find Prometheus query string for slo type $sloType")
}
}
diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/SloTypes.kt b/theodolite/src/main/kotlin/theodolite/evaluation/SloTypes.kt
new file mode 100644
index 0000000000000000000000000000000000000000..7a37c698e42b9dd6b863e7fd7a4c7c3df38fc374
--- /dev/null
+++ b/theodolite/src/main/kotlin/theodolite/evaluation/SloTypes.kt
@@ -0,0 +1,10 @@
+package theodolite.evaluation
+
+enum class SloTypes(val value: String) {
+ LAG_TREND("lag trend"),
+ LAG_TREND_PERCENTAGE("lag trend percentage"),
+ DROPPED_RECORDS("dropped records"),
+ DROPPED_RECORDS_PERCENTAGE("dropped records percentage")
+
+
+}
\ No newline at end of file
diff --git a/theodolite/src/main/resources/application.properties b/theodolite/src/main/resources/application.properties
index b888207f1314756784adeb60ecfe6529bee36bf3..8eb6f4862ea81fab761aa6cd4d481d08658b52dc 100644
--- a/theodolite/src/main/resources/application.properties
+++ b/theodolite/src/main/resources/application.properties
@@ -6,4 +6,4 @@ quarkus.native.additional-build-args=\
--report-unsupported-elements-at-runtime
prom.record.lag.query="sum by(group)(kafka_consumergroup_group_lag >= 0)"
-prom.dropped.records.query="todo"
+prom.dropped.records.query="sum by(job) (kafka_streams_stream_task_metrics_dropped_records_total>=0)"