started

Signed-off-by: wind57 <[email protected]>

Author: wind57

spring-cloud-kubernetes-integration-tests/spring-cloud-kubernetes-k8s-client-discovery/src/test/java/org/springframework/cloud/kubernetes/k8s/client/discovery/KubernetesClientReactiveIT.java

@@ -28,7 +28,7 @@
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.test.system.CapturedOutput;
 import org.springframework.boot.test.web.server.LocalManagementPort;
-import org.springframework.cloud.client.discovery.DiscoveryClient;
+import org.springframework.cloud.client.discovery.ReactiveDiscoveryClient;
 import org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryProperties;
 import org.springframework.cloud.kubernetes.integration.tests.commons.Images;
 import org.springframework.cloud.kubernetes.integration.tests.commons.Phase;
@@ -55,7 +55,7 @@ class KubernetesClientReactiveIT extends KubernetesClientDiscoveryBase {
 	private int port;
 
 	@Autowired
-	private DiscoveryClient discoveryClient;
+	private ReactiveDiscoveryClient discoveryClient;
 
 	@BeforeEach
 	void beforeEach() {

spring-cloud-kubernetes-integration-tests/spring-cloud-kubernetes-k8s-client-discovery/src/test/java/org/springframework/cloud/kubernetes/k8s/client/discovery/TestAssertions.java

@@ -24,6 +24,7 @@
 import org.springframework.boot.test.system.CapturedOutput;
 import org.springframework.cloud.client.ServiceInstance;
 import org.springframework.cloud.client.discovery.DiscoveryClient;
+import org.springframework.cloud.client.discovery.ReactiveDiscoveryClient;
 import org.springframework.cloud.kubernetes.commons.discovery.DefaultKubernetesServiceInstance;
 import org.springframework.http.HttpMethod;
 import org.springframework.web.reactive.function.client.WebClient;
@@ -137,4 +138,18 @@ static void assertPodMetadata(DiscoveryClient discoveryClient) {
 
 	}
 
+	static void assertPodMetadata(ReactiveDiscoveryClient discoveryClient) {
+
+		List<ServiceInstance> serviceInstances = discoveryClient.getInstances("service-wiremock").collectList().block();
+		assertThat(serviceInstances).hasSize(1);
+		DefaultKubernetesServiceInstance wiremockInstance = (DefaultKubernetesServiceInstance) serviceInstances.get(0);
+
+		assertThat(wiremockInstance.getServiceId()).isEqualTo("service-wiremock");
+		assertThat(wiremockInstance.getInstanceId()).isNotNull();
+		assertThat(wiremockInstance.getHost()).isNotNull();
+		assertThat(wiremockInstance.getMetadata()).isEqualTo(Map.of("k8s_namespace", "default", "type", "ClusterIP",
+			"port.http", "8080", "app", "service-wiremock"));
+
+	}
+
 }