Skip to content

Commit fb1e26f

Browse files
authored
chore: Only request running pods from Kubernetes API (#1322)
1 parent 555ed88 commit fb1e26f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Diff for: discovery-azure-api/src/main/scala/akka/discovery/azureapi/rbac/aks/AzureRbacAksServiceDiscovery.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ final class AzureRbacAksServiceDiscovery(implicit system: ExtendedActorSystem) e
209209
val host = settings.apiServiceHost
210210
val port = settings.apiServicePort
211211
val path = Uri.Path.Empty / "api" / "v1" / "namespaces" / namespace / "pods"
212-
val query = Uri.Query("labelSelector" -> labelSelector)
212+
val query = Uri.Query("labelSelector" -> labelSelector, "fieldSelector" -> "status.phase==Running")
213213
val uri = Uri.from(scheme = "https", host = host, port = port).withPath(path).withQuery(query)
214214

215215
Future(HttpRequest(uri = uri, headers = List(Authorization(OAuth2BearerToken(token)))))

Diff for: discovery-kubernetes-api/src/main/scala/akka/discovery/kubernetes/KubernetesApiServiceDiscovery.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ class KubernetesApiServiceDiscovery(implicit system: ActorSystem) extends Servic
221221
port <- Try(portStr.toInt).toOption
222222
} yield {
223223
val path = Uri.Path.Empty / "api" / "v1" / "namespaces" / namespace / "pods"
224-
val query = Uri.Query("labelSelector" -> labelSelector)
224+
val query = Uri.Query("labelSelector" -> labelSelector, "fieldSelection" -> "status.phase==Running")
225225
val uri = Uri.from(scheme = "https", host = host, port = port).withPath(path).withQuery(query)
226226

227227
HttpRequest(uri = uri, headers = List(Authorization(OAuth2BearerToken(token))))

0 commit comments

Comments
 (0)