NowChess/NowChessSystems
4
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

fix(coordinator): use genericKubernetesResources API for Argo Rollout scaling #43

Merged
Janis merged 1 commits from fix/coordinator-kubernetes into main 2026-05-02 21:22:54 +02:00
Conversation 0 Commits 1 Files Changed 1
+5 -2
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/coordinator/src/main/scala/de/nowchess/coordinator/service/AutoScaler.scala
+5 -2
View File
@@ -30,6 +30,9 @@ class AutoScaler:
if kubeClientInstance.isUnsatisfied then None if kubeClientInstance.isUnsatisfied then None
else Some(kubeClientInstance.get()) else Some(kubeClientInstance.get())
private val argoApiVersion = "argoproj.io/v1alpha1"
private val argoKind = "Rollout"
// scalafix:off DisableSyntax.asInstanceOf // scalafix:off DisableSyntax.asInstanceOf
// scalafix:off DisableSyntax.isInstanceOf // scalafix:off DisableSyntax.isInstanceOf
private def rolloutSpec(rollout: GenericKubernetesResource): Option[java.util.Map[String, AnyRef]] = private def rolloutSpec(rollout: GenericKubernetesResource): Option[java.util.Map[String, AnyRef]] =
@@ -61,7 +64,7 @@ class AutoScaler:
try try
Option( Option(
kube kube
.resources(classOf[GenericKubernetesResource]) .genericKubernetesResources(argoApiVersion, argoKind)
.inNamespace(config.k8sNamespace) .inNamespace(config.k8sNamespace)
.withName(config.k8sRolloutName) .withName(config.k8sRolloutName)
.get(), .get(),
@@ -102,7 +105,7 @@ class AutoScaler:
try try
Option( Option(
kube kube
.resources(classOf[GenericKubernetesResource]) .genericKubernetesResources(argoApiVersion, argoKind)
.inNamespace(config.k8sNamespace) .inNamespace(config.k8sNamespace)
.withName(config.k8sRolloutName) .withName(config.k8sRolloutName)
.get(), .get(),