Skip to content
Snippets Groups Projects
Commit 647f5b71 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Remove zookeeper from BenchmarkExecutor + Add Benchmark

parent 73522d11
No related branches found
No related tags found
5 merge requests!159Re-implementation of Theodolite with Kotlin/Quarkus,!157Update Graal Image in CI pipeline,!83WIP: Re-implementation of Theodolite with Kotlin/Quarkus,!81Feature/126 kafka communication,!78Resolve "Implement Quarkus/Kotlin protype"
This commit is part of merge request !78. Comments created here will be created in the context of that merge request.
package theodolite
class Benchmark {
fun start(){
}
fun stop(){
}
}
\ No newline at end of file
...@@ -4,11 +4,6 @@ import org.apache.kafka.clients.admin.AdminClient ...@@ -4,11 +4,6 @@ import org.apache.kafka.clients.admin.AdminClient
import org.apache.kafka.clients.admin.AdminClientConfig import org.apache.kafka.clients.admin.AdminClientConfig
import org.apache.kafka.clients.admin.ListTopicsResult import org.apache.kafka.clients.admin.ListTopicsResult
import org.apache.kafka.clients.admin.NewTopic import org.apache.kafka.clients.admin.NewTopic
import org.apache.zookeeper.Watcher
import org.apache.zookeeper.ZooKeeper
import org.apache.zookeeper.WatchedEvent
class RunUc (){ class RunUc (){
...@@ -60,23 +55,9 @@ class RunUc (){ ...@@ -60,23 +55,9 @@ class RunUc (){
} }
fun resetZookeeper(){
val watcher :Watcher = startWatcher()
val zookeeperclient = ZooKeeper(ip,60, watcher)
zookeeperclient.delete("/workload-generation", -1)
System.out.println("Deletion executed")
}
private fun startWatcher(): Watcher {
return Watcher { event ->
System.out.println(event.toString())
System.out.println(event.state.toString())
}
}
fun start_workload_generator(wg: String, dim_value:Integer, uc_id: String){ fun start_workload_generator(wg: String, dim_value:Integer, uc_id: String){
} }
} }
...@@ -8,13 +8,7 @@ object Main { ...@@ -8,13 +8,7 @@ object Main {
fun main(args: Array<String>) { fun main(args: Array<String>) {
println("Running main method") println("Running main method")
val run = RunUc()
val testtopic = mapOf<String,Int>("test" to 1)
run.createTopics(testtopic, 1.toShort())
run.deleteTopics(listOf("test"))
//Quarkus.run() //Quarkus.run()
run.resetZookeeper()
} }
} }
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