Skip to content

Commit 0b9e84b

Browse files
committed
Use upstream readiness check for Kubernetes
1 parent af88e59 commit 0b9e84b

File tree

1 file changed

+2
-15
lines changed

1 file changed

+2
-15
lines changed

extensions/kubernetes-client/deployment/src/main/java/io/quarkus/kubernetes/client/deployment/DevServicesKubernetesProcessor.java

Lines changed: 2 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import java.util.function.Supplier;
2121
import java.util.stream.Collectors;
2222

23+
import io.fabric8.kubernetes.client.readiness.Readiness;
2324
import org.jboss.logging.Logger;
2425
import org.testcontainers.DockerClientFactory;
2526
import org.testcontainers.containers.ContainerState;
@@ -45,9 +46,6 @@
4546
import com.github.dockerjava.api.command.InspectContainerResponse;
4647

4748
import io.fabric8.kubernetes.api.model.*;
48-
import io.fabric8.kubernetes.api.model.apps.Deployment;
49-
import io.fabric8.kubernetes.api.model.apps.ReplicaSet;
50-
import io.fabric8.kubernetes.api.model.apps.StatefulSet;
5149
import io.fabric8.kubernetes.client.*;
5250
import io.fabric8.kubernetes.client.Config;
5351
import io.quarkus.deployment.Feature;
@@ -218,7 +216,7 @@ public void applyManifests(
218216
resources.forEach(resource -> {
219217
client.resource(resource).create();
220218

221-
if (isReadinessApplicable(resource)) {
219+
if (Readiness.getInstance().isReadinessApplicable(resource)) {
222220
resourcesWithReadiness.add(resource);
223221
}
224222
});
@@ -242,17 +240,6 @@ public void applyManifests(
242240
}
243241
}
244242

245-
private boolean isReadinessApplicable(HasMetadata item) {
246-
return (item instanceof Deployment ||
247-
item instanceof io.fabric8.kubernetes.api.model.extensions.Deployment ||
248-
item instanceof ReplicaSet ||
249-
item instanceof Pod ||
250-
item instanceof ReplicationController ||
251-
item instanceof Endpoints ||
252-
item instanceof Node ||
253-
item instanceof StatefulSet);
254-
}
255-
256243
private InputStream getManifestStream(String manifestPath) throws IOException {
257244
try {
258245
URL url = new URL(manifestPath);

0 commit comments

Comments
 (0)