WIP: Re-implementation of Theodolite with Kotlin/Quarkus

Merge the new Theodolite implementation written in Kotlin. This issue fixed #148 (closed).

theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmark.kt

@@ -2,10 +2,14 @@ package theodolite.benchmark
 
 import io.fabric8.kubernetes.api.model.KubernetesResource
 import io.fabric8.kubernetes.client.DefaultKubernetesClient
+import mu.KotlinLogging
 import theodolite.k8s.K8sResourceLoader
 import theodolite.patcher.PatcherManager
 import theodolite.util.*
-import java.util.*
+
+private val logger = KotlinLogging.logger {}
+
+private var DEFAULT_NAMESPACE = "default"
 
 class KubernetesBenchmark : Benchmark {
     lateinit var name: String
@@ -14,11 +18,16 @@ class KubernetesBenchmark : Benchmark {
     lateinit var resourceTypes: List<TypeName>
     lateinit var loadTypes: List<TypeName>
     lateinit var kafkaConfig: KafkaConfig
+    lateinit var namespace: String
 
     private fun loadKubernetesResources(resources: List<String>): List<Pair<String, KubernetesResource>> {
         val basePath = "./../../../resources/main/yaml/"
         val parser = YamlParser()
-        val loader = K8sResourceLoader(DefaultKubernetesClient().inNamespace("theodolite-she"))
+
+        namespace = System.getenv("NAMESPACE") ?: DEFAULT_NAMESPACE
+        logger.info { "Using $namespace as namespace." }
+
+        val loader = K8sResourceLoader(DefaultKubernetesClient().inNamespace(namespace))
         return resources
             .map { resource ->
                 val resourcePath = "$basePath/$resource"
@@ -50,6 +59,7 @@ class KubernetesBenchmark : Benchmark {
         }
 
         return KubernetesBenchmarkDeployment(
+            namespace = namespace,
             resources = resources.map { r -> r.second },
             kafkaConfig = hashMapOf("bootstrap.servers" to kafkaConfig.bootstrapServer),
             topics = kafkaConfig.getKafkaTopics()