io.micronaut.discovery.consul.client.v1

Class AbstractConsulClient

java.lang.Object

io.micronaut.discovery.consul.client.v1.AbstractConsulClient

All Implemented Interfaces:

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

@Client(id="consul",
        path="/v1",
        configuration=ConsulConfiguration.class)
 @Requires(beans=ConsulConfiguration.class)
public abstract class AbstractConsulClient
extends java.lang.Object
implements ConsulClient

Abstract implementation of ConsulClient that also implements DiscoveryClient.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields inherited from interface io.micronaut.discovery.consul.client.v1.ConsulClient

SERVICE_ID

Constructor Summary

Constructors

Constructor and Description
AbstractConsulClient()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getDescription() A description that describes this object.
org.reactivestreams.Publisher<java.util.List<ServiceInstance>>	getInstances(java.lang.String serviceId) Obtain a list of ServiceInstance for the given service id.
org.reactivestreams.Publisher<java.util.List<java.lang.String>>	getServiceIds()
void	setConsulConfiguration(ConsulConfiguration consulConfiguration)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.discovery.consul.client.v1.ConsulOperations

deregister, deregister, fail, fail, getHealthyServices, getHealthyServices, getMembers, getNodes, getNodes, getSelf, getServiceNames, getServices, pass, pass, putValue, readValues, readValues, register, register, status, warn, warn

Methods inherited from interface java.io.Closeable

close

Constructor Detail

AbstractConsulClient

public AbstractConsulClient()

Method Detail

setConsulConfiguration

@Inject
public void setConsulConfiguration(ConsulConfiguration consulConfiguration)

Parameters:

consulConfiguration - The Consul configuration

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

getServiceIds

public org.reactivestreams.Publisher<java.util.List<java.lang.String>> getServiceIds()

Specified by:

getServiceIds in interface ConsulClient

Specified by:

getServiceIds in interface DiscoveryClient

Returns:

The known service IDs

getInstances

public org.reactivestreams.Publisher<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