Skip to content
Snippets Groups Projects
Commit df6d8e1a authored by Benedikt Wetzel's avatar Benedikt Wetzel
Browse files

begin with UC1Benchmark implementation

parent 88bc461a
No related branches found
No related tags found
4 merge requests!159Re-implementation of Theodolite with Kotlin/Quarkus,!157Update Graal Image in CI pipeline,!83WIP: Re-implementation of Theodolite with Kotlin/Quarkus,!78Resolve "Implement Quarkus/Kotlin protype"
package theodolite.evaluation
interface SLOChecker {
}
\ No newline at end of file
...@@ -15,7 +15,7 @@ class KafkaBenchmarkExecutor(benchmark: Benchmark, results: Results, executionDu ...@@ -15,7 +15,7 @@ class KafkaBenchmarkExecutor(benchmark: Benchmark, results: Results, executionDu
this.waitAndLog() this.waitAndLog()
benchmark.stop() benchmark.stop()
// todo evaluate // todo evaluate
val result = false // if success else falsew val result = false // if success else false
this.results.setResult(Pair(load, res), result) this.results.setResult(Pair(load, res), result)
return result; return result;
} }
......
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
...@@ -50,9 +50,9 @@ class WorkloadGeneratorStateCleaner(ip: String) { ...@@ -50,9 +50,9 @@ class WorkloadGeneratorStateCleaner(ip: String) {
System.out.println("ZooKeeper reset was successful") 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) {}
}
} }
...@@ -2,10 +2,10 @@ package theodolite.util ...@@ -2,10 +2,10 @@ package theodolite.util
// todo: needs cluster and resource config // todo: needs cluster and resource config
abstract class Benchmark(val config: Map<String, Any>) { abstract class Benchmark(val config: Map<String, Any>) {
abstract fun start(); abstract fun start(load: LoadDimension, resources: Resource);
abstract fun stop(); 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
...@@ -10,4 +10,8 @@ class KafkaBenchmark(config: Map<String, Any>): Benchmark(config) { ...@@ -10,4 +10,8 @@ class KafkaBenchmark(config: Map<String, Any>): Benchmark(config) {
TODO("Not yet implemented") TODO("Not yet implemented")
} }
override fun startWorkloadGenerator(wg: String, dimValue: Int, ucId: String) {
TODO("Not yet implemented")
}
} }
\ No newline at end of file
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