Use the new workload generator

theodolite-quarkus/src/main/kotlin/theodolite/execution/TheodoliteYamlExecutor.kt

@@ -9,9 +9,9 @@ class TheodoliteYamlExecutor {
         // load the BenchmarkExecution and the BenchmarkType
         val parser = YamlParser()
         val benchmarkExecution =
-            parser.parse("./../../../resources/main/yaml/testBenchmarkExecution.yaml", BenchmarkExecution::class.java)!!
+            parser.parse("./../../../resources/main/yaml/BenchmarkExecution.yaml", BenchmarkExecution::class.java)!!
         val benchmark =
-            parser.parse("./../../../resources/main/yaml/testBenchmarkType.yaml", KubernetesBenchmark::class.java)!!
+            parser.parse("./../../../resources/main/yaml/BenchmarkType.yaml", KubernetesBenchmark::class.java)!!
 
         val executor = TheodoliteExecutor(benchmarkExecution, benchmark)
         executor.run()

theodolite-quarkus/src/main/resources/yaml/BenchmarkType.yaml

@@ -5,6 +5,7 @@ appResource:
   - "jmx-configmap.yaml"
 loadGenResource:
   - "uc1-load-generator-deployment.yaml"
+  - "uc1-load-generator-service.yaml"
 resourceTypes:
   - typeName: "Instances"
     patchers:

theodolite-quarkus/src/main/resources/yaml/uc1-load-generator-deployment.yaml

@@ -15,20 +15,22 @@ spec:
       terminationGracePeriodSeconds: 0
       containers:
         - name: workload-generator
-          image: ghcr.io/cau-se/theodolite-uc1-workload-generator:theodolite-kotlin-latest
+          image: ghcr.io/cau-se/theodolite-uc1-workload-generator:latest
+          ports:
+            - containerPort: 5701
+              name: coordination
           env:
-            # Order need to be preserved for run_uc.py
             - name: NUM_SENSORS
               value: "25000"
-            - name: INSTANCES
-              value: "1"
             - name: NUM_NESTED_GROUPS
               value: "5"
-            - name: ZK_HOST
-              value: "my-confluent-cp-zookeeper"
-            - name: ZK_PORT
-              value: "2181"
+            - name: KUBERNETES_NAMESPACE
+              valueFrom:
+                fieldRef:
+                  fieldPath: metadata.namespace
+            - name: KUBERNETES_DNS_NAME
+              value: "titan-ccp-load-generator.$(KUBERNETES_NAMESPACE).svc.cluster.local"
             - name: KAFKA_BOOTSTRAP_SERVERS
               value: "my-confluent-cp-kafka:9092"
             - name: SCHEMA_REGISTRY_URL
-              value: "http://my-confluent-cp-schema-registry:8081"
\ No newline at end of file
+              value: "http://my-confluent-cp-schema-registry:8081"

theodolite-quarkus/src/main/resources/yaml/uc1-load-generator-service.yaml

+apiVersion: v1
+kind: Service
+metadata:
+  name: titan-ccp-load-generator
+  labels:
+    app: titan-ccp-load-generator
+spec:
+  type: ClusterIP
+  clusterIP: None
+  selector:
+    app: titan-ccp-load-generator
+  ports:
+    - name: coordination
+      port: 5701
+      targetPort: 5701
+      protocol: TCP