Skip to content

Commit 8729e1f

Browse files
authored
Merge pull request #2060 from wind57/clean-up-after-breaking-changes
Clean up after breaking changes
2 parents d23e1ba + b1ce8f1 commit 8729e1f

File tree

20 files changed

+43
-98
lines changed

20 files changed

+43
-98
lines changed

spring-cloud-kubernetes-client-config/src/main/java/org/springframework/cloud/kubernetes/client/config/KubernetesClientConfigDataLocationResolver.java

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,7 @@
2121

2222
import org.springframework.boot.bootstrap.BootstrapRegistry;
2323
import org.springframework.boot.bootstrap.ConfigurableBootstrapContext;
24-
import org.springframework.boot.context.config.ConfigDataLocation;
2524
import org.springframework.boot.context.config.ConfigDataLocationResolverContext;
26-
import org.springframework.boot.context.config.Profiles;
2725
import org.springframework.cloud.kubernetes.commons.KubernetesClientProperties;
2826
import org.springframework.cloud.kubernetes.commons.KubernetesNamespaceProvider;
2927
import org.springframework.cloud.kubernetes.commons.config.ConfigDataRetryableConfigMapPropertySourceLocator;
@@ -34,7 +32,6 @@
3432
import org.springframework.cloud.kubernetes.commons.config.SecretsPropertySourceLocator;
3533
import org.springframework.cloud.kubernetes.commons.configdata.ConfigDataPropertiesHolder;
3634
import org.springframework.cloud.kubernetes.commons.configdata.KubernetesConfigDataLocationResolver;
37-
import org.springframework.core.env.Environment;
3835

3936
import static org.springframework.cloud.kubernetes.client.KubernetesClientUtils.kubernetesApiClient;
4037
import static org.springframework.cloud.kubernetes.commons.config.ConfigUtils.registerSingle;
@@ -45,8 +42,8 @@
4542
public class KubernetesClientConfigDataLocationResolver extends KubernetesConfigDataLocationResolver {
4643

4744
@Override
48-
protected void registerBeans(ConfigDataLocationResolverContext resolverContext, ConfigDataLocation location,
49-
Profiles profiles, ConfigDataPropertiesHolder properties, KubernetesNamespaceProvider namespaceProvider) {
45+
protected void registerBeans(ConfigDataLocationResolverContext resolverContext,
46+
ConfigDataPropertiesHolder properties, KubernetesNamespaceProvider namespaceProvider) {
5047
KubernetesClientProperties kubernetesClientProperties = properties.clientProperties();
5148
ConfigMapConfigProperties configMapProperties = properties.configMapProperties();
5249
SecretsConfigProperties secretsProperties = properties.secretsProperties();
@@ -91,8 +88,4 @@ private CoreV1Api registerClientAndCoreV1Api(ConfigurableBootstrapContext bootst
9188
return coreV1Api;
9289
}
9390

94-
protected KubernetesNamespaceProvider kubernetesNamespaceProvider(Environment environment) {
95-
return new KubernetesNamespaceProvider(environment);
96-
}
97-
9891
}

spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesClientInformerDiscoveryClient.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -50,9 +50,9 @@
5050
import static org.springframework.cloud.kubernetes.client.discovery.KubernetesClientDiscoveryClientUtils.serviceMetadata;
5151
import static org.springframework.cloud.kubernetes.client.discovery.KubernetesClientInstanceIdHostPodNameSupplier.externalName;
5252
import static org.springframework.cloud.kubernetes.client.discovery.KubernetesClientInstanceIdHostPodNameSupplier.nonExternalName;
53-
import static org.springframework.cloud.kubernetes.client.discovery.KubernetesClientPodLabelsAndAnnotationsSupplier.externalName;
5453
import static org.springframework.cloud.kubernetes.client.discovery.KubernetesClientPodLabelsAndAnnotationsSupplier.nonExternalName;
5554
import static org.springframework.cloud.kubernetes.commons.discovery.DiscoveryClientUtils.endpointsPort;
55+
import static org.springframework.cloud.kubernetes.commons.discovery.DiscoveryClientUtils.externalNameServiceInstance;
5656
import static org.springframework.cloud.kubernetes.commons.discovery.DiscoveryClientUtils.serviceInstance;
5757
import static org.springframework.cloud.kubernetes.commons.discovery.DiscoveryClientUtils.serviceInstanceMetadata;
5858
import static org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryConstants.EXTERNAL_NAME;
@@ -143,10 +143,8 @@ public List<ServiceInstance> getInstances(String serviceId) {
143143
properties);
144144

145145
KubernetesClientInstanceIdHostPodNameSupplier supplierOne = externalName(service);
146-
KubernetesClientPodLabelsAndAnnotationsSupplier supplierTwo = externalName();
147-
148-
ServiceInstance externalNameServiceInstance = serviceInstance(null, serviceMetadata, supplierOne,
149-
supplierTwo, new ServicePortNameAndNumber(-1, null), serviceInstanceMetadata, properties);
146+
ServiceInstance externalNameServiceInstance = externalNameServiceInstance(serviceMetadata, supplierOne,
147+
serviceInstanceMetadata);
150148
serviceInstances.add(externalNameServiceInstance);
151149
}
152150
}

