Merge branch 'master' of git.se.informatik.uni-kiel.de:she/theodolite into enhance-code-quality

execution/theodolite.yaml

@@ -9,12 +9,12 @@ spec:
         runAsUser: 0 # Set the permissions for write access to the volumes.
       containers:
         - name: lag-analysis
-          image: ghcr.io/cau-se/theodolite-slo-checker-lag-trend:theodolite-kotlin-latest
+          image: ghcr.io/cau-se/theodolite-slo-checker-lag-trend:latest
           ports:
           - containerPort: 80
             name: analysis
         - name: theodolite
-          image: ghcr.io/cau-se/theodolite:theodolite-kotlin-latest
+          image: ghcr.io/cau-se/theodolite:latest
           imagePullPolicy: Always
           env:
             - name: NAMESPACE

helm/templates/theodolite/random-scheduler/deployment.yaml

@@ -22,7 +22,7 @@ spec:
       serviceAccount: {{ include "theodolite.fullname" . }}-random-scheduler
       containers:
         - name: random-scheduler
-          image: ghcr.io/cau-se/theodolite-random-scheduler:theodolite-kotlin-latest
+          image: ghcr.io/cau-se/theodolite-random-scheduler:latest
           #imagePullPolicy: Always
           env:
             - name: TARGET_NAMESPACE

helm/values.yaml

@@ -247,7 +247,7 @@ operator:
   enabled: true
   
   image: ghcr.io/cau-se/theodolite
-  imageTag: theodolite-kotlin-latest
+  imageTag: latest
   imagePullPolicy: Always
 
   executionCRD:
@@ -259,7 +259,7 @@ operator:
     lagTrend:
       enabled: true
       image: ghcr.io/cau-se/theodolite-slo-checker-lag-trend
-      imageTag: theodolite-kotlin-latest
+      imageTag: latest
       imagePullPolicy: Always
 
   resultsVolume:

slope-evaluator/requirements.txt

-fastapi==0.55.1
+fastapi==0.65.2
 scikit-learn==0.20.3
 pandas==1.0.3
 uvicorn

theodolite-benchmarks/definitions/uc1-flink/uc1-flink-benchmark-operator.yaml

@@ -39,6 +39,8 @@ spec:
             variableName: "NUM_SENSORS"
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc1-kstreams/uc1-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc1-kstreams/uc1-benchmark-operator.yaml

@@ -24,10 +24,10 @@ spec:
           properties:
             container: "workload-generator"
             variableName: "NUM_SENSORS"
-        - type: "NumSensorsLoadGeneratorReplicaPatcher"
+        - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc1-kstreams/uc1-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc2-flink/uc2-flink-benchmark-operator.yaml

@@ -39,6 +39,8 @@ spec:
             variableName: "NUM_SENSORS"
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc2-kstreams/uc2-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc2-kstreams/uc2-benchmark-operator.yaml

@@ -27,7 +27,7 @@ spec:
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc2-kstreams/uc2-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc3-flink/uc3-flink-benchmark-operator.yaml

@@ -39,6 +39,8 @@ spec:
             variableName: "NUM_SENSORS"
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc3-kstreams/uc3-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc3-kstreams/uc3-benchmark-operator.yaml

@@ -27,7 +27,7 @@ spec:
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc3-kstreams/uc3-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc4-flink/uc4-flink-benchmark-operator.yaml

@@ -37,8 +37,11 @@ spec:
           properties:
             container: "workload-generator"
             variableName: "NUM_NESTED_GROUPS"
-        - type: "NumNestedGroupsLoadGeneratorReplicaPatcher"
+        - type: NumNestedGroupsLoadGeneratorReplicaPatcher
           resource: "uc4-kstreams/uc4-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
+            numSensors: "4.0"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:

theodolite-benchmarks/definitions/uc4-kstreams/uc4-benchmark-operator.yaml

@@ -27,7 +27,7 @@ spec:
         - type: NumNestedGroupsLoadGeneratorReplicaPatcher
           resource: "uc4-kstreams/uc4-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
             numSensors: "4.0"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"

theodolite/src/main/kotlin/theodolite/patcher/PatcherFactory.kt

@@ -78,6 +78,10 @@ class PatcherFactory {
                     k8sResource = resource,
                     container = patcherDefinition.properties["container"]!!
                 )
+                "ImagePatcher" -> ImagePatcher(
+                    k8sResource = resource,
+                    container = patcherDefinition.properties["container"]!!
+                )
                 else -> throw InvalidPatcherConfigurationException("Patcher type ${patcherDefinition.type} not found.")
             }
         } catch (e: Exception) {