Add a NodeSelectorPatcher

theodolite-quarkus/src/main/kotlin/theodolite/patcher/NodeSelectorPatcher.kt

+package theodolite.patcher
+
+import io.fabric8.kubernetes.api.model.KubernetesResource
+import io.fabric8.kubernetes.api.model.Service
+import io.fabric8.kubernetes.api.model.apps.Deployment
+
+class NodeSelectorPatcher(private val k8sResource: KubernetesResource, private val variableName: String): AbstractPatcher(k8sResource, variableName){
+    override fun <String> patch(value: String) {
+        if (k8sResource is Deployment) {
+                k8sResource.spec.template.spec.nodeSelector = mapOf(variableName to value as kotlin.String)
+        }
+    }
+}
\ No newline at end of file

theodolite-quarkus/src/main/kotlin/theodolite/patcher/PatcherManager.kt

@@ -12,6 +12,8 @@ class PatcherManager {
             "EnvVarPatcher" -> EnvVarPatcher(k8sResources.filter { it.first == patcherDefinition.resource}.map { resource -> resource.second }[0],
                                 patcherDefinition.container,
                                 patcherDefinition.variableName)
+            "NodeSelectorPatcher" -> NodeSelectorPatcher(k8sResources.filter { it.first == patcherDefinition.resource }.map { resource -> resource.second }[0],
+                                patcherDefinition.variableName)
             else -> throw IllegalArgumentException("Patcher type ${patcherDefinition.type} not found")
         }
     }

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

@@ -29,4 +29,16 @@ configOverrides:
       container: "workload-generator"
       variableName: "KAFKA_SERVER"
     value: "localhost:9192"
+  - patcher:
+      type: "NodeSelectorPatcher"
+      resource: "workloadGenerator.yaml"
+      variableName: "env"
+    value: "prod"
+  - patcher:
+      type: "NodeSelectorPatcher"
+      resource: "aggregation-deployment.yaml"
+      variableName: "env"
+    value: "prod"
+
+