Skip to content
Snippets Groups Projects
Commit b95c7afc authored by Sören Henning's avatar Sören Henning
Browse files

Improve code style

parent c6b073a0
No related branches found
No related tags found
No related merge requests found
Pipeline #10032 passed
......@@ -2,7 +2,6 @@ package rocks.theodolite.kubernetes.slo
import khttp.post
import mu.KotlinLogging
import rocks.theodolite.kubernetes.util.PrometheusResponse
import java.net.ConnectException
/**
......@@ -23,7 +22,7 @@ class ExternalSloChecker(
/**
* Evaluates an experiment using an external service.
* Will try to reach the external service until success or [RETRIES] times.
* Each request will timeout after [TIMEOUT].
* Each request will time out after [TIMEOUT].
*
* @param fetchedData that should be evaluated
* @return true if the experiment was successful (the threshold was not exceeded).
......
......@@ -4,7 +4,6 @@ import com.google.gson.Gson
import khttp.get
import khttp.responses.Response
import mu.KotlinLogging
import rocks.theodolite.kubernetes.util.PrometheusResponse
import java.net.ConnectException
import java.time.Duration
import java.time.Instant
......
package rocks.theodolite.kubernetes.util
package rocks.theodolite.kubernetes.slo
import io.quarkus.runtime.annotations.RegisterForReflection
import java.util.*
......
package rocks.theodolite.kubernetes.slo
import rocks.theodolite.kubernetes.util.PrometheusResponse
/**
* A SloChecker can be used to evaluate data from Prometheus.
* @constructor Creates an empty SloChecker
......
......@@ -19,8 +19,8 @@ class SloConfigHandler {
"sum by(consumergroup) ($DEFAULT_CONSUMER_LAG_METRIC_BASE$it >= 0)"
}
SloTypes.DROPPED_RECORDS.value, SloTypes.DROPPED_RECORDS_RATIO.value -> slo.properties["promQLQuery"] ?: DEFAULT_DROPPED_RECORDS_QUERY
SloTypes.LAG_TREND.value, SloTypes.LAG_TREND_RATIO.value -> slo.properties["promQLQuery"] ?: DEFAULT_CONSUMER_LAG_QUERY
SloTypes.DROPPED_RECORDS.value, SloTypes.DROPPED_RECORDS_RATIO.value -> slo.properties["promQLQuery"] ?: DEFAULT_DROPPED_RECORDS_QUERY
SloTypes.LAG_TREND.value, SloTypes.LAG_TREND_RATIO.value -> slo.properties["promQLQuery"] ?: DEFAULT_CONSUMER_LAG_QUERY // TODO reachable?
SloTypes.DROPPED_RECORDS.value, SloTypes.DROPPED_RECORDS_RATIO.value -> slo.properties["promQLQuery"] ?: DEFAULT_DROPPED_RECORDS_QUERY // TODO reachable?
else -> throw InvalidPatcherConfigurationException("Could not find Prometheus query string for slo type ${slo.sloType}")
}
}
......
package rocks.theodolite.kubernetes.slo
import com.google.gson.Gson
import rocks.theodolite.kubernetes.util.PromResult
class SloJson constructor(
val results: List<List<PromResult>>,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment