loadBalancerClientFactory;
+
+ @BeforeAll
+ static void beforeAll() {
+
+ wireMockServer = new WireMockServer(options().dynamicPort());
+ wireMockServer.start();
+ WireMock.configureFor("localhost", wireMockServer.port());
+
+ serviceAMockServer = new WireMockServer(SERVICE_A_PORT);
+ serviceAMockServer.start();
+ WireMock.configureFor("localhost", SERVICE_A_PORT);
+
+ serviceBMockServer = new WireMockServer(SERVICE_B_PORT);
+ serviceBMockServer.start();
+ WireMock.configureFor("localhost", SERVICE_B_PORT);
+
+ // we mock host creation so that it becomes something like : localhost:8888
+ // then wiremock can catch this request, and we can assert for the result
+ MOCKED_STATIC.when(() -> KubernetesServiceInstanceMapper.createHost("service-a", "a", "cluster.local"))
+ .thenReturn("localhost");
+
+ MOCKED_STATIC.when(() -> KubernetesServiceInstanceMapper.createHost("service-b", "b", "cluster.local"))
+ .thenReturn("localhost");
+
+ // Configure the kubernetes master url to point to the mock server
+ System.setProperty(Config.KUBERNETES_MASTER_SYSTEM_PROPERTY, "http://localhost:" + wireMockServer.port());
+ System.setProperty(Config.KUBERNETES_TRUST_CERT_SYSTEM_PROPERTY, "true");
+ System.setProperty(Config.KUBERNETES_AUTH_TRYKUBECONFIG_SYSTEM_PROPERTY, "false");
+ System.setProperty(Config.KUBERNETES_AUTH_TRYSERVICEACCOUNT_SYSTEM_PROPERTY, "false");
+ System.setProperty(Config.KUBERNETES_NAMESPACE_SYSTEM_PROPERTY, "test");
+ System.setProperty(Config.KUBERNETES_HTTP2_DISABLE, "true");
+ }
+
+ @AfterAll
+ static void afterAll() {
+ wireMockServer.stop();
+ serviceAMockServer.stop();
+ serviceBMockServer.stop();
+ MOCKED_STATIC.close();
+ }
+
+ /**
+ *
+ * - service-a is present in 'a' namespace
+ * - service-b is present in 'b' namespace
+ * - we enable search in namespace 'a'
+ * - load balancer mode is 'POD'
+ *
+ * - as such, only service-a service is load balanced
+ * - we also assert the type of ServiceInstanceListSupplier corresponding to the POD mode.
+ *
+ */
+ @Test
+ void test() {
+
+ Service serviceA = Util.createService("a", "service-a", SERVICE_A_PORT);
+ Service serviceB = Util.createService("b", "service-a", SERVICE_B_PORT);
+
+ Endpoints endpointsA = new EndpointsBuilder()
+ .withSubsets(new EndpointSubsetBuilder()
+ .withPorts(new EndpointPortBuilder().withPort(SERVICE_A_PORT).build())
+ .withAddresses(new EndpointAddressBuilder().withIp("127.0.0.1").build()).build())
+ .withMetadata(new ObjectMetaBuilder().withName("no-port-name-service").withNamespace("a").build())
+ .build();
+
+ Endpoints endpointsB = new EndpointsBuilder()
+ .withSubsets(new EndpointSubsetBuilder()
+ .withPorts(new EndpointPortBuilder().withPort(SERVICE_B_PORT).build())
+ .withAddresses(new EndpointAddressBuilder().withIp("127.0.0.1").build()).build())
+ .withMetadata(new ObjectMetaBuilder().withName("no-port-name-service").withNamespace("b").build())
+ .build();
+
+ String endpointsAListAsString = Serialization.asJson(new EndpointsListBuilder().withItems(endpointsA).build());
+ String endpointsBListAsString = Serialization.asJson(new EndpointsListBuilder().withItems(endpointsB).build());
+
+ String serviceAString = Serialization.asJson(serviceA);
+ String serviceBString = Serialization.asJson(serviceB);
+
+ wireMockServer
+ .stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/namespaces/a/endpoints?fieldSelector=metadata.name%3Dservice-a"))
+ .willReturn(WireMock.aResponse().withBody(endpointsAListAsString).withStatus(200)));
+
+ wireMockServer
+ .stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/namespaces/b/endpoints?fieldSelector=metadata.name%3Dservice-b"))
+ .willReturn(WireMock.aResponse().withBody(endpointsBListAsString).withStatus(200)));
+
+ wireMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/namespaces/a/services/service-a"))
+ .willReturn(WireMock.aResponse().withBody(serviceAString).withStatus(200)));
+
+ wireMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/namespaces/b/services/service-a"))
+ .willReturn(WireMock.aResponse().withBody(serviceBString).withStatus(200)));
+
+ serviceAMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/"))
+ .willReturn(WireMock.aResponse().withBody("service-a-reached").withStatus(200)));
+
+ serviceBMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/"))
+ .willReturn(WireMock.aResponse().withBody("service-b-reached").withStatus(200)));
+
+ String serviceAResult = builder.baseUrl(SERVICE_A_URL).build().method(HttpMethod.GET).retrieve()
+ .bodyToMono(String.class).block();
+ Assertions.assertThat(serviceAResult).isEqualTo("service-a-reached");
+
+ CachingServiceInstanceListSupplier supplier = (CachingServiceInstanceListSupplier) loadBalancerClientFactory
+ .getIfAvailable().getProvider("service-a", ServiceInstanceListSupplier.class).getIfAvailable();
+ Assertions.assertThat(supplier.getDelegate().getClass())
+ .isSameAs(DiscoveryClientServiceInstanceListSupplier.class);
+ }
+
+ @TestConfiguration
+ static class LoadBalancerConfiguration {
+
+ @Bean
+ @LoadBalanced
+ WebClient.Builder client() {
+ return WebClient.builder();
+ }
+
+ }
+
+ @SpringBootApplication
+ static class Configuration {
+
+ public static void main(String[] args) {
+ SpringApplication.run(ServiceModeAllNamespacesTest.Configuration.class);
+ }
+
+ }
+
+
+}
diff --git a/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/ServiceModeAllNamespacesTest.java b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/ServiceModeAllNamespacesTest.java
new file mode 100644
index 0000000000..cf5750e653
--- /dev/null
+++ b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/ServiceModeAllNamespacesTest.java
@@ -0,0 +1,187 @@
+/*
+ * Copyright 2013-2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.kubernetes.fabric8.loadbalancer.it;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.client.WireMock;
+import io.fabric8.kubernetes.api.model.Service;
+import io.fabric8.kubernetes.api.model.ServiceListBuilder;
+import io.fabric8.kubernetes.client.Config;
+import io.fabric8.kubernetes.client.utils.Serialization;
+import org.assertj.core.api.Assertions;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+import org.mockito.MockedStatic;
+import org.mockito.Mockito;
+
+import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
+import org.springframework.cloud.kubernetes.commons.loadbalancer.KubernetesServiceInstanceMapper;
+import org.springframework.cloud.kubernetes.fabric8.loadbalancer.Fabric8ServicesListSupplier;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
+import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
+import org.springframework.context.annotation.Bean;
+import org.springframework.http.HttpMethod;
+import org.springframework.web.reactive.function.client.WebClient;
+
+import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.options;
+import static org.springframework.cloud.kubernetes.fabric8.loadbalancer.it.ServiceModeAllNamespacesTest.Configuration;
+import static org.springframework.cloud.kubernetes.fabric8.loadbalancer.it.ServiceModeAllNamespacesTest.LoadBalancerConfiguration;
+
+/**
+ * @author wind57
+ */
+@SpringBootTest(
+ properties = { "spring.cloud.kubernetes.loadbalancer.mode=SERVICE", "spring.main.cloud-platform=KUBERNETES",
+ "spring.cloud.kubernetes.discovery.all-namespaces=true" },
+ classes = { LoadBalancerConfiguration.class, Configuration.class })
+class ServiceModeAllNamespacesTest {
+
+ private static final String SERVICE_A_URL = "http://service-a";
+
+ private static final String SERVICE_B_URL = "http://service-b";
+
+ private static final int SERVICE_A_PORT = 8888;
+
+ private static final int SERVICE_B_PORT = 8889;
+
+ private static WireMockServer wireMockServer;
+
+ private static WireMockServer serviceAMockServer;
+
+ private static WireMockServer serviceBMockServer;
+
+ private static final MockedStatic MOCKED_STATIC = Mockito
+ .mockStatic(KubernetesServiceInstanceMapper.class);
+
+ @Autowired
+ private WebClient.Builder builder;
+
+ @Autowired
+ private ObjectProvider loadBalancerClientFactory;
+
+ @BeforeAll
+ static void beforeAll() {
+
+ wireMockServer = new WireMockServer(options().dynamicPort());
+ wireMockServer.start();
+ WireMock.configureFor("localhost", wireMockServer.port());
+
+ serviceAMockServer = new WireMockServer(SERVICE_A_PORT);
+ serviceAMockServer.start();
+ WireMock.configureFor("localhost", SERVICE_A_PORT);
+
+ serviceBMockServer = new WireMockServer(SERVICE_B_PORT);
+ serviceBMockServer.start();
+ WireMock.configureFor("localhost", SERVICE_B_PORT);
+
+ // we mock host creation so that it becomes something like : localhost:8888
+ // then wiremock can catch this request, and we can assert for the result
+ MOCKED_STATIC.when(() -> KubernetesServiceInstanceMapper.createHost("service-a", "a", "cluster.local"))
+ .thenReturn("localhost");
+
+ MOCKED_STATIC.when(() -> KubernetesServiceInstanceMapper.createHost("service-b", "b", "cluster.local"))
+ .thenReturn("localhost");
+
+ // Configure the kubernetes master url to point to the mock server
+ System.setProperty(Config.KUBERNETES_MASTER_SYSTEM_PROPERTY, "http://localhost:" + wireMockServer.port());
+ System.setProperty(Config.KUBERNETES_TRUST_CERT_SYSTEM_PROPERTY, "true");
+ System.setProperty(Config.KUBERNETES_AUTH_TRYKUBECONFIG_SYSTEM_PROPERTY, "false");
+ System.setProperty(Config.KUBERNETES_AUTH_TRYSERVICEACCOUNT_SYSTEM_PROPERTY, "false");
+ System.setProperty(Config.KUBERNETES_NAMESPACE_SYSTEM_PROPERTY, "test");
+ System.setProperty(Config.KUBERNETES_HTTP2_DISABLE, "true");
+ }
+
+ @AfterAll
+ static void afterAll() {
+ wireMockServer.stop();
+ serviceAMockServer.stop();
+ serviceBMockServer.stop();
+ MOCKED_STATIC.close();
+ }
+
+ /**
+ *
+ * - service-a is present in namespace a with exposed port 8888
+ * - service-b is present in namespace b with exposed port 8889
+ * - we make two calls to them via the load balancer
+ *
+ */
+ @Test
+ void test() {
+
+ Service serviceA = Util.createService("a", "service-a", SERVICE_A_PORT);
+ Service serviceB = Util.createService("b", "service-b", SERVICE_B_PORT);
+
+ String serviceListAJson = Serialization.asJson(new ServiceListBuilder().withItems(serviceA).build());
+ String serviceListBJson = Serialization.asJson(new ServiceListBuilder().withItems(serviceB).build());
+
+ wireMockServer
+ .stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/services?fieldSelector=metadata.name%3Dservice-a"))
+ .willReturn(WireMock.aResponse().withBody(serviceListAJson).withStatus(200)));
+
+ wireMockServer
+ .stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/services?fieldSelector=metadata.name%3Dservice-b"))
+ .willReturn(WireMock.aResponse().withBody(serviceListBJson).withStatus(200)));
+
+ serviceAMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/"))
+ .willReturn(WireMock.aResponse().withBody("service-a-reached").withStatus(200)));
+
+ serviceBMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/"))
+ .willReturn(WireMock.aResponse().withBody("service-b-reached").withStatus(200)));
+
+ String serviceAResult = builder.baseUrl(SERVICE_A_URL).build().method(HttpMethod.GET).retrieve()
+ .bodyToMono(String.class).block();
+ Assertions.assertThat(serviceAResult).isEqualTo("service-a-reached");
+
+ String serviceBResult = builder.baseUrl(SERVICE_B_URL).build().method(HttpMethod.GET).retrieve()
+ .bodyToMono(String.class).block();
+ Assertions.assertThat(serviceBResult).isEqualTo("service-b-reached");
+
+ CachingServiceInstanceListSupplier supplier = (CachingServiceInstanceListSupplier) loadBalancerClientFactory
+ .getIfAvailable().getProvider("service-a", ServiceInstanceListSupplier.class).getIfAvailable();
+ Assertions.assertThat(supplier.getDelegate().getClass()).isSameAs(Fabric8ServicesListSupplier.class);
+ }
+
+ @TestConfiguration
+ static class LoadBalancerConfiguration {
+
+ @Bean
+ @LoadBalanced
+ WebClient.Builder client() {
+ return WebClient.builder();
+ }
+
+ }
+
+ @SpringBootApplication
+ static class Configuration {
+
+ public static void main(String[] args) {
+ SpringApplication.run(Configuration.class);
+ }
+
+ }
+
+}
diff --git a/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/ServiceModeSpecificNamespaceTest.java b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/ServiceModeSpecificNamespaceTest.java
new file mode 100644
index 0000000000..5369e61304
--- /dev/null
+++ b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/ServiceModeSpecificNamespaceTest.java
@@ -0,0 +1,184 @@
+/*
+ * Copyright 2013-2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.kubernetes.fabric8.loadbalancer.it;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.client.WireMock;
+import io.fabric8.kubernetes.api.model.Service;
+import io.fabric8.kubernetes.client.Config;
+import io.fabric8.kubernetes.client.utils.Serialization;
+import org.assertj.core.api.Assertions;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+import org.mockito.MockedStatic;
+import org.mockito.Mockito;
+
+import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
+import org.springframework.cloud.kubernetes.commons.loadbalancer.KubernetesServiceInstanceMapper;
+import org.springframework.cloud.kubernetes.fabric8.loadbalancer.Fabric8ServicesListSupplier;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
+import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
+import org.springframework.context.annotation.Bean;
+import org.springframework.http.HttpMethod;
+import org.springframework.web.reactive.function.client.WebClient;
+
+import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.options;
+import static org.springframework.cloud.kubernetes.fabric8.loadbalancer.it.ServiceModeSpecificNamespaceTest.Configuration;
+import static org.springframework.cloud.kubernetes.fabric8.loadbalancer.it.ServiceModeSpecificNamespaceTest.LoadBalancerConfiguration;
+
+/**
+ * @author wind57
+ */
+@SpringBootTest(
+ properties = { "spring.cloud.kubernetes.loadbalancer.mode=SERVICE", "spring.main.cloud-platform=KUBERNETES",
+ "spring.cloud.kubernetes.discovery.all-namespaces=false", "spring.cloud.kubernetes.client.namespace=a" },
+ classes = { LoadBalancerConfiguration.class, Configuration.class })
+class ServiceModeSpecificNamespaceTest {
+
+ private static final String SERVICE_A_URL = "http://service-a";
+
+ private static final int SERVICE_A_PORT = 8888;
+
+ private static final int SERVICE_B_PORT = 8889;
+
+ private static WireMockServer wireMockServer;
+
+ private static WireMockServer serviceAMockServer;
+
+ private static WireMockServer serviceBMockServer;
+
+ private static final MockedStatic MOCKED_STATIC = Mockito
+ .mockStatic(KubernetesServiceInstanceMapper.class);
+
+ @Autowired
+ private WebClient.Builder builder;
+
+ @Autowired
+ private ObjectProvider loadBalancerClientFactory;
+
+ @BeforeAll
+ static void beforeAll() {
+
+ wireMockServer = new WireMockServer(options().dynamicPort());
+ wireMockServer.start();
+ WireMock.configureFor("localhost", wireMockServer.port());
+
+ serviceAMockServer = new WireMockServer(SERVICE_A_PORT);
+ serviceAMockServer.start();
+ WireMock.configureFor("localhost", SERVICE_A_PORT);
+
+ serviceBMockServer = new WireMockServer(SERVICE_B_PORT);
+ serviceBMockServer.start();
+ WireMock.configureFor("localhost", SERVICE_B_PORT);
+
+ // we mock host creation so that it becomes something like : localhost:8888
+ // then wiremock can catch this request, and we can assert for the result
+ MOCKED_STATIC.when(() -> KubernetesServiceInstanceMapper.createHost("service-a", "a", "cluster.local"))
+ .thenReturn("localhost");
+
+ MOCKED_STATIC.when(() -> KubernetesServiceInstanceMapper.createHost("service-b", "b", "cluster.local"))
+ .thenReturn("localhost");
+
+ // Configure the kubernetes master url to point to the mock server
+ System.setProperty(Config.KUBERNETES_MASTER_SYSTEM_PROPERTY, "http://localhost:" + wireMockServer.port());
+ System.setProperty(Config.KUBERNETES_TRUST_CERT_SYSTEM_PROPERTY, "true");
+ System.setProperty(Config.KUBERNETES_AUTH_TRYKUBECONFIG_SYSTEM_PROPERTY, "false");
+ System.setProperty(Config.KUBERNETES_AUTH_TRYSERVICEACCOUNT_SYSTEM_PROPERTY, "false");
+ System.setProperty(Config.KUBERNETES_NAMESPACE_SYSTEM_PROPERTY, "test");
+ System.setProperty(Config.KUBERNETES_HTTP2_DISABLE, "true");
+ }
+
+ @AfterAll
+ static void afterAll() {
+ wireMockServer.stop();
+ serviceAMockServer.stop();
+ serviceBMockServer.stop();
+ MOCKED_STATIC.close();
+ }
+
+ /**
+ *
+ * - service-a is present in 'a' namespace
+ * - service-a is present in 'b' namespace
+ * - we enable search in namespace 'a'
+ * - load balancer mode is 'SERVICE'
+ *
+ * - as such, only service-a service is load balanced
+ * - we also assert the type of ServiceInstanceListSupplier corresponding to the SERVICE mode.
+ *
+ */
+ @Test
+ void test() {
+
+ Service serviceA = Util.createService("a", "service-a", SERVICE_A_PORT);
+ Service serviceB = Util.createService("b", "service-a", SERVICE_B_PORT);
+
+ String serviceAJson = Serialization.asJson(serviceA);
+ String serviceBJson = Serialization.asJson(serviceB);
+
+ wireMockServer
+ .stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/namespaces/a/services/service-a"))
+ .willReturn(WireMock.aResponse().withBody(serviceAJson).withStatus(200)));
+
+ wireMockServer
+ .stubFor(WireMock.get(WireMock.urlEqualTo("/api/v1/namespaces/b/services/service-a"))
+ .willReturn(WireMock.aResponse().withBody(serviceBJson).withStatus(200)));
+
+ serviceAMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/"))
+ .willReturn(WireMock.aResponse().withBody("service-a-reached").withStatus(200)));
+
+ serviceBMockServer.stubFor(WireMock.get(WireMock.urlEqualTo("/"))
+ .willReturn(WireMock.aResponse().withBody("service-b-reached").withStatus(200)));
+
+ String serviceAResult = builder.baseUrl(SERVICE_A_URL).build().method(HttpMethod.GET).retrieve()
+ .bodyToMono(String.class).block();
+ Assertions.assertThat(serviceAResult).isEqualTo("service-a-reached");
+
+ CachingServiceInstanceListSupplier supplier = (CachingServiceInstanceListSupplier) loadBalancerClientFactory
+ .getIfAvailable().getProvider("service-a", ServiceInstanceListSupplier.class).getIfAvailable();
+ Assertions.assertThat(supplier.getDelegate().getClass()).isSameAs(Fabric8ServicesListSupplier.class);
+ }
+
+ @TestConfiguration
+ static class LoadBalancerConfiguration {
+
+ @Bean
+ @LoadBalanced
+ WebClient.Builder client() {
+ return WebClient.builder();
+ }
+
+ }
+
+ @SpringBootApplication
+ static class Configuration {
+
+ public static void main(String[] args) {
+ SpringApplication.run(ServiceModeAllNamespacesTest.Configuration.class);
+ }
+
+ }
+
+}
diff --git a/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/Util.java b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/Util.java
new file mode 100644
index 0000000000..76ca6097e6
--- /dev/null
+++ b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/java/org/springframework/cloud/kubernetes/fabric8/loadbalancer/it/Util.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2013-2024 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.kubernetes.fabric8.loadbalancer.it;
+
+import io.fabric8.kubernetes.api.model.Service;
+import io.fabric8.kubernetes.api.model.ServiceBuilder;
+import io.fabric8.kubernetes.api.model.ServicePortBuilder;
+import io.fabric8.kubernetes.api.model.ServiceSpecBuilder;
+
+/**
+ * @author wind57
+ */
+final class Util {
+
+ private Util() {
+
+ }
+
+ static Service createService(String namespace, String name, int port) {
+ return new ServiceBuilder().withNewMetadata().withNamespace(namespace).withName(name).endMetadata()
+ .withSpec(new ServiceSpecBuilder()
+ .withPorts(new ServicePortBuilder().withName("http").withPort(port).build()).build())
+ .build();
+ }
+
+}
diff --git a/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/resources/logback-test.xml b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/resources/logback-test.xml
new file mode 100644
index 0000000000..047e3076eb
--- /dev/null
+++ b/spring-cloud-kubernetes-fabric8-loadbalancer/src/test/resources/logback-test.xml
@@ -0,0 +1,7 @@
+
+
+
+
+
+
+
diff --git a/spring-cloud-kubernetes-integration-tests/pom.xml b/spring-cloud-kubernetes-integration-tests/pom.xml
index 4e47756483..22a6f84198 100644
--- a/spring-cloud-kubernetes-integration-tests/pom.xml
+++ b/spring-cloud-kubernetes-integration-tests/pom.xml
@@ -128,7 +128,7 @@
spring-cloud-kubernetes-k8s-client-configuration-watcher
-
+
spring-cloud-kubernetes-k8s-client-loadbalancer
@@ -137,5 +137,5 @@
spring-cloud-kubernetes-k8s-client-rabbitmq-secret-reload-multiple-apps
-
+