Skip to content

Commit dd16c5a

Browse files
committed
drop deprecations
Signed-off-by: wind57 <[email protected]>
1 parent 827a637 commit dd16c5a

File tree

21 files changed

+197
-432
lines changed

21 files changed

+197
-432
lines changed

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: 1 addition & 2 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,7 +81,7 @@ public class KubernetesInformerDiscoveryClient implements DiscoveryClient {
8281

8382
private final ServicePortSecureResolver servicePortSecureResolver;
8483

85-
private final CoreV1Api coreV1Api;
84+
final CoreV1Api coreV1Api;
8685

8786
public KubernetesInformerDiscoveryClient(List<SharedInformerFactory> sharedInformerFactories,
8887
List<Lister<V1Service>> serviceListers, List<Lister<V1Endpoints>> endpointsListers,

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

Lines changed: 8 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import io.kubernetes.client.informer.SharedInformer;
2222
import io.kubernetes.client.informer.SharedInformerFactory;
2323
import io.kubernetes.client.informer.cache.Lister;
24+
import io.kubernetes.client.openapi.apis.CoreV1Api;
2425
import io.kubernetes.client.openapi.models.V1Endpoints;
2526
import io.kubernetes.client.openapi.models.V1Service;
2627

@@ -30,7 +31,6 @@
3031
import org.springframework.cloud.client.CommonsClientAutoConfiguration;
3132
import org.springframework.cloud.client.discovery.simple.SimpleDiscoveryClientAutoConfiguration;
3233
import org.springframework.cloud.kubernetes.client.KubernetesClientAutoConfiguration;
33-
import org.springframework.cloud.kubernetes.commons.KubernetesNamespaceProvider;
3434
import org.springframework.cloud.kubernetes.commons.discovery.ConditionalOnSpringCloudKubernetesBlockingDiscovery;
3535
import org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryClientHealthConfiguration;
3636
import org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryProperties;
@@ -52,25 +52,16 @@
5252
@Import(KubernetesDiscoveryClientHealthConfiguration.class)
5353
public class KubernetesInformerDiscoveryClientAutoConfiguration {
5454

55-
@Deprecated(forRemoval = true)
56-
public KubernetesInformerDiscoveryClient kubernetesInformerDiscoveryClient(
57-
KubernetesNamespaceProvider kubernetesNamespaceProvider, SharedInformerFactory sharedInformerFactory,
58-
Lister<V1Service> serviceLister, Lister<V1Endpoints> endpointsLister,
59-
SharedInformer<V1Service> serviceInformer, SharedInformer<V1Endpoints> endpointsInformer,
60-
KubernetesDiscoveryProperties properties) {
61-
return new KubernetesInformerDiscoveryClient(kubernetesNamespaceProvider.getNamespace(), sharedInformerFactory,
62-
serviceLister, endpointsLister, serviceInformer, endpointsInformer, properties);
63-
}
64-
6555
@Bean
6656
@ConditionalOnMissingBean
6757
@Conditional(ConditionalOnSelectiveNamespacesMissing.class)
6858
KubernetesInformerDiscoveryClient kubernetesClientInformerDiscoveryClient(
6959
SharedInformerFactory sharedInformerFactory, Lister<V1Service> serviceLister,
7060
Lister<V1Endpoints> endpointsLister, SharedInformer<V1Service> serviceInformer,
71-
SharedInformer<V1Endpoints> endpointsInformer, KubernetesDiscoveryProperties properties) {
72-
return new KubernetesInformerDiscoveryClient(sharedInformerFactory, serviceLister, endpointsLister,
73-
serviceInformer, endpointsInformer, properties);
61+
SharedInformer<V1Endpoints> endpointsInformer, KubernetesDiscoveryProperties properties,
62+
CoreV1Api coreV1Api) {
63+
return new KubernetesInformerDiscoveryClient(List.of(sharedInformerFactory), List.of(serviceLister),
64+
List.of(endpointsLister), List.of(serviceInformer), List.of(endpointsInformer), properties, coreV1Api);
7465
}
7566

7667
@Bean
@@ -79,9 +70,10 @@ KubernetesInformerDiscoveryClient kubernetesClientInformerDiscoveryClient(
7970
KubernetesInformerDiscoveryClient selectiveNamespacesKubernetesInformerDiscoveryClient(
8071
List<SharedInformerFactory> sharedInformerFactories, List<Lister<V1Service>> serviceListers,
8172
List<Lister<V1Endpoints>> endpointsListers, List<SharedInformer<V1Service>> serviceInformers,
82-
List<SharedInformer<V1Endpoints>> endpointsInformers, KubernetesDiscoveryProperties properties) {
73+
List<SharedInformer<V1Endpoints>> endpointsInformers, KubernetesDiscoveryProperties properties,
74+
CoreV1Api coreV1Api) {
8375
return new KubernetesInformerDiscoveryClient(sharedInformerFactories, serviceListers, endpointsListers,
84-
serviceInformers, endpointsInformers, properties);
76+
serviceInformers, endpointsInformers, properties, coreV1Api);
8577
}
8678

8779
}

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

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -18,19 +18,12 @@
1818

1919
import java.util.Objects;
2020

21-
import io.kubernetes.client.informer.SharedInformer;
22-
import io.kubernetes.client.informer.SharedInformerFactory;
23-
import io.kubernetes.client.informer.cache.Lister;
24-
import io.kubernetes.client.openapi.models.V1Endpoints;
25-
import io.kubernetes.client.openapi.models.V1Service;
2621
import reactor.core.publisher.Flux;
2722
import reactor.core.scheduler.Schedulers;
2823

2924
import org.springframework.cloud.client.ServiceInstance;
3025
import org.springframework.cloud.client.discovery.ReactiveDiscoveryClient;
3126
import org.springframework.cloud.kubernetes.client.discovery.KubernetesInformerDiscoveryClient;
32-
import org.springframework.cloud.kubernetes.commons.KubernetesNamespaceProvider;
33-
import org.springframework.cloud.kubernetes.commons.discovery.KubernetesDiscoveryProperties;
3427

3528
/**
3629
* @author Ryan Baxter
@@ -39,18 +32,6 @@ public class KubernetesInformerReactiveDiscoveryClient implements ReactiveDiscov
3932

4033
private final KubernetesInformerDiscoveryClient kubernetesDiscoveryClient;
4134

42-
@Deprecated(forRemoval = true)
43-
public KubernetesInformerReactiveDiscoveryClient(KubernetesNamespaceProvider kubernetesNamespaceProvider,
44-
SharedInformerFactory sharedInformerFactory, Lister<V1Service> serviceLister,
45-
Lister<V1Endpoints> endpointsLister, SharedInformer<V1Service> serviceInformer,
46-
SharedInformer<V1Endpoints> endpointsInformer, KubernetesDiscoveryProperties properties) {
47-
this.kubernetesDiscoveryClient = new KubernetesInformerDiscoveryClient(
48-
kubernetesNamespaceProvider.getNamespace(), sharedInformerFactory, serviceLister, endpointsLister,
49-
serviceInformer, endpointsInformer, properties);
50-
}
51-
52-
// this is either kubernetesClientInformerDiscoveryClient
53-
// or selectiveNamespacesKubernetesClientInformerDiscoveryClient
5435
KubernetesInformerReactiveDiscoveryClient(KubernetesInformerDiscoveryClient kubernetesDiscoveryClient) {
5536
this.kubernetesDiscoveryClient = kubernetesDiscoveryClient;
5637
}

0 commit comments

Comments
 (0)