spring-cloud-kubernetes-client-discovery/src/test/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesClientInformerDiscoveryClientTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353
import org.springframework.cloud.client.ServiceInstance;
5454
import org.springframework.cloud.kubernetes.commons.discovery.DefaultKubernetesServiceInstance;
5555
import org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryProperties;
56+
import org.springframework.cloud.kubernetes.commons.discovery.KubernetesExternalNameServiceInstance;
5657

5758
import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.options;
5859
import static org.assertj.core.api.Assertions.assertThat;
@@ -570,7 +571,8 @@ void testExternalNameService() {
570571

571572
List<ServiceInstance> result = discoveryClient.getInstances("blue-service");
572573
assertThat(result.size()).isEqualTo(1);
573-
DefaultKubernetesServiceInstance externalNameServiceInstance = (DefaultKubernetesServiceInstance) result.get(0);
574+
KubernetesExternalNameServiceInstance externalNameServiceInstance = (KubernetesExternalNameServiceInstance) result
575+
.get(0);
574576
assertThat(externalNameServiceInstance.getServiceId()).isEqualTo("blue-service");
575577
assertThat(externalNameServiceInstance.getHost()).isEqualTo("k8s-spring-b");
576578
assertThat(externalNameServiceInstance.getPort()).isEqualTo(-1);

spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/AbstractKubernetesInfoContributor.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -69,11 +69,6 @@ public abstract class AbstractKubernetesInfoContributor implements InfoContribut
6969
*/
7070
public static final String HOST_IP = "hostIp";
7171

72-
/**
73-
* Labels key.
74-
*/
75-
public static final String LABELS = "labels";
76-
7772
private static final Log LOG = LogFactory.getLog(AbstractKubernetesInfoContributor.class);
7873

7974
@Override

spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/configdata/KubernetesConfigDataLocationResolver.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public final List<KubernetesConfigDataResource> resolveProfileSpecific(
9090

9191
Environment environment = environment(kubernetesConfigData, profiles);
9292
KubernetesNamespaceProvider namespaceProvider = kubernetesNamespaceProvider(environment);
93-
registerBeans(resolverContext, location, profiles, properties, namespaceProvider);
93+
registerBeans(resolverContext, properties, namespaceProvider);
9494

9595
KubernetesConfigDataResource resource = new KubernetesConfigDataResource(location.isOptional(), profiles,
9696
environment);
@@ -99,8 +99,7 @@ public final List<KubernetesConfigDataResource> resolveProfileSpecific(
9999
}
100100

101101
protected abstract void registerBeans(ConfigDataLocationResolverContext resolverContext,
102-
ConfigDataLocation location, Profiles profiles, ConfigDataPropertiesHolder properties,
103-
KubernetesNamespaceProvider namespaceProvider);
102+
ConfigDataPropertiesHolder properties, KubernetesNamespaceProvider namespaceProvider);
104103

105104
protected final boolean isRetryEnabledForConfigMap(ConfigMapConfigProperties configMapProperties) {
106105
return RETRY_IS_PRESENT && configMapProperties != null && configMapProperties.retry().enabled()

spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/discovery/DiscoveryClientUtils.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,16 @@ public static ServiceInstance serviceInstance(@Nullable ServicePortSecureResolve
159159
podMetadata);
160160
}
161161

162+
public static ServiceInstance externalNameServiceInstance(ServiceMetadata serviceMetadata,
163+
Supplier<InstanceIdHostPodName> instanceIdAndHost, Map<String, String> serviceInstanceMetadata) {
164+
165+
InstanceIdHostPodName data = instanceIdAndHost.get();
166+
167+
return new KubernetesExternalNameServiceInstance(serviceMetadata.name(), data.host(), data.instanceId(),
168+
serviceInstanceMetadata);
169+
170+
}
171+
162172
/**
163173
* take primary-port-name from service label "PRIMARY_PORT_NAME_LABEL_KEY" if it
164174
* exists, otherwise from KubernetesDiscoveryProperties if it exists, otherwise null.

spring-cloud-kubernetes-commons/src/test/java/org/springframework/cloud/kubernetes/commons/configdata/KubernetesConfigDataLocationResolverTests.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -49,10 +49,8 @@ class KubernetesConfigDataLocationResolverTests {
4949
private static final KubernetesConfigDataLocationResolver NOOP_RESOLVER = new KubernetesConfigDataLocationResolver() {
5050

5151
@Override
52-
protected void registerBeans(ConfigDataLocationResolverContext resolverContext, ConfigDataLocation location,
53-
Profiles profiles, ConfigDataPropertiesHolder properties,
54-
KubernetesNamespaceProvider namespaceProvider) {
55-
52+
protected void registerBeans(ConfigDataLocationResolverContext resolverContext,
53+
ConfigDataPropertiesHolder properties, KubernetesNamespaceProvider namespaceProvider) {
5654
}
5755

5856
};
@@ -293,8 +291,8 @@ void testResolveProfileSpecificSix() {
293291

294292
Profiles profiles = Mockito.mock(Profiles.class);
295293
ConfigDataLocation configDataLocation = ConfigDataLocation.of("kubernetes:abc");
296-
List<KubernetesConfigDataResource> result = storePropertiesResolver.resolveProfileSpecific(RESOLVER_CONTEXT,
297-
configDataLocation, profiles);
294+
storePropertiesResolver.resolveProfileSpecific(RESOLVER_CONTEXT,
295+
configDataLocation, profiles);
298296

299297
// on the other hand, @Default will be picked here
300298
Assertions.assertThat(storePropertiesResolver.configMapConfigProperties.enabled()).isTrue();

spring-cloud-kubernetes-commons/src/test/java/org/springframework/cloud/kubernetes/commons/configdata/StorePropertiesResolver.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,7 @@
1616

1717
package org.springframework.cloud.kubernetes.commons.configdata;
1818

19-
import org.springframework.boot.context.config.ConfigDataLocation;
2019
import org.springframework.boot.context.config.ConfigDataLocationResolverContext;
21-
import org.springframework.boot.context.config.Profiles;
2220
import org.springframework.cloud.kubernetes.commons.KubernetesClientProperties;
2321
import org.springframework.cloud.kubernetes.commons.KubernetesNamespaceProvider;
2422
import org.springframework.cloud.kubernetes.commons.config.ConfigMapConfigProperties;
@@ -36,8 +34,8 @@ class StorePropertiesResolver extends KubernetesConfigDataLocationResolver {
3634
KubernetesClientProperties kubernetesClientProperties;
3735

3836
@Override
39-
protected void registerBeans(ConfigDataLocationResolverContext resolverContext, ConfigDataLocation location,
40-
Profiles profiles, ConfigDataPropertiesHolder properties, KubernetesNamespaceProvider namespaceProvider) {
37+
protected void registerBeans(ConfigDataLocationResolverContext resolverContext,
38+
ConfigDataPropertiesHolder properties, KubernetesNamespaceProvider namespaceProvider) {
4139

4240
secretsConfigProperties = properties.secretsProperties();
4341
configMapConfigProperties = properties.configMapProperties();

spring-cloud-kubernetes-controllers/spring-cloud-kubernetes-configuration-watcher/src/test/java/org/springframework/cloud/kubernetes/configuration/watcher/BusEventBasedConfigMapWatcherChangeDetectorTests.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,6 @@ class BusEventBasedConfigMapWatcherChangeDetectorTests {
6767
@Mock
6868
private ApplicationEventPublisher applicationEventPublisher;
6969

70-
private BusEventBasedConfigMapWatcherChangeDetector changeDetector;
71-
7270
private BusProperties busProperties;
7371

7472
private MockEnvironment mockEnvironment;

spring-cloud-kubernetes-fabric8-config/src/main/java/org/springframework/cloud/kubernetes/fabric8/config/Fabric8ConfigDataLocationResolver.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,7 @@
2020
import io.fabric8.kubernetes.client.KubernetesClient;
2121

2222
import org.springframework.boot.bootstrap.ConfigurableBootstrapContext;
23-
import org.springframework.boot.context.config.ConfigDataLocation;
2423
import org.springframework.boot.context.config.ConfigDataLocationResolverContext;
25-
import org.springframework.boot.context.config.Profiles;
2624
import org.springframework.cloud.kubernetes.commons.KubernetesClientProperties;
2725
import org.springframework.cloud.kubernetes.commons.KubernetesNamespaceProvider;
2826
import org.springframework.cloud.kubernetes.commons.config.ConfigDataRetryableConfigMapPropertySourceLocator;
@@ -45,9 +43,8 @@
4543
public class Fabric8ConfigDataLocationResolver extends KubernetesConfigDataLocationResolver {
4644

4745
@Override
48-
protected void registerBeans(ConfigDataLocationResolverContext resolverContext, ConfigDataLocation location,
49-
Profiles profiles, ConfigDataPropertiesHolder propertiesHolder,
50-
KubernetesNamespaceProvider namespaceProvider) {
46+
protected void registerBeans(ConfigDataLocationResolverContext resolverContext,
47+
ConfigDataPropertiesHolder propertiesHolder, KubernetesNamespaceProvider namespaceProvider) {
5148

5249
KubernetesClientProperties kubernetesClientProperties = propertiesHolder.clientProperties();
5350
ConfigMapConfigProperties configMapProperties = propertiesHolder.configMapProperties();

0 commit comments

Comments
 (0)