io.micronaut.kubernetes.discovery.provider

Class AbstractV1EndpointsProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

Direct Known Subclasses:

KubernetesServiceInstanceEndpointInformerProvider, KubernetesServiceInstanceEndpointProvider

public abstract class AbstractV1EndpointsProvider
extends AbstractKubernetesServiceInstanceProvider

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

Since:

3.2

Author:

Pavol Gressa

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

AbstractKubernetesServiceInstanceProvider.PortBinder

Field Summary

Fields

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

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

SECURE_LABEL

Constructor Summary

Constructors

Constructor and Description
AbstractV1EndpointsProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Method Summary

Modifier and Type	Method and Description
abstract reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Endpoints>	getEndpoints(java.lang.String name, java.lang.String namespace)
org.reactivestreams.Publisher<java.util.List<io.micronaut.discovery.ServiceInstance>>	getInstances(KubernetesServiceConfiguration serviceConfiguration)
java.lang.String	getMode()
org.reactivestreams.Publisher<java.lang.String>	getServiceIds(java.lang.String namespace)
abstract reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Endpoints>	listEndpoints(java.lang.String namespace)

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

buildServiceInstance, compositePredicate, discoveryConfigurationFilter, hasValidPortConfiguration, isMetadataSecure, isPortSecure, serviceConfigurationDiscoveryFilter

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

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

AbstractV1EndpointsProvider

public AbstractV1EndpointsProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Method Detail

getMode

public java.lang.String getMode()

Returns:

the provider mode name.

getServiceIds

public org.reactivestreams.Publisher<java.lang.String> getServiceIds(java.lang.String namespace)

Parameters:

namespace - namespace

Returns:

provider service ids for given namespace

getInstances

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

Parameters:

serviceConfiguration - service discovery configuration

Returns:

discovered service instances

getEndpoints

public abstract reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Endpoints> getEndpoints(java.lang.String name,
                                                                                                          java.lang.String namespace)

listEndpoints

public abstract reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Endpoints> listEndpoints(java.lang.String namespace)