diff --git a/spring-cloud-kubernetes-client-discovery/src/test/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClientTests.java b/spring-cloud-kubernetes-client-discovery/src/test/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClientTests.java index 3198afb7..3eab6f51 100644 --- a/spring-cloud-kubernetes-client-discovery/src/test/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClientTests.java +++ b/spring-cloud-kubernetes-client-discovery/src/test/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClientTests.java @@ -83,7 +83,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_NO_UNSET_PORT_NAME); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1").toArray()) @@ -96,7 +96,7 @@ class KubernetesInformerDiscoveryClientTests { void testDiscoveryGetServicesAllNamespaceShouldWork() { Lister serviceLister = setupServiceLister(SERVICE_1, SERVICE_2); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, null, null, null, KubernetesDiscoveryProperties.DEFAULT); assertThat(discoveryClient.getServices().toArray()).containsOnly(SERVICE_1.getMetadata().getName(), @@ -111,7 +111,7 @@ class KubernetesInformerDiscoveryClientTests { Map labels = Map.of("k8s", "true", "spring", "true"); KubernetesDiscoveryProperties kubernetesDiscoveryProperties = properties(true, labels); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, null, null, null, kubernetesDiscoveryProperties); assertThat(discoveryClient.getServices().toArray()).containsOnly(SERVICE_3.getMetadata().getName()); @@ -126,7 +126,7 @@ class KubernetesInformerDiscoveryClientTests { Map labels = Map.of("k8s", "true", "spring", "true"); KubernetesDiscoveryProperties kubernetesDiscoveryProperties = properties(true, labels); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, kubernetesDiscoveryProperties); assertThat(discoveryClient.getInstances("test-svc-1").toArray()).isEmpty(); @@ -142,7 +142,7 @@ class KubernetesInformerDiscoveryClientTests { void testDiscoveryInstancesWithSecuredServiceByAnnotations() { Lister serviceLister = setupServiceLister(SERVICE_4); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_1); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, ALL_NAMESPACES); assertThat(discoveryClient.getServices().toArray()).containsOnly(SERVICE_4.getMetadata().getName()); ServiceInstance serviceInstance = discoveryClient.getInstances(SERVICE_4.getMetadata().getName()).get(0); @@ -153,7 +153,7 @@ class KubernetesInformerDiscoveryClientTests { void testDiscoveryInstancesWithSecuredServiceByLabels() { Lister serviceLister = setupServiceLister(SERVICE_4); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_1); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, ALL_NAMESPACES); assertThat(discoveryClient.getServices().toArray()).containsOnly(SERVICE_4.getMetadata().getName()); @@ -165,7 +165,7 @@ class KubernetesInformerDiscoveryClientTests { void testDiscoveryGetServicesOneNamespaceShouldWork() { Lister serviceLister = setupServiceLister(SERVICE_1, SERVICE_2); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, null, null, null, KubernetesDiscoveryProperties.DEFAULT); assertThat(discoveryClient.getServices().toArray()).containsOnly(SERVICE_1.getMetadata().getName()); @@ -177,7 +177,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1, SERVICE_2); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_1); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -191,7 +191,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1, SERVICE_2); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_1); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -205,7 +205,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_NOT_READY_ADDRESS); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, KubernetesDiscoveryProperties.DEFAULT); @@ -221,7 +221,7 @@ class KubernetesInformerDiscoveryClientTests { Set.of(), true, 60, true, null, Set.of(), Map.of(), null, KubernetesDiscoveryProperties.Metadata.DEFAULT, 0, true); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, kubernetesDiscoveryProperties); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -235,7 +235,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, KubernetesDiscoveryProperties.DEFAULT); @@ -247,7 +247,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_NO_PORTS); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, KubernetesDiscoveryProperties.DEFAULT); @@ -259,7 +259,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_6); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_WITH); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -276,7 +276,7 @@ class KubernetesInformerDiscoveryClientTests { Lister endpointsLister = setupEndpointsLister( ENDPOINTS_MULTIPLE_PORTS_WITHOUT_SUPPORTED_PORT_NAMES); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -292,7 +292,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_WITH); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -307,7 +307,7 @@ class KubernetesInformerDiscoveryClientTests { Lister endpointsLister = setupEndpointsLister( ENDPOINTS_MULTIPLE_PORTS_WITHOUT_SUPPORTED_PORT_NAMES); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -321,7 +321,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_WITH); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -335,7 +335,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_WITH_MULTIPLE_PORTS_NO_HTTPS); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -350,7 +350,7 @@ class KubernetesInformerDiscoveryClientTests { Lister endpointsLister = setupEndpointsLister( ENDPOINTS_MULTIPLE_PORTS_WITHOUT_SUPPORTED_PORT_NAMES); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient("namespace1", + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, NOT_ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")) @@ -364,7 +364,7 @@ class KubernetesInformerDiscoveryClientTests { Lister serviceLister = setupServiceLister(SERVICE_1, SERVICE_2); Lister endpointsLister = setupEndpointsLister(ENDPOINTS_1, ENDPOINTS_2); - KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient(null, + KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient( SHARED_INFORMER_FACTORY, serviceLister, endpointsLister, null, null, ALL_NAMESPACES); assertThat(discoveryClient.getInstances("test-svc-1")).containsOnly(