Apache/openjpa
1
0
Fork 0
mirror of https://github.com/apache/openjpa.git synced 2025-03-06 08:29:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Considering only active pods for TCPRemoteCommitProvider (#85)

Browse Source
This commit is contained in:
Francesco Chicchiriccò 2021-10-25 12:25:04 +02:00 committed by GitHub
parent 9113461cb9
commit 6be0f5b061
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
openjpa-kubernetes/src/main/java/org/apache/openjpa/event/kubernetes/KubernetesTCPRemoteCommitProvider.java
View File

@ -21,6 +21,7 @@ package org.apache.openjpa.event.kubernetes;
import io.fabric8.kubernetes.client.DefaultKubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.fabric8.kubernetes.client.internal.readiness.Readiness;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
@ -67,6 +68,7 @@ public class KubernetesTCPRemoteCommitProvider extends DynamicTCPRemoteCommitPro
try (KubernetesClient client = kubernetesClient()) {
podIPs.addAll(client.pods().inNamespace(_namespace).withLabel(_label).list().
getItems().stream().
filter(Readiness::isPodReady).
map(pod -> pod.getStatus().getPodIP()).
collect(Collectors.toList()));

2
pom.xml
View File

@ -85,7 +85,7 @@
<mssql.connector.version>9.2.1.jre8</mssql.connector.version>
<!-- other common versions -->
<kubernetes-client.version>5.4.1</kubernetes-client.version>
<kubernetes-client.version>5.9.0</kubernetes-client.version>
<slf4j.version>1.7.23</slf4j.version>
<!-- Compile Java source/target class level -->
<compile.class.source>${java.class.version}</compile.class.source>