io.micronaut.kubernetes.discovery

Class KubernetesDiscoveryClient

java.lang.Object

io.micronaut.kubernetes.discovery.KubernetesDiscoveryClient

All Implemented Interfaces:

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

@Singleton
 @Requires(env="k8s") @Requires(beans={KubernetesClient.class,KubernetesConfiguration.KubernetesDiscoveryConfiguration.class}) @Requires(property="kubernetes.client.discovery.enabled",notEquals="false")
 @Replaces(bean=io.micronaut.discovery.kubernetes.KubernetesDiscoveryClient.class)
public class KubernetesDiscoveryClient
extends java.lang.Object
implements io.micronaut.discovery.DiscoveryClient

A DiscoveryClient implementation for Kubernetes using the API.

Since:

1.0.0

Author:

Álvaro Sánchez-Mariscal

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
KubernetesDiscoveryClient(KubernetesClient client, KubernetesConfiguration configuration, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration, KubernetesServiceInstanceList instanceList)

Method Summary

Modifier and Type	Method and Description
void	close()
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()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KubernetesDiscoveryClient

public KubernetesDiscoveryClient(KubernetesClient client,
                                 KubernetesConfiguration configuration,
                                 KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration,
                                 KubernetesServiceInstanceList instanceList)

Parameters:

client - An HTTP Client to query the Kubernetes API.

configuration - The configuration properties

discoveryConfiguration - The discovery configuration properties

instanceList - The KubernetesServiceInstanceList

Method Detail

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

getServiceIds

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

Specified by:

getServiceIds in interface io.micronaut.discovery.DiscoveryClient

Returns:

A list of services metadata's name.

getDescription

public java.lang.String getDescription()

Specified by:

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

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