Package 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, Closeable, AutoCloseable

@Singleton
@Requires(env="k8s") @Requires(property="kubernetes.client.discovery.enabled",notEquals="false",defaultValue="true")
public class KubernetesDiscoveryClient
extends 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	Description
protected static final org.slf4j.Logger	LOG
static final String	SERVICE_ID

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
@NonNull String	getDescription()
org.reactivestreams.Publisher<List<io.micronaut.discovery.ServiceInstance>>	getInstances(String serviceId)
org.reactivestreams.Publisher<List<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 Details

SERVICE_ID

public static final String SERVICE_ID

See Also:

• Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

Constructor Details

KubernetesDiscoveryClient

@Inject
public KubernetesDiscoveryClient(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client,
 KubernetesConfiguration configuration,
 KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration,
 List<KubernetesServiceConfiguration> serviceConfigurations,
 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 Details

getInstances

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

Specified by:

getInstances in interface io.micronaut.discovery.DiscoveryClient

getServiceIds

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

Specified by:

getServiceIds in interface io.micronaut.discovery.DiscoveryClient

Returns:

A list of services metadata's name.

getDescription

@NonNull
public @NonNull String getDescription()

Specified by:

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable