io.micronaut.discovery.client

Class CachingCompositeDiscoveryClient

java.lang.Object

io.micronaut.discovery.CompositeDiscoveryClient

io.micronaut.discovery.client.CachingCompositeDiscoveryClient

All Implemented Interfaces:

Described, DiscoveryClient, Closeable, AutoCloseable

@Primary
 @Requires(property="micronaut.caches.discovery-client.enabled",
          notEquals="false")
 @Replaces(value=DefaultCompositeDiscoveryClient.class)
public class CachingCompositeDiscoveryClient
extends CompositeDiscoveryClient

Replaces the default DefaultCompositeDiscoveryClient with one that caches the return values.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
CachingCompositeDiscoveryClient(DiscoveryClient[] discoveryClients)

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<List<ServiceInstance>>	getInstances(String serviceId) Obtain a list of ServiceInstance for the given service id.
io.reactivex.Flowable<List<String>>	getServiceIds()

Methods inherited from class io.micronaut.discovery.CompositeDiscoveryClient

close, getDescription, getDiscoveryClients, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingCompositeDiscoveryClient

public CachingCompositeDiscoveryClient(DiscoveryClient[] discoveryClients)

Parameters:

discoveryClients - The discovery clients

Method Detail

getInstances

@Cacheable(value="discovery-client")
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

Overrides:

getInstances in class CompositeDiscoveryClient

Parameters:

serviceId - The service id

Returns:

A Publisher that emits a list of ServiceInstance

getServiceIds

@Cacheable(value="discovery-client")
public io.reactivex.Flowable<List<String>> getServiceIds()

Specified by:

getServiceIds in interface DiscoveryClient

Overrides:

getServiceIds in class CompositeDiscoveryClient

Returns:

The known service IDs