io.micronaut.discovery.kubernetes

Class KubernetesDiscoveryClient

java.lang.Object

io.micronaut.discovery.kubernetes.KubernetesDiscoveryClient

All Implemented Interfaces:

Described, DiscoveryClient, Closeable, AutoCloseable

@Singleton
 @Requires(env="k8s")
public class KubernetesDiscoveryClient
extends Object
implements DiscoveryClient

A DiscoveryClient implementation for Kubernetes. Kubernetes uses environment variables so no API calls is required.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
KubernetesDiscoveryClient() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
String	getDescription() A description that describes this object.
io.reactivex.Flowable<List<ServiceInstance>>	getInstances(String serviceId) Obtain a list of ServiceInstance for the given service id.
io.reactivex.Flowable<List<String>>	getServiceIds()
protected Map<String,String>	resolveEnvironment() Resolves the environment variables.

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesDiscoveryClient

public KubernetesDiscoveryClient()

Default constructor.

Method Detail

getInstances

public io.reactivex.Flowable<List<ServiceInstance>> getInstances(String serviceId)

Description copied from interface: DiscoveryClient

Obtain a list of ServiceInstance for the given service id.

Specified by:

getInstances in interface DiscoveryClient

Parameters:

serviceId - The service id

Returns:

A Publisher that emits a list of ServiceInstance

getServiceIds

public io.reactivex.Flowable<List<String>> getServiceIds()

Specified by:

getServiceIds in interface DiscoveryClient

Returns:

The known service IDs

getDescription

public String getDescription()

Description copied from interface: Described

A description that describes this object.

Specified by:

getDescription in interface Described

Returns:

The description

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

resolveEnvironment

protected Map<String,String> resolveEnvironment()

Resolves the environment variables.

Returns:

The environment variables