Class SameInstancePreferenceServiceInstanceListSupplier

java.lang.Object

org.springframework.cloud.loadbalancer.core.DelegatingServiceInstanceListSupplier

org.springframework.cloud.loadbalancer.core.SameInstancePreferenceServiceInstanceListSupplier

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 SameInstancePreferenceServiceInstanceListSupplier
extends DelegatingServiceInstanceListSupplier
implements SelectedInstanceCallback

An implementation of ServiceInstanceListSupplier that selects the previously chosen instance if it's available.

Since:

2.2.7

Author:

Olga Maciaszek-Sharma, Jürgen Kreitler

Field Summary

Fields inherited from class DelegatingServiceInstanceListSupplier

delegate

Constructor Summary

Constructors

Constructor	Description
SameInstancePreferenceServiceInstanceListSupplier(ServiceInstanceListSupplier delegate)
SameInstancePreferenceServiceInstanceListSupplier(ServiceInstanceListSupplier delegate, org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer.Factory<org.springframework.cloud.client.ServiceInstance> 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)
void	selectedServiceInstance(org.springframework.cloud.client.ServiceInstance serviceInstance)	Passes the selected ServiceInstance as an argument.

Methods inherited from class DelegatingServiceInstanceListSupplier

afterPropertiesSet, destroy, getDelegate, getServiceId

Methods inherited from class Object

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

Constructor Details

SameInstancePreferenceServiceInstanceListSupplier

public SameInstancePreferenceServiceInstanceListSupplier(ServiceInstanceListSupplier delegate)

SameInstancePreferenceServiceInstanceListSupplier

public SameInstancePreferenceServiceInstanceListSupplier(ServiceInstanceListSupplier delegate,
 org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer.Factory<org.springframework.cloud.client.ServiceInstance> loadBalancerClientFactory)

Method Details

get

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

Specified by:

get in interface Supplier<reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>>

get

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

Specified by:

get in interface ServiceInstanceListSupplier

selectedServiceInstance

public void selectedServiceInstance(org.springframework.cloud.client.ServiceInstance serviceInstance)

Description copied from interface: SelectedInstanceCallback

Passes the selected ServiceInstance as an argument.

Specified by:

selectedServiceInstance in interface SelectedInstanceCallback

Overrides:

selectedServiceInstance in class DelegatingServiceInstanceListSupplier

Parameters:

serviceInstance - that has been selected