diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/DeploymentManager.kt b/theodolite-quarkus/src/main/kotlin/theodolite/DeploymentManager.kt index 41b92089910d1745388ce4137fd89bae1c6c2e81..a06f0354a3d4cdad1c71a159fefe7b65d318b3cf 100644 --- a/theodolite-quarkus/src/main/kotlin/theodolite/DeploymentManager.kt +++ b/theodolite-quarkus/src/main/kotlin/theodolite/DeploymentManager.kt @@ -16,7 +16,7 @@ class DeploymentManager { val path = "/home/lorenz/git/spesb/theodolite-quarkus/YAML/" val theodoliteDeploment = "theodolite.yaml" val service = "aggregation-service.yaml" - val workload = "workloadGenerator" + val workloadFile = "workloadGenerator.yaml" val inputStream: InputStream = path.byteInputStream() val client = DefaultKubernetesClient().inNamespace("default") @@ -24,14 +24,17 @@ class DeploymentManager { val dp: Service = client.services().load(path+service).get(); + val workload : Deployment = client.apps().deployments().load(path+workloadFile).get(); + + // TODO MAKE YAML LOADING CATCH EXEPTION - fun printFile(){ - - println() + fun printFile(){ - println(dp.toString()) + //println(workload) + changeWorkloadNumInstances(workload,5000) + //println(workload) println(path) @@ -48,5 +51,19 @@ class DeploymentManager { } } + fun changeWorkloadNumInstances (dep: Deployment,num: String){ + + val vars = dep.spec.template.spec.containers.get(0).env.filter { + it.name == "NUM_SENSORS" + }.forEach { + x -> + x.value = num + } + + + println(vars) + + } + }