io.micronaut.discovery

Class CompositeDiscoveryClient

java.lang.Object

io.micronaut.discovery.CompositeDiscoveryClient

All Implemented Interfaces:

Described, DiscoveryClient, Closeable, AutoCloseable

Direct Known Subclasses:

CachingCompositeDiscoveryClient, DefaultCompositeDiscoveryClient

public abstract class CompositeDiscoveryClient
extends Object
implements DiscoveryClient

A composite implementation combining all registered DiscoveryClient instances.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompositeDiscoveryClient(DiscoveryClient[] discoveryClients) Construct the CompositeDiscoveryClient from all discovery clients.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeDiscoveryClient

protected CompositeDiscoveryClient(DiscoveryClient[] discoveryClients)

Construct the CompositeDiscoveryClient from all discovery clients.

Parameters:

discoveryClients - The service discovery clients

Method Detail

getDescription

public String getDescription()

Description copied from interface: Described

A description that describes this object.

Specified by:

getDescription in interface Described

Returns:

The description

getDiscoveryClients

public DiscoveryClient[] getDiscoveryClients()

The underlying clients.

Returns:

The clients

getInstances

public io.reactivex.Flowable<List<ServiceInstance>> getInstances(String serviceId)

Description copied from interface: DiscoveryClient

Obtain a list of ServiceInstance for the given service id.

Specified by:

getInstances in interface DiscoveryClient

Parameters:

serviceId - The service id

Returns:

A Publisher that emits a list of ServiceInstance

getServiceIds

public io.reactivex.Flowable<List<String>> getServiceIds()

Specified by:

getServiceIds in interface DiscoveryClient

Returns:

The known service IDs

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object