Allow configuring port of http probes

extensions/kubernetes/kind/deployment/src/main/java/io/quarkus/kind/deployment/KindProcessor.java

@@ -41,6 +41,7 @@
 import io.quarkus.kubernetes.spi.KubernetesJobBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesLabelBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesPortBuildItem;
+import io.quarkus.kubernetes.spi.KubernetesProbePortNameBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesResourceMetadataBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBindingBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBuildItem;
@@ -104,6 +105,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
             Optional<ContainerImageInfoBuildItem> image,
             Optional<KubernetesCommandBuildItem> command,
             List<KubernetesPortBuildItem> ports,
+            Optional<KubernetesProbePortNameBuildItem> portName,
             Optional<KubernetesHealthLivenessPathBuildItem> livenessPath,
             Optional<KubernetesHealthReadinessPathBuildItem> readinessPath,
             List<KubernetesRoleBuildItem> roles,
@@ -112,6 +114,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
 
         return DevClusterHelper.createDecorators(KIND, applicationInfo, outputTarget, config, packageConfig,
                 metricsConfiguration, initContainers, jobs, annotations, labels, envs, baseImage, image, command, ports,
+                portName,
                 livenessPath,
                 readinessPath,
                 roles, roleBindings, customProjectRoot);

extensions/kubernetes/minikube/deployment/src/main/java/io/quarkus/minikube/deployment/MinikubeProcessor.java

@@ -38,6 +38,7 @@
 import io.quarkus.kubernetes.spi.KubernetesJobBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesLabelBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesPortBuildItem;
+import io.quarkus.kubernetes.spi.KubernetesProbePortNameBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesResourceMetadataBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBindingBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBuildItem;
@@ -100,6 +101,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
             Optional<ContainerImageInfoBuildItem> image,
             Optional<KubernetesCommandBuildItem> command,
             List<KubernetesPortBuildItem> ports,
+            Optional<KubernetesProbePortNameBuildItem> portName,
             Optional<KubernetesHealthLivenessPathBuildItem> livenessPath,
             Optional<KubernetesHealthReadinessPathBuildItem> readinessPath,
             List<KubernetesRoleBuildItem> roles,
@@ -108,6 +110,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
 
         return DevClusterHelper.createDecorators(MINIKUBE, applicationInfo, outputTarget, config, packageConfig,
                 metricsConfiguration, initContainers, jobs, annotations, labels, envs, baseImage, image, command, ports,
+                portName,
                 livenessPath,
                 readinessPath,
                 roles, roleBindings, customProjectRoot);

extensions/kubernetes/spi/src/main/java/io/quarkus/kubernetes/spi/KubernetesProbePortNameBuildItem.java

@@ -0,0 +1,19 @@
+package io.quarkus.kubernetes.spi;
+
+import io.quarkus.builder.item.SimpleBuildItem;
+
+/**
+ * A build item for selecting which port to use for probes using an {@literal HTTP get} action.
+ */
+public class KubernetesProbePortNameBuildItem extends SimpleBuildItem {
+
+    private final String name;
+
+    public KubernetesProbePortNameBuildItem(String name) {
+        this.name = name;
+    }
+
+    public String getName() {
+        return name;
+    }
+}

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/ApplyHttpGetActionPortDecorator.java

@@ -1,33 +1,89 @@
-
 package io.quarkus.kubernetes.deployment;
 
+import static io.dekorate.utils.Metadata.getMetadata;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
 import io.dekorate.kubernetes.decorator.AddLivenessProbeDecorator;
 import io.dekorate.kubernetes.decorator.AddReadinessProbeDecorator;
 import io.dekorate.kubernetes.decorator.AddSidecarDecorator;
-import io.dekorate.kubernetes.decorator.ApplicationContainerDecorator;
 import io.dekorate.kubernetes.decorator.Decorator;
 import io.dekorate.kubernetes.decorator.ResourceProvidingDecorator;
+import io.fabric8.kubernetes.api.builder.Builder;
+import io.fabric8.kubernetes.api.model.ContainerBuilder;
 import io.fabric8.kubernetes.api.model.HTTPGetActionFluent;
 
