alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2758 Added polling when extracting LB url for database services

Browse Source
This commit is contained in:
jcechace 2020-11-13 03:01:36 +01:00 committed by Jiri Pechanec
parent 6d6d0a3888
commit 0befe82b76
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
debezium-testing/debezium-testing-openshift/src/main/java/io/debezium/testing/openshift/tools/databases/DatabaseController.java
View File

@ -6,6 +6,9 @@
package io.debezium.testing.openshift.tools.databases;
import static io.debezium.testing.openshift.tools.WaitConditions.scaled;
import static java.util.concurrent.TimeUnit.MINUTES;
import static java.util.concurrent.TimeUnit.SECONDS;
import static org.awaitility.Awaitility.await;
import java.util.List;
import java.util.concurrent.TimeUnit;
@ -45,12 +48,25 @@ public DatabaseController(Deployment deployment, List<Service> services, String
this.ocpUtils = new OpenShiftUtils(ocp);
}
public String getDatabaseUrl() {
Service svc = ocp
private Service getService() {
return ocp
.services()
.inNamespace(project)
.withName(deployment.getMetadata().getName() + "-lb")
.get();
}
private void awaitIngress() {
LOGGER.info("Waiting for LoadBalancerIngress to be available");
await()
.atMost(scaled(2), MINUTES)
.pollInterval(3, SECONDS)
.until(() -> getService().getStatus().getLoadBalancer().getIngress().size() > 0);
}
public String getDatabaseUrl() {
awaitIngress();
Service svc = getService();
LoadBalancerIngress ingress = svc.getStatus().getLoadBalancer().getIngress().get(0);
String hostname = ingress.getHostname();
Integer port = svc.getSpec().getPorts().stream().filter(p -> p.getName().equals("db")).findAny().get().getPort();