Verify, that grpc can be used for Openshift probes

See quarkusio/quarkus#32113 for details

monitoring/opentelemetry-reactive/src/test/java/io/quarkus/ts/opentelemetry/reactive/OpenTelemetryGrpcIT.java → monitoring/opentelemetry-reactive/src/test/java/io/quarkus/ts/opentelemetry/reactive/GrpcIT.java

@@ -18,15 +18,17 @@
 import io.quarkus.test.services.QuarkusApplication;
 
 @QuarkusScenario
-public class OpenTelemetryGrpcIT {
+public class GrpcIT {
 
     @JaegerContainer(useOtlpCollector = true)
     static final JaegerService jaeger = new JaegerService();
 
     @QuarkusApplication()
     static RestService app = new RestService()
             .withProperty("quarkus.application.name", "pingpong")
-            .withProperty("quarkus.opentelemetry.tracer.exporter.otlp.endpoint", jaeger::getCollectorUrl);
+            .withProperty("quarkus.opentelemetry.tracer.exporter.otlp.endpoint", jaeger::getCollectorUrl)
+            .withProperty("quarkus.openshift.readiness-probe.grpc-action", "9000:io.quarkus.example.PongService")
+            .withProperty("quarkus.openshift.liveness-probe.grpc-action", "9000:io.quarkus.example.PongService");
 
     private static final String PING_ENDPOINT = "/grpc-ping";
     private static final String PONG_ENDPOINT = "/grpc-pong";
@@ -61,5 +63,4 @@ protected void assertTraceIdWithPongService(String expected) {
 
         assertEquals(expected, pongTraceId);
     }
-
 }

monitoring/opentelemetry-reactive/src/test/java/io/quarkus/ts/opentelemetry/reactive/OpenShiftGrpcIT.java

@@ -0,0 +1,42 @@
+package io.quarkus.ts.opentelemetry.reactive;
+
+import java.util.List;
+
+import jakarta.inject.Inject;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import io.fabric8.kubernetes.api.model.Container;
+import io.fabric8.kubernetes.api.model.GRPCAction;
+import io.fabric8.kubernetes.api.model.Pod;
+import io.fabric8.kubernetes.api.model.Probe;
+import io.quarkus.test.bootstrap.inject.OpenShiftClient;
+import io.quarkus.test.scenarios.OpenShiftDeploymentStrategy;
+import io.quarkus.test.scenarios.OpenShiftScenario;
+
+@OpenShiftScenario(deployment = OpenShiftDeploymentStrategy.UsingOpenShiftExtension)
+public class OpenShiftGrpcIT extends GrpcIT {
+
+    @Inject
+    static OpenShiftClient oc;
+
+    @Test
+    void grpcProbes() {
+        List<Pod> pods = oc.podsInService(app);
+        Assertions.assertEquals(1, pods.size());
+        List<Container> containers = pods.get(0).getSpec().getContainers();
+        Assertions.assertEquals(1, containers.size());
+        Container container = containers.get(0);
+        validateProbe(container.getLivenessProbe());
+        validateProbe(container.getReadinessProbe());
+    }
+
+    private static void validateProbe(Probe probe) {
+        Assertions.assertNotNull(probe);
+        GRPCAction grpcAction = probe.getGrpc();
+        Assertions.assertNotNull(grpcAction);
+        Assertions.assertEquals("io.quarkus.example.PongService", grpcAction.getService());
+        Assertions.assertEquals(9000, grpcAction.getPort());
+    }
+}