io.micronaut.cache.discovery

Class CachingCompositeDiscoveryClient

java.lang.Object

io.micronaut.discovery.CompositeDiscoveryClient

io.micronaut.cache.discovery.CachingCompositeDiscoveryClient

All Implemented Interfaces:

io.micronaut.core.naming.Described, io.micronaut.discovery.DiscoveryClient, java.io.Closeable, java.lang.AutoCloseable

@Primary
 @Requires(beans=DiscoveryClientCacheConfiguration.class)
 @Replaces(value=io.micronaut.discovery.DefaultCompositeDiscoveryClient.class)
public class CachingCompositeDiscoveryClient
extends io.micronaut.discovery.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(io.micronaut.discovery.DiscoveryClient[] discoveryClients)

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<java.util.List<io.micronaut.discovery.ServiceInstance>>	getInstances(java.lang.String serviceId)
io.reactivex.Flowable<java.util.List<java.lang.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(io.micronaut.discovery.DiscoveryClient[] discoveryClients)

Parameters:

discoveryClients - The discovery clients

Method Detail

getInstances

@Cacheable(value="discovery-client")
public io.reactivex.Flowable<java.util.List<io.micronaut.discovery.ServiceInstance>> getInstances(java.lang.String serviceId)

Specified by:

getInstances in interface io.micronaut.discovery.DiscoveryClient

Overrides:

getInstances in class io.micronaut.discovery.CompositeDiscoveryClient

getServiceIds

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

Specified by:

getServiceIds in interface io.micronaut.discovery.DiscoveryClient

Overrides:

getServiceIds in class io.micronaut.discovery.CompositeDiscoveryClient