chore: Only request running pods from Kubernetes API (#1322)

akka · Sep 26, 2024 · fb1e26f · fb1e26f
1 parent 555ed88
commit fb1e26f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...re-api/src/main/scala/akka/discovery/azureapi/rbac/aks/AzureRbacAksServiceDiscovery.scala b/...re-api/src/main/scala/akka/discovery/azureapi/rbac/aks/AzureRbacAksServiceDiscovery.scala
@@ -209,7 +209,7 @@ final class AzureRbacAksServiceDiscovery(implicit system: ExtendedActorSystem) e
     val host = settings.apiServiceHost
     val port = settings.apiServicePort
     val path = Uri.Path.Empty / "api" / "v1" / "namespaces" / namespace / "pods"
-    val query = Uri.Query("labelSelector" -> labelSelector)
+    val query = Uri.Query("labelSelector" -> labelSelector, "fieldSelector" -> "status.phase==Running")
     val uri = Uri.from(scheme = "https", host = host, port = port).withPath(path).withQuery(query)
 
     Future(HttpRequest(uri = uri, headers = List(Authorization(OAuth2BearerToken(token)))))

diff --git a/...bernetes-api/src/main/scala/akka/discovery/kubernetes/KubernetesApiServiceDiscovery.scala b/...bernetes-api/src/main/scala/akka/discovery/kubernetes/KubernetesApiServiceDiscovery.scala
@@ -221,7 +221,7 @@ class KubernetesApiServiceDiscovery(implicit system: ActorSystem) extends Servic
       port <- Try(portStr.toInt).toOption
     } yield {
       val path = Uri.Path.Empty / "api" / "v1" / "namespaces" / namespace / "pods"
-      val query = Uri.Query("labelSelector" -> labelSelector)
+      val query = Uri.Query("labelSelector" -> labelSelector, "fieldSelection" -> "status.phase==Running")
       val uri = Uri.from(scheme = "https", host = host, port = port).withPath(path).withQuery(query)
 
       HttpRequest(uri = uri, headers = List(Authorization(OAuth2BearerToken(token))))