diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/Benchmark.kt b/theodolite-quarkus/src/main/kotlin/theodolite/Benchmark.kt new file mode 100644 index 0000000000000000000000000000000000000000..ddb5bc913f58f319830062c86f7638b929fd86e0 --- /dev/null +++ b/theodolite-quarkus/src/main/kotlin/theodolite/Benchmark.kt @@ -0,0 +1,13 @@ +package theodolite + +class Benchmark { + + + fun start(){ + + } + + fun stop(){ + + } +} \ No newline at end of file diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/BenchmarkExecutor.kt b/theodolite-quarkus/src/main/kotlin/theodolite/BenchmarkExecutor.kt index cf31b75ed26b8f214dd455d6a05e77b8599d6f8e..afa4acfc638d90ea7ea0f03db6241b4b0093eb6a 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/BenchmarkExecutor.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/BenchmarkExecutor.kt @@ -4,11 +4,6 @@ import org.apache.kafka.clients.admin.AdminClient import org.apache.kafka.clients.admin.AdminClientConfig import org.apache.kafka.clients.admin.ListTopicsResult import org.apache.kafka.clients.admin.NewTopic -import org.apache.zookeeper.Watcher -import org.apache.zookeeper.ZooKeeper -import org.apache.zookeeper.WatchedEvent - - 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){ } } + diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/Main.kt b/theodolite-quarkus/src/main/kotlin/theodolite/Main.kt index e83c7bdff3406e73c6cb20d9d7d3fd570aff98a9..a7846edadf07bcc5f1476dd5bd4242c4682642b0 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/Main.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/Main.kt @@ -8,13 +8,7 @@ object Main { fun main(args: Array<String>) { 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() - run.resetZookeeper() + } }