Restructuring

theodolite-quarkus/src/main/kotlin/theodolite/GreetingResource.kt

-package theodolite
-
-import javax.ws.rs.GET
-import javax.ws.rs.Path
-import javax.ws.rs.Produces
-import javax.ws.rs.core.MediaType
-
-@Path("/hello-resteasy")
-class GreetingResource {
-
-    @GET
-    @Produces(MediaType.TEXT_PLAIN)
-    fun hello() = "Hello RESTEasy"
-}
\ No newline at end of file

theodolite-quarkus/src/main/kotlin/theodolite/Main.kt

@@ -2,6 +2,7 @@ package theodolite
 
 import io.quarkus.runtime.annotations.QuarkusMain
 import mu.KotlinLogging
+import theodolite.execution.DeploymentManager
 
 private val logger = KotlinLogging.logger {}
 

theodolite-quarkus/src/main/kotlin/theodolite/Benchmark.kt → theodolite-quarkus/src/main/kotlin/theodolite/execution/Benchmark.kt

-package theodolite
+package theodolite.execution
 
 class Benchmark {
     fun start() {}
 
     fun stop() {}
 
-    fun startWorkloadGenerator(wg: String, dimValue: Int, ucId: String) { }
+    fun startWorkloadGenerator(wg: String, dimValue: Int, ucId: String) {}
 }

theodolite-quarkus/src/main/kotlin/theodolite/BenchmarkExecutor.kt → theodolite-quarkus/src/main/kotlin/theodolite/execution/BenchmarkExecutor.kt

-package theodolite
+package theodolite.execution
 
 class BenchmarkExecutor(benchmark: Benchmark) {
     val benchmark: Benchmark = benchmark
 
     fun waitExecution(executionMinutes: Int) {
-    val milliToMinutes = 60000
-    System.out.println("Wait while executing")
-    for (i in 1.rangeTo(executionMinutes)) {
-       Thread.sleep((milliToMinutes * i).toLong())
-       System.out.println("Executed: $i minutes")
+        val milliToMinutes = 60000
+        System.out.println("Wait while executing")
+        for (i in 1.rangeTo(executionMinutes)) {
+            Thread.sleep((milliToMinutes * i).toLong())
+            System.out.println("Executed: $i minutes")
+        }
+
+        System.out.println("Execution finished")
     }
 
-    System.out.println("Execution finished")
- }
     fun runExperiment() {}
 }

theodolite-quarkus/src/main/kotlin/theodolite/ConfigMapManager.kt → theodolite-quarkus/src/main/kotlin/theodolite/execution/ConfigMapManager.kt

-package theodolite
+package theodolite.execution
 
 import io.fabric8.kubernetes.api.model.ConfigMap
 import io.fabric8.kubernetes.client.NamespacedKubernetesClient

theodolite-quarkus/src/main/kotlin/theodolite/DeploymentManager.kt → theodolite-quarkus/src/main/kotlin/theodolite/execution/DeploymentManager.kt

-package theodolite
+package theodolite.execution
 
 import io.fabric8.kubernetes.api.model.Container
 import io.fabric8.kubernetes.api.model.EnvVar

theodolite-quarkus/src/main/kotlin/theodolite/ServiceManager.kt → theodolite-quarkus/src/main/kotlin/theodolite/execution/ServiceManager.kt

-package theodolite
+package theodolite.execution
 
 import io.fabric8.kubernetes.api.model.Service
 import io.fabric8.kubernetes.client.NamespacedKubernetesClient

theodolite-quarkus/src/main/kotlin/theodolite/YamlLoader.kt → theodolite-quarkus/src/main/kotlin/theodolite/execution/YamlLoader.kt

-package theodolite
+package theodolite.execution
 
 import io.fabric8.kubernetes.api.model.ConfigMap
 import io.fabric8.kubernetes.api.model.Service

theodolite-quarkus/src/main/kotlin/theodolite/TopicManager.kt → theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt

-package theodolite
+package theodolite.k8s
 
 import org.apache.kafka.clients.admin.AdminClient
 import org.apache.kafka.clients.admin.AdminClientConfig
@@ -12,7 +12,7 @@ class TopicManager(boostrapIp: String) {
     init {
         try {
             kafkaAdmin = AdminClient.create(props)
-        } catch (e : Exception) {
+        } catch (e: Exception) {
             System.out.println(e.toString())
         }
     }
@@ -45,7 +45,7 @@ class TopicManager(boostrapIp: String) {
 
         try {
             result.all().get()
-        } catch (ex:Exception) {
+        } catch (ex: Exception) {
             System.out.println(ex.toString())
         }
         System.out.println("Topics deleted")

theodolite-quarkus/src/main/kotlin/theodolite/WorkloadGeneratorStateCleaner.kt → theodolite-quarkus/src/main/kotlin/theodolite/k8s/WorkloadGeneratorStateCleaner.kt

-package theodolite
+package theodolite.k8s
 
 import org.apache.zookeeper.KeeperException
 import org.apache.zookeeper.WatchedEvent
@@ -15,7 +15,7 @@ class WorkloadGeneratorStateCleaner(ip: String) {
         try {
             val watcher: Watcher = ZookeperWatcher()  // defined below
             zookeeperClient = ZooKeeper(ip, sessionTimeout, watcher)
-        } catch (e:Exception) {
+        } catch (e: Exception) {
             System.out.println(e.toString())
         }
     }
@@ -33,12 +33,14 @@ class WorkloadGeneratorStateCleaner(ip: String) {
 
             try {
                 val clients = zookeeperClient.getChildren(path, true)
-                if (clients.isEmpty()){
+                if (clients.isEmpty()) {
                     break;
                 }
             } catch (ex: Exception) {
                 when (ex) {
-                    is KeeperException -> { deleted = true }
+                    is KeeperException -> {
+                        deleted = true
+                    }
                     is InterruptedException -> {
                         System.out.println(ex.toString())
                     }

theodolite-quarkus/src/native-test/kotlin/theodolite/NativeGreetingResourceIT.kt

-package theodolite
-
-import io.quarkus.test.junit.NativeImageTest
-
-@NativeImageTest
-class NativeGreetingResourceIT : GreetingResourceTest()
\ No newline at end of file