Skip to content
Snippets Groups Projects

Make the analysis of experiments more flexible

Merged Benedikt Wetzel requested to merge wetzel/spesb:249-make-analysis-flexible into master
Files
12
@@ -13,7 +13,6 @@ import java.util.*
@@ -13,7 +13,6 @@ import java.util.*
import java.util.regex.Pattern
import java.util.regex.Pattern
private val logger = KotlinLogging.logger {}
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.
* Contains the analysis. Fetches a metric from Prometheus, documents it, and evaluates it.
@@ -51,7 +50,7 @@ class AnalysisExecutor(
@@ -51,7 +50,7 @@ class AnalysisExecutor(
fetcher.fetchMetric(
fetcher.fetchMetric(
start = interval.first,
start = interval.first,
end = interval.second,
end = interval.second,
query = RECORD_LAG_QUERY
query = SloConfigHandler.getQueryString(sloType = slo.sloType)
)
)
}
}
@@ -59,7 +58,7 @@ class AnalysisExecutor(
@@ -59,7 +58,7 @@ class AnalysisExecutor(
ioHandler.writeToCSVFile(
ioHandler.writeToCSVFile(
fileURL = "${fileURL}_${repetitionCounter++}",
fileURL = "${fileURL}_${repetitionCounter++}",
data = data.getResultAsList(),
data = data.getResultAsList(),
columns = listOf("group", "timestamp", "value")
columns = listOf("labels", "timestamp", "value")
)
)
}
}
Loading