io.micronaut.kubernetes.discovery.provider

Class KubernetesServiceInstanceServiceProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

io.micronaut.kubernetes.discovery.provider.KubernetesServiceInstanceServiceProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

@Singleton
public class KubernetesServiceInstanceServiceProvider
extends AbstractKubernetesServiceInstanceProvider

Service instance provider uses Kubernetes Service as source of service discovery.

Since:

2.3

Author:

Pavol Gressa

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	EXTERNAL_NAME
protected static org.slf4j.Logger	LOG
static java.lang.String	MODE

Constructor Summary

Constructors

Constructor and Description
KubernetesServiceInstanceServiceProvider(KubernetesClient client, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<java.util.List<io.micronaut.discovery.ServiceInstance>>	getInstances(KubernetesServiceConfiguration serviceConfiguration)
java.lang.String	getMode()

Methods inherited from class io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

buildServiceInstance, compositePredicate, hasValidPortConfiguration

Methods inherited from class java.lang.Object

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

Field Detail

MODE

public static final java.lang.String MODE

See Also:

Constant Field Values

EXTERNAL_NAME

protected static final java.lang.String EXTERNAL_NAME

See Also:

Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KubernetesServiceInstanceServiceProvider

public KubernetesServiceInstanceServiceProvider(KubernetesClient client,
                                                KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Method Detail

getMode

public java.lang.String getMode()

Returns:

the provider mode name.

getInstances

public org.reactivestreams.Publisher<java.util.List<io.micronaut.discovery.ServiceInstance>> getInstances(KubernetesServiceConfiguration serviceConfiguration)

Parameters:

serviceConfiguration - service discovery configuration

Returns:

discovered service instances