public abstract class CompositeDiscoveryClient extends Object implements DiscoveryClient
DiscoveryClient
instances.Modifier | Constructor and Description |
---|---|
protected |
CompositeDiscoveryClient(DiscoveryClient[] discoveryClients)
Construct the CompositeDiscoveryClient from all discovery clients.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
String |
getDescription()
A description that describes this object.
|
DiscoveryClient[] |
getDiscoveryClients()
The underlying clients.
|
io.reactivex.Flowable<List<ServiceInstance>> |
getInstances(String serviceId)
Obtain a list of
ServiceInstance for the given service id. |
io.reactivex.Flowable<List<String>> |
getServiceIds() |
String |
toString() |
protected CompositeDiscoveryClient(DiscoveryClient[] discoveryClients)
discoveryClients
- The service discovery clientspublic String getDescription()
Described
getDescription
in interface Described
public DiscoveryClient[] getDiscoveryClients()
public io.reactivex.Flowable<List<ServiceInstance>> getInstances(String serviceId)
DiscoveryClient
ServiceInstance
for the given service id.getInstances
in interface DiscoveryClient
serviceId
- The service idPublisher
that emits a list of ServiceInstance
public io.reactivex.Flowable<List<String>> getServiceIds()
getServiceIds
in interface DiscoveryClient
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException