SpringCloud/spring-cloud-kubernetes
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#962 Fixing tests dependent to KubernetesServiceInstance

Browse Source
This commit is contained in:
piomin
2020-08-24 13:59:08 +02:00
parent 7adfad8ef4
commit d5592f9f9c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-kubernetes-controllers/spring-cloud-kubernetes-configuration-watcher/src/test/java/org/springframework/cloud/kubernetes/configuration/watcher/HttpBasedConfigurationWatchChangeDetectorTests.java
View File

@@ -99,7 +99,7 @@ public class HttpBasedConfigurationWatchChangeDetectorTests {
fooEndpointPort.setPort(wireMockRule.port());
List<ServiceInstance> instances = new ArrayList<>();
KubernetesServiceInstance fooServiceInstance = new KubernetesServiceInstance(
"foo", "foo", fooEndpointAddress, fooEndpointPort, new HashMap<>(),
"foo", "foo", fooEndpointAddress.getIp(), fooEndpointPort.getPort(), new HashMap<>(),
false);
instances.add(fooServiceInstance);
when(reactiveDiscoveryClient.getInstances(eq("foo")))
@@ -185,7 +185,7 @@ public class HttpBasedConfigurationWatchChangeDetectorTests {
fooEndpointPort.setPort(wireMockRule.port());
List<ServiceInstance> instances = new ArrayList<>();
KubernetesServiceInstance fooServiceInstance = new KubernetesServiceInstance(
"foo", "foo", fooEndpointAddress, fooEndpointPort, metadata, false);
"foo", "foo", fooEndpointAddress.getIp(), fooEndpointPort.getPort(), metadata, false);
instances.add(fooServiceInstance);
when(reactiveDiscoveryClient.getInstances(eq("foo")))
.thenReturn(Flux.fromIterable(instances));
@@ -211,7 +211,7 @@ public class HttpBasedConfigurationWatchChangeDetectorTests {
fooEndpointPort.setPort(wireMockRule.port());
List<ServiceInstance> instances = new ArrayList<>();
KubernetesServiceInstance fooServiceInstance = new KubernetesServiceInstance(
"foo", "foo", fooEndpointAddress, fooEndpointPort, metadata, false);
"foo", "foo", fooEndpointAddress.getIp(), fooEndpointPort.getPort(), metadata, false);
instances.add(fooServiceInstance);
when(reactiveDiscoveryClient.getInstances(eq("foo")))
.thenReturn(Flux.fromIterable(instances));