-public class ApplyHttpGetActionPortDecorator extends ApplicationContainerDecorator<HTTPGetActionFluent<?>> {
+public class ApplyHttpGetActionPortDecorator extends Decorator<HTTPGetActionFluent<?>> {
 
+    private final String deployment;
+    private final String container;
     private final Integer port;
+    private final String probeKind;
 
     public ApplyHttpGetActionPortDecorator(Integer port) {
-        this(ANY, ANY, port);
+        this(ANY, ANY, port, ANY);
+    }
+
+    public ApplyHttpGetActionPortDecorator(Integer port, String probeKind) {
+        this(ANY, ANY, port, probeKind);
     }
 
     public ApplyHttpGetActionPortDecorator(String deployment, Integer port) {
-        this(deployment, ANY, port);
+        this(deployment, ANY, port, ANY);
+    }
+
+    public ApplyHttpGetActionPortDecorator(String deployment, Integer port, String probeKind) {
+        this(deployment, ANY, port, probeKind);
     }
 
     public ApplyHttpGetActionPortDecorator(String deployment, String container, Integer port) {
-        super(deployment, container);
+        this(deployment, container, port, ANY);
+    }
+
+    public ApplyHttpGetActionPortDecorator(String deployment, String container, Integer port, String probeKind) {
+        this.deployment = deployment;
+        this.container = container;
         this.port = port;
+        this.probeKind = probeKind;
+    }
+
+    @Override
+    public void visit(List<Map.Entry<String, Object>> path, HTTPGetActionFluent<?> action) {
+        boolean inMatchingProbe = probeKind == ANY || path.stream().map(e -> e.getKey()).anyMatch(i -> i.equals(probeKind));
+        if (!inMatchingProbe) {
+            return;
+        }
+
+        boolean inMatchingContainer = container == ANY || path.stream()
+                .map(e -> e.getValue())
+                .filter(v -> v instanceof ContainerBuilder)
+                .map(v -> (ContainerBuilder) v)
+                .anyMatch(c -> c.getName() != null && c.getName().equals(container));
+
+        if (!inMatchingContainer) {
+            return;
+        }
+
+        boolean inMatchingResource = deployment == ANY || path.stream()
+                .map(e -> e.getValue())
+                .filter(v -> v instanceof Builder)
+                .map(v -> (Builder) v)
+                .map(b -> getMetadata(b))
+                .filter(m -> m.isPresent())
+                .map(Optional::get)
+                .anyMatch(m -> m.getName() != null && m.getName().equals(deployment));
+
+        if (!inMatchingResource) {
+            return;
+        }
+
+        visit(action);
     }
 
     @Override
-    public void andThenVisit(HTTPGetActionFluent<?> action) {
+    public void visit(HTTPGetActionFluent<?> action) {
         if (port == null) {
             // workaround to make sure we don't get a NPE
             action.withNewPort((String) null);

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/ChangeDeploymentTriggerDecorator.java

@@ -13,4 +13,5 @@ public ChangeDeploymentTriggerDecorator(String containerName, String imageStream
     public Class<? extends Decorator>[] after() {
         return new Class[] { ApplyDeploymentTriggerDecorator.class, RemoveDeploymentTriggerDecorator.class };
     }
+
 }

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/DevClusterHelper.java

@@ -1,7 +1,6 @@
 
 package io.quarkus.kubernetes.deployment;
 
-import static io.quarkus.kubernetes.deployment.Constants.DEFAULT_HTTP_PORT;
 import static io.quarkus.kubernetes.deployment.Constants.KUBERNETES;
 import static io.quarkus.kubernetes.deployment.Constants.MAX_NODE_PORT_VALUE;
 import static io.quarkus.kubernetes.deployment.Constants.MAX_PORT_NUMBER;
@@ -42,6 +41,7 @@
 import io.quarkus.kubernetes.spi.KubernetesJobBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesLabelBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesPortBuildItem;
+import io.quarkus.kubernetes.spi.KubernetesProbePortNameBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBindingBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBuildItem;
 
@@ -64,6 +64,7 @@ public static List<DecoratorBuildItem> createDecorators(String clusterKind,
             Optional<ContainerImageInfoBuildItem> image,
             Optional<KubernetesCommandBuildItem> command,
             List<KubernetesPortBuildItem> ports,
+            Optional<KubernetesProbePortNameBuildItem> portName,
             Optional<KubernetesHealthLivenessPathBuildItem> livenessPath,
             Optional<KubernetesHealthReadinessPathBuildItem> readinessPath,
             List<KubernetesRoleBuildItem> roles,
@@ -118,8 +119,14 @@ public static List<DecoratorBuildItem> createDecorators(String clusterKind,
         }
 
         //Probe port handling
-        Integer portNumber = port.map(Port::getContainerPort).orElse(DEFAULT_HTTP_PORT);
-        result.add(new DecoratorBuildItem(clusterKind, new ApplyHttpGetActionPortDecorator(name, name, portNumber)));
+        result.add(
+                KubernetesCommonHelper.createProbeHttpPortDecorator(name, clusterKind, "livenessProbe", config.livenessProbe,
+                        portName,
+                        ports));
+        result.add(
+                KubernetesCommonHelper.createProbeHttpPortDecorator(name, clusterKind, "readinessProbe", config.readinessProbe,
+                        portName,
+                        ports));
 
         // Handle init Containers
         result.addAll(KubernetesCommonHelper.createInitContainerDecorators(clusterKind, name, initContainers, result));

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/KnativeProcessor.java

@@ -282,7 +282,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
         result.add(new DecoratorBuildItem(KNATIVE, new ApplyServiceTypeDecorator(name, config.getServiceType().name())));
 
         //In Knative its expected that all http ports in probe are omitted (so we set them to null).
-        result.add(new DecoratorBuildItem(KNATIVE, new ApplyHttpGetActionPortDecorator(name, null)));
+        result.add(new DecoratorBuildItem(KNATIVE, new ApplyHttpGetActionPortDecorator(name, (Integer) null)));
 
         //Traffic Splitting
         config.revisionName.ifPresent(r -> {

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/KubernetesCommonHelper.java

@@ -2,6 +2,8 @@
 package io.quarkus.kubernetes.deployment;
 
 import static io.dekorate.kubernetes.decorator.AddServiceResourceDecorator.distinct;
+import static io.quarkus.kubernetes.deployment.Constants.DEFAULT_HTTP_PORT;
+import static io.quarkus.kubernetes.deployment.Constants.HTTP_PORT;
 import static io.quarkus.kubernetes.deployment.Constants.QUARKUS_ANNOTATIONS_BUILD_TIMESTAMP;
 import static io.quarkus.kubernetes.deployment.Constants.QUARKUS_ANNOTATIONS_COMMIT_ID;
 import static io.quarkus.kubernetes.deployment.Constants.QUARKUS_ANNOTATIONS_VCS_URL;
@@ -81,6 +83,7 @@
 import io.quarkus.kubernetes.spi.KubernetesJobBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesLabelBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesPortBuildItem;
+import io.quarkus.kubernetes.spi.KubernetesProbePortNameBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBindingBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBuildItem;
 
@@ -687,6 +690,46 @@ private static List<DecoratorBuildItem> createAnnotationDecorators(Optional<Proj
         return result;
     }
 
+    /**
+     * Create a decorator that sets the port to the http probe.
+     * The rules for setting the probe are the following:
+     * 1. if 'http-action-port' is set, use that.
+     * 2. if 'http-action-port-name' is set, use that to lookup the port value.
+     * 3. if a `KubernetesPorbePortBuild` is set, then use that to lookup the port.
+     * 4. if we still haven't found a port fallback to 8080.
+     *
+     * @param name The name of the deployment / container.
+     * @param target The deployment target
+     * @param the probe kind (e.g. readinessProbe, livenessProbe etc)
+     * @param portName the probe port name build item
+     * @paramt ports a list of kubernetes port build items
+     * @return a decorator for configures the port of the http action of the probe.
+     */
+    public static DecoratorBuildItem createProbeHttpPortDecorator(String name, String target, String probeKind,
+            ProbeConfig probeConfig,
+            Optional<KubernetesProbePortNameBuildItem> portName,
+            List<KubernetesPortBuildItem> ports) {
+
+        //1. check if `httpActionPort` is defined
+        //2. lookup port by `httpPortName`
+        //3. fallback to DEFAULT_HTTP_PORT
+        String httpPortName = probeConfig.httpActionPortName
+                .or(() -> portName.map(KubernetesProbePortNameBuildItem::getName))
+                .orElse(HTTP_PORT);
+
+        Integer port = probeConfig.httpActionPort
+                .orElse(ports.stream().filter(p -> httpPortName.equals(p.getName()))
+                        .map(KubernetesPortBuildItem::getPort).findFirst().orElse(DEFAULT_HTTP_PORT));
+        return new DecoratorBuildItem(target, new ApplyHttpGetActionPortDecorator(name, name, port, probeKind));
+    }
+
+    /**
+     * Create the decorators needed for setting up probes.
+     * The method will not create decorators related to ports, as they are not supported by all targets (e.g. knative)
+     * Port related decorators are created by `applyProbePort` instead.
+     *
+     * @return a list of decorators that configure the probes
+     */
     private static List<DecoratorBuildItem> createProbeDecorators(String name, String target, ProbeConfig livenessProbe,
             ProbeConfig readinessProbe,
             Optional<KubernetesHealthLivenessPathBuildItem> livenessPath,

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/OpenshiftProcessor.java

@@ -1,7 +1,6 @@
 
 package io.quarkus.kubernetes.deployment;
 
-import static io.quarkus.kubernetes.deployment.Constants.DEFAULT_HTTP_PORT;
 import static io.quarkus.kubernetes.deployment.Constants.DEFAULT_S2I_IMAGE_NAME;
 import static io.quarkus.kubernetes.deployment.Constants.OPENSHIFT;
 import static io.quarkus.kubernetes.deployment.Constants.OPENSHIFT_APP_RUNTIME;
@@ -61,6 +60,7 @@
 import io.quarkus.kubernetes.spi.KubernetesJobBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesLabelBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesPortBuildItem;
+import io.quarkus.kubernetes.spi.KubernetesProbePortNameBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesResourceMetadataBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBindingBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBuildItem;
@@ -179,6 +179,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
             Optional<BaseImageInfoBuildItem> baseImage,
             Optional<ContainerImageInfoBuildItem> image,
             Optional<KubernetesCommandBuildItem> command,
+            Optional<KubernetesProbePortNameBuildItem> portName,
             List<KubernetesPortBuildItem> ports,
             Optional<KubernetesHealthLivenessPathBuildItem> livenessPath,
             Optional<KubernetesHealthReadinessPathBuildItem> readinessPath,
@@ -301,8 +302,13 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
         }
 
         // Probe port handling
-        Integer portNumber = port.map(Port::getContainerPort).orElse(DEFAULT_HTTP_PORT);
-        result.add(new DecoratorBuildItem(OPENSHIFT, new ApplyHttpGetActionPortDecorator(name, name, portNumber)));
+        result.add(KubernetesCommonHelper.createProbeHttpPortDecorator(name, OPENSHIFT, "livenssProbe", config.livenessProbe,
+                portName,
+                ports));
+        result.add(
+                KubernetesCommonHelper.createProbeHttpPortDecorator(name, OPENSHIFT, "readinessProbe", config.readinessProbe,
+                        portName,
+                        ports));
 
         // Handle non-openshift builds
         if (deploymentKind == DeploymentResourceKind.DeploymentConfig

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/ProbeConfig.java

@@ -10,6 +10,19 @@
 @ConfigGroup
 public class ProbeConfig {
 
+    /**
+     * The port number to use when configuring the {@literal http get} action.
+     * If not configured, the port corresponding to the {@code httpActionPortName} will be used.
+     */
+    @ConfigItem
+    Optional<Integer> httpActionPort;
+
+    /**
+     * The port name for selecting the port of the {@literal HTTP get} action.
+     */
+    @ConfigItem
+    Optional<String> httpActionPortName;
+
     /**
      * The http path to use for the probe For this to work, the container port also
      * needs to be set.

extensions/kubernetes/vanilla/deployment/src/main/java/io/quarkus/kubernetes/deployment/VanillaKubernetesProcessor.java

@@ -1,7 +1,6 @@
 
 package io.quarkus.kubernetes.deployment;
 
-import static io.quarkus.kubernetes.deployment.Constants.DEFAULT_HTTP_PORT;
 import static io.quarkus.kubernetes.deployment.Constants.DEPLOYMENT_GROUP;
 import static io.quarkus.kubernetes.deployment.Constants.DEPLOYMENT_VERSION;
 import static io.quarkus.kubernetes.deployment.Constants.INGRESS;
@@ -52,6 +51,7 @@
 import io.quarkus.kubernetes.spi.KubernetesJobBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesLabelBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesPortBuildItem;
+import io.quarkus.kubernetes.spi.KubernetesProbePortNameBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesResourceMetadataBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBindingBuildItem;
 import io.quarkus.kubernetes.spi.KubernetesRoleBuildItem;
@@ -132,6 +132,7 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
             List<KubernetesAnnotationBuildItem> annotations,
             List<KubernetesLabelBuildItem> labels, List<KubernetesEnvBuildItem> envs,
             Optional<ContainerImageInfoBuildItem> image, Optional<KubernetesCommandBuildItem> command,
+            Optional<KubernetesProbePortNameBuildItem> portName,
             List<KubernetesPortBuildItem> ports, Optional<KubernetesHealthLivenessPathBuildItem> livenessPath,
             Optional<KubernetesHealthReadinessPathBuildItem> readinessPath, List<KubernetesRoleBuildItem> roles,
             List<KubernetesRoleBindingBuildItem> roleBindings, Optional<CustomProjectRootBuildItem> customProjectRoot,
@@ -241,8 +242,14 @@ public List<DecoratorBuildItem> createDecorators(ApplicationInfoBuildItem applic
         }
 
         // Probe port handling
-        Integer portNumber = port.map(Port::getContainerPort).orElse(DEFAULT_HTTP_PORT);
-        result.add(new DecoratorBuildItem(KUBERNETES, new ApplyHttpGetActionPortDecorator(name, name, portNumber)));
+        result.add(
+                KubernetesCommonHelper.createProbeHttpPortDecorator(name, KUBERNETES, "livenessProbe", config.livenessProbe,
+                        portName,
+                        ports));
+        result.add(
+                KubernetesCommonHelper.createProbeHttpPortDecorator(name, KUBERNETES, "readinessProbe", config.readinessProbe,
+                        portName,
+                        ports));
 
         // Handle remote debug configuration
         if (config.remoteDebug.enabled) {
@@ -274,5 +281,4 @@ void externalizeInitTasks(
                     decorators);
         }
     }
-
 }