Class ReactiveApiVersionServiceInstanceListSupplier

java.lang.Object

org.springframework.cloud.loadbalancer.core.DelegatingServiceInstanceListSupplier

org.springframework.cloud.loadbalancer.core.ReactiveApiVersionServiceInstanceListSupplier

All Implemented Interfaces:

Supplier<reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>>, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, SelectedInstanceCallback, ServiceInstanceListSupplier

public class ReactiveApiVersionServiceInstanceListSupplier
extends DelegatingServiceInstanceListSupplier

A reactive version of the ServiceInstanceListSupplier that filters service instances based on the API version specified in the request. The version is extracted from the request using an ApiVersionStrategy and matched against the API_VERSION metadata field of the service instances.

Since:

5.0.x

Author:

Olga Maciaszek-Sharma

Field Summary

Fields

Modifier and Type	Field	Description
static final String	API_VERSION	Service instance metadata map key that service instance API version is retrieved from.

Fields inherited from class DelegatingServiceInstanceListSupplier

delegate

Constructor Summary

Constructors

Constructor	Description
ReactiveApiVersionServiceInstanceListSupplier(ServiceInstanceListSupplier delegate, LoadBalancerClientFactory loadBalancerClientFactory)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>	get()
reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>	get(org.springframework.cloud.client.loadbalancer.Request request)

Methods inherited from class DelegatingServiceInstanceListSupplier

afterPropertiesSet, destroy, getDelegate, getServiceId, selectedServiceInstance

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

API_VERSION

public static final String API_VERSION

Service instance metadata map key that service instance API version is retrieved from.

See Also:

• Constant Field Values

Constructor Details

ReactiveApiVersionServiceInstanceListSupplier

public ReactiveApiVersionServiceInstanceListSupplier(ServiceInstanceListSupplier delegate,
 LoadBalancerClientFactory loadBalancerClientFactory)

Method Details

get

public reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>> get(org.springframework.cloud.client.loadbalancer.Request request)

get

public reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>> get()