io.micronaut.discovery

Class CompositeDiscoveryClient

java.lang.Object

io.micronaut.discovery.CompositeDiscoveryClient

All Implemented Interfaces:

Described, DiscoveryClient, java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

DefaultCompositeDiscoveryClient

public abstract class CompositeDiscoveryClient
extends java.lang.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()
java.lang.String	getDescription() A description that describes this object.
DiscoveryClient[]	getDiscoveryClients() The underlying clients.
io.reactivex.Flowable<java.util.List<ServiceInstance>>	getInstances(java.lang.String serviceId) Obtain a list of ServiceInstance for the given service id.
io.reactivex.Flowable<java.util.List<java.lang.String>>	getServiceIds()
java.lang.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 java.lang.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<java.util.List<ServiceInstance>> getInstances(java.lang.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<java.util.List<java.lang.String>> getServiceIds()

Specified by:

getServiceIds in interface DiscoveryClient

Returns:

The known service IDs

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object