Class DiscoveryClientServiceInstanceListSupplier

java.lang.Object

org.springframework.cloud.loadbalancer.core.DiscoveryClientServiceInstanceListSupplier

All Implemented Interfaces:

Supplier<reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>>, ServiceInstanceListSupplier

public class DiscoveryClientServiceInstanceListSupplier
extends Object
implements ServiceInstanceListSupplier

A discovery-client-based ServiceInstanceListSupplier implementation.

Since:

2.2.0

Author:

Spencer Gibb, Olga Maciaszek-Sharma, Tim Ysewyn, Rod Catter

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVICE_DISCOVERY_TIMEOUT	Property that establishes the timeout for calls to service discovery.

Constructor Summary

Constructors

Constructor	Description
DiscoveryClientServiceInstanceListSupplier(org.springframework.cloud.client.discovery.DiscoveryClient delegate, org.springframework.core.env.Environment environment)
DiscoveryClientServiceInstanceListSupplier(org.springframework.cloud.client.discovery.ReactiveDiscoveryClient delegate, org.springframework.core.env.Environment environment)

Method Summary

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

Methods inherited from class Object

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

Methods inherited from interface ServiceInstanceListSupplier

get

Field Details

SERVICE_DISCOVERY_TIMEOUT

public static final String SERVICE_DISCOVERY_TIMEOUT

Property that establishes the timeout for calls to service discovery.

See Also:

• Constant Field Values

Constructor Details

DiscoveryClientServiceInstanceListSupplier

public DiscoveryClientServiceInstanceListSupplier(org.springframework.cloud.client.discovery.DiscoveryClient delegate,
 org.springframework.core.env.Environment environment)

DiscoveryClientServiceInstanceListSupplier

public DiscoveryClientServiceInstanceListSupplier(org.springframework.cloud.client.discovery.ReactiveDiscoveryClient delegate,
 org.springframework.core.env.Environment environment)

Method Details

getServiceId

public String getServiceId()

Specified by:

getServiceId in interface ServiceInstanceListSupplier

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>>>