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(property="kubernetes.client.discovery.enabled",notEquals="false",defaultValue="true")
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
static java.lang.String	SERVICE_ID

Constructor Summary

Constructors

Constructor and Description

KubernetesDiscoveryClient(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client, KubernetesConfiguration configuration, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration, java.util.List<KubernetesServiceConfiguration> serviceConfigurations, java.util.List<KubernetesServiceInstanceProvider> instanceProviders, KubernetesServiceInstanceList instanceList) Creates discovery client that supports the discovery modes.

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

Methods inherited from interface io.micronaut.core.naming.Described

getDescription

Field Detail

SERVICE_ID

public static final java.lang.String SERVICE_ID

See Also:

Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KubernetesDiscoveryClient

@Inject
public KubernetesDiscoveryClient(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client,
                                         KubernetesConfiguration configuration,
                                         KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration,
                                         java.util.List<KubernetesServiceConfiguration> serviceConfigurations,
                                         java.util.List<KubernetesServiceInstanceProvider> instanceProviders,
                                         KubernetesServiceInstanceList instanceList)

Creates discovery client that supports the discovery modes.

Parameters:

client - An HTTP Client to query the Kubernetes API.

configuration - The configuration properties

discoveryConfiguration - The discovery configuration properties

serviceConfigurations - The manual service discovery configurations

instanceProviders - The service instance provider implementations

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

@NonNull
public java.lang.String getDescription()

Specified by:

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

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable