Skip to content

Commit 4c6ff11

Browse files
authored
Merge pull request #2049 from wind57/drop_deprecations
Drop deprecations
2 parents 173ee09 + 72e64e7 commit 4c6ff11

File tree

30 files changed

+205
-976
lines changed

30 files changed

+205
-976
lines changed

.github/workflows/composites/pre-test-actions/action.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ runs:
2424
- name: build project
2525
shell: bash
2626
run: |
27-
./mvnw clean install -Dspring-boot.build-image.skip=true -DskipITs -DskipTests -T1C -U -B -q
27+
./mvnw clean install -P 'run-on-github-actions' -Dspring-boot.build-image.skip=true -DskipITs -DskipTests -T1C -U -B -q
2828
2929
- name: build controllers project
3030
uses: ./.github/workflows/composites/build-controllers-project

spring-cloud-kubernetes-client-autoconfig/src/main/java/org/springframework/cloud/kubernetes/client/KubernetesClientPodUtils.java

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -60,20 +60,6 @@ public class KubernetesClientPodUtils implements PodUtils<V1Pod> {
6060

6161
private final boolean failFast;
6262

63-
@Deprecated(forRemoval = true)
64-
public KubernetesClientPodUtils(CoreV1Api client, String namespace) {
65-
if (client == null) {
66-
throw new IllegalArgumentException("Must provide an instance of KubernetesClient");
67-
}
68-
69-
this.client = client;
70-
this.hostName = EnvReader.getEnv(HOSTNAME);
71-
this.serviceHost = EnvReader.getEnv(KUBERNETES_SERVICE_HOST);
72-
this.current = LazilyInstantiate.using(this::internalGetPod);
73-
this.namespace = namespace;
74-
this.failFast = false;
75-
}
76-
7763
// mainly needed for the health and info contributors, so that they report DOWN
7864
// correctly
7965
public KubernetesClientPodUtils(CoreV1Api client, String namespace, boolean failFast) {

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,6 @@
2929
*/
3030
public class KubernetesClientSecretsPropertySource extends SecretsPropertySource {
3131

32-
@Deprecated(forRemoval = true)
33-
public KubernetesClientSecretsPropertySource(SourceData sourceData) {
34-
super(sourceData);
35-
}
36-
3732
private static final EnumMap<NormalizedSourceType, KubernetesClientContextToSourceData> STRATEGIES = new EnumMap<>(
3833
NormalizedSourceType.class);
3934

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

Lines changed: 0 additions & 66 deletions
This file was deleted.

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,13 @@
1717
package org.springframework.cloud.kubernetes.client.discovery;
1818

1919
import java.util.Collections;
20+
import java.util.List;
2021

2122
import io.kubernetes.client.informer.SharedIndexInformer;
2223
import io.kubernetes.client.informer.SharedInformerFactory;
2324
import io.kubernetes.client.informer.cache.Lister;
2425
import io.kubernetes.client.openapi.ApiClient;
26+
import io.kubernetes.client.openapi.apis.CoreV1Api;
2527
import io.kubernetes.client.openapi.models.V1Endpoints;
2628
import io.kubernetes.client.openapi.models.V1EndpointsList;
2729
import io.kubernetes.client.openapi.models.V1Service;
@@ -96,8 +98,9 @@ public void initialize(BootstrapRegistry registry) {
9698
.sharedIndexInformerFor(endpointsApi, V1Endpoints.class, 0L, namespace);
9799
Lister<V1Endpoints> endpointsLister = new Lister<>(endpointsSharedIndexInformer.getIndexer());
98100
KubernetesInformerDiscoveryClient discoveryClient = new KubernetesInformerDiscoveryClient(
99-
sharedInformerFactory, serviceLister, endpointsLister, serviceSharedIndexInformer,
100-
endpointsSharedIndexInformer, discoveryProperties);
101+
List.of(sharedInformerFactory), List.of(serviceLister), List.of(endpointsLister),
102+
List.of(serviceSharedIndexInformer), List.of(endpointsSharedIndexInformer), discoveryProperties,
103+
new CoreV1Api(apiClient));
101104
try {
102105
discoveryClient.afterPropertiesSet();
103106
return discoveryClient::getInstances;

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

Lines changed: 0 additions & 133 deletions
This file was deleted.

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

Lines changed: 8 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@
3535
import jakarta.annotation.PostConstruct;
3636
import org.apache.commons.logging.LogFactory;
3737

38-
import org.springframework.beans.factory.annotation.Autowired;
3938
import org.springframework.cloud.client.ServiceInstance;
4039
import org.springframework.cloud.client.discovery.DiscoveryClient;
4140
import org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryProperties;
@@ -82,46 +81,22 @@ public class KubernetesInformerDiscoveryClient implements DiscoveryClient {
8281

8382
private final ServicePortSecureResolver servicePortSecureResolver;
8483

85-
// visible only for testing and
86-
// must be constructor injected in a future release
87-
@Autowired
88-
CoreV1Api coreV1Api;
89-
90-
@Deprecated(forRemoval = true)
91-
public KubernetesInformerDiscoveryClient(String namespace, SharedInformerFactory sharedInformerFactory,
92-
Lister<V1Service> serviceLister, Lister<V1Endpoints> endpointsLister,
93-
SharedInformer<V1Service> serviceInformer, SharedInformer<V1Endpoints> endpointsInformer,
94-
KubernetesDiscoveryProperties properties) {
95-
this.sharedInformerFactories = List.of(sharedInformerFactory);
96-
this.serviceListers = List.of(serviceLister);
97-
this.endpointsListers = List.of(endpointsLister);
98-
this.informersReadyFunc = () -> serviceInformer.hasSynced() && endpointsInformer.hasSynced();
99-
this.properties = properties;
100-
filter = filter(properties);
101-
servicePortSecureResolver = new ServicePortSecureResolver(properties);
102-
}
103-
104-
public KubernetesInformerDiscoveryClient(SharedInformerFactory sharedInformerFactory,
105-
Lister<V1Service> serviceLister, Lister<V1Endpoints> endpointsLister,
106-
SharedInformer<V1Service> serviceInformer, SharedInformer<V1Endpoints> endpointsInformer,
107-
KubernetesDiscoveryProperties properties) {
108-
this.sharedInformerFactories = List.of(sharedInformerFactory);
109-
this.serviceListers = List.of(serviceLister);
110-
this.endpointsListers = List.of(endpointsLister);
111-
this.informersReadyFunc = () -> serviceInformer.hasSynced() && endpointsInformer.hasSynced();
112-
this.properties = properties;
113-
filter = filter(properties);
114-
servicePortSecureResolver = new ServicePortSecureResolver(properties);
115-
}
84+
final CoreV1Api coreV1Api;
11685

11786
public KubernetesInformerDiscoveryClient(List<SharedInformerFactory> sharedInformerFactories,
11887
List<Lister<V1Service>> serviceListers, List<Lister<V1Endpoints>> endpointsListers,
11988
List<SharedInformer<V1Service>> serviceInformers, List<SharedInformer<V1Endpoints>> endpointsInformers,
120-
KubernetesDiscoveryProperties properties) {
89+
KubernetesDiscoveryProperties properties, CoreV1Api coreV1Api) {
12190
this.sharedInformerFactories = sharedInformerFactories;
12291

12392
this.serviceListers = serviceListers;
12493
this.endpointsListers = endpointsListers;
94+
this.coreV1Api = coreV1Api;
95+
this.properties = properties;
96+
97+
filter = filter(properties);
98+
servicePortSecureResolver = new ServicePortSecureResolver(properties);
99+
125100
this.informersReadyFunc = () -> {
126101
boolean serviceInformersReady = serviceInformers.isEmpty() || serviceInformers.stream()
127102
.map(SharedInformer::hasSynced)
@@ -134,9 +109,6 @@ public KubernetesInformerDiscoveryClient(List<SharedInformerFactory> sharedInfor
134109
return serviceInformersReady && endpointsInformersReady;
135110
};
136111

137-
this.properties = properties;
138-
filter = filter(properties);
139-
servicePortSecureResolver = new ServicePortSecureResolver(properties);
140112
}
141113

142114
@Override

0 commit comments

Comments
 (0)