diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/evaluation/SLOChecker.kt b/theodolite-quarkus/src/main/kotlin/theodolite/evaluation/SLOChecker.kt new file mode 100644 index 0000000000000000000000000000000000000000..10e113fdf1110e0c8bb30cad8a4b5f04f9e82c0d --- /dev/null +++ b/theodolite-quarkus/src/main/kotlin/theodolite/evaluation/SLOChecker.kt @@ -0,0 +1,4 @@ +package theodolite.evaluation + +interface SLOChecker { +} \ No newline at end of file diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/KafkaBenchmarkExecutor.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/KafkaBenchmarkExecutor.kt index e019e80d08d1c3b968311a4227a11b74b5c9368b..9a3885e2540b6828e4d2d78273738c0e122d9ca3 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/KafkaBenchmarkExecutor.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/KafkaBenchmarkExecutor.kt @@ -15,7 +15,7 @@ class KafkaBenchmarkExecutor(benchmark: Benchmark, results: Results, executionDu this.waitAndLog() benchmark.stop() // todo evaluate - val result = false // if success else falsew + val result = false // if success else false this.results.setResult(Pair(load, res), result) return result; } diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/UC1Benchmark.kt b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/UC1Benchmark.kt new file mode 100644 index 0000000000000000000000000000000000000000..75ba7f42f76f7b67b200d54b91baf1f30a4692b9 --- /dev/null +++ b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/UC1Benchmark.kt @@ -0,0 +1,20 @@ +package theodolite.k8s + +import theodolite.util.Benchmark +import theodolite.util.LoadDimension +import theodolite.util.Resource + +class UC1Benchmark(config: Map<String, Any>) : Benchmark(config) { + override fun start(load: LoadDimension, resources: Resource) { + TODO("Not yet implemented") + } + + override fun stop() { + TODO("Not yet implemented") + } + + override fun startWorkloadGenerator(wg: String, load: LoadDimension, ucId: String) { + TODO("Not yet implemented") + } + +} \ No newline at end of file diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/WorkloadGeneratorStateCleaner.kt b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/WorkloadGeneratorStateCleaner.kt index c519b0c843ae3f75c21a7596446c700972b44753..5ab9ad222756383cc841768a12a6aa72cab165a1 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/WorkloadGeneratorStateCleaner.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/WorkloadGeneratorStateCleaner.kt @@ -50,9 +50,9 @@ class WorkloadGeneratorStateCleaner(ip: String) { System.out.println("ZooKeeper reset was successful") } -} -private class ZookeperWatcher : Watcher { + private class ZookeperWatcher : Watcher { - override fun process(event: WatchedEvent) {} + override fun process(event: WatchedEvent) {} + } } diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/util/Benchmark.kt b/theodolite-quarkus/src/main/kotlin/theodolite/util/Benchmark.kt index c3ddab0fa64a71a948096ebb9d6805e30e57e184..e9add1a506f85205c20b006ee43deb28045d0b40 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/util/Benchmark.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/util/Benchmark.kt @@ -2,10 +2,10 @@ package theodolite.util // todo: needs cluster and resource config abstract class Benchmark(val config: Map<String, Any>) { - abstract fun start(); + abstract fun start(load: LoadDimension, resources: Resource); abstract fun stop(); - abstract fun startWorkloadGenerator(wg: String, dimValue: Int, ucId: String); + abstract fun startWorkloadGenerator(wg: String, load: LoadDimension, ucId: String); } \ No newline at end of file diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaBenchmark.kt b/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaBenchmark.kt index 3ed499bf6f4f2dfc16b7af6c297be424ac2ba8a7..74201393b07e8f5e480ee8360f5265fb388fd4d1 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaBenchmark.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaBenchmark.kt @@ -10,4 +10,8 @@ class KafkaBenchmark(config: Map<String, Any>): Benchmark(config) { TODO("Not yet implemented") } + override fun startWorkloadGenerator(wg: String, dimValue: Int, ucId: String) { + TODO("Not yet implemented") + } + } \ No newline at end of file