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",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

Constructor Summary

Constructors

Constructor and Description
KubernetesDiscoveryClient(KubernetesClient client, KubernetesConfiguration configuration, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration, java.util.List<KubernetesServiceConfiguration> serviceConfigurations, KubernetesServiceInstanceList instanceList) Deprecated. This constructor is no longer used as it doesn't support the discovery modes. Use KubernetesDiscoveryClient(KubernetesClient, KubernetesConfiguration, KubernetesConfiguration.KubernetesDiscoveryConfiguration, List, List, KubernetesServiceInstanceList) instead.
KubernetesDiscoveryClient(KubernetesClient 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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KubernetesDiscoveryClient

@Deprecated
public KubernetesDiscoveryClient(KubernetesClient client,
                                             KubernetesConfiguration configuration,
                                             KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration,
                                             java.util.List<KubernetesServiceConfiguration> serviceConfigurations,
                                             KubernetesServiceInstanceList instanceList)

Deprecated. This constructor is no longer used as it doesn't support the discovery modes. Use KubernetesDiscoveryClient(KubernetesClient, KubernetesConfiguration, KubernetesConfiguration.KubernetesDiscoveryConfiguration, List, List, KubernetesServiceInstanceList) instead.

Creates discovery client that operates with endpoints only, so the discovery modes are not supported.

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

instanceList - The KubernetesServiceInstanceList

KubernetesDiscoveryClient

@Inject
public KubernetesDiscoveryClient(KubernetesClient 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

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