io.micronaut.discovery.consul.client.v1

Class AbstractConsulClient

java.lang.Object

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

All Implemented Interfaces:

io.micronaut.core.naming.Described, ConsulClient, ConsulOperations, io.micronaut.discovery.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()
org.reactivestreams.Publisher<java.util.List<io.micronaut.discovery.ServiceInstance>>	getInstances(java.lang.String serviceId)
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()

Specified by:

getDescription in interface io.micronaut.core.naming.Described

getServiceIds

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

Specified by:

getServiceIds in interface ConsulClient

Specified by:

getServiceIds in interface io.micronaut.discovery.DiscoveryClient

getInstances

public org.reactivestreams.Publisher<java.util.List<io.micronaut.discovery.ServiceInstance>> getInstances(java.lang.String serviceId)

Specified by:

getInstances in interface io.micronaut.discovery.DiscoveryClient