Class SubsetServiceInstanceListSupplier

java.lang.Object

org.springframework.cloud.loadbalancer.core.DelegatingServiceInstanceListSupplier

org.springframework.cloud.loadbalancer.core.SubsetServiceInstanceListSupplier

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 SubsetServiceInstanceListSupplier
extends DelegatingServiceInstanceListSupplier

A ServiceInstanceListSupplier implementation that uses deterministic subsetting algorithm to limit the number of instances provided by delegate.

Since:

4.1.0

Author:

Zhuozhi Ji

Field Summary

Fields inherited from class DelegatingServiceInstanceListSupplier

delegate

Constructor Summary

Constructors

Constructor	Description
SubsetServiceInstanceListSupplier(ServiceInstanceListSupplier delegate, org.springframework.core.env.PropertyResolver resolver, org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer.Factory<org.springframework.cloud.client.ServiceInstance> factory)

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)
String	getInstanceId()
int	getSize()

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

Constructor Details

SubsetServiceInstanceListSupplier

public SubsetServiceInstanceListSupplier(ServiceInstanceListSupplier delegate,
 org.springframework.core.env.PropertyResolver resolver,
 org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer.Factory<org.springframework.cloud.client.ServiceInstance> factory)

Method Details

get

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

get

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

getInstanceId

public String getInstanceId()

getSize

public int getSize()