io.micronaut.kubernetes.discovery.provider

Class KubernetesServiceInstanceEndpointProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider

io.micronaut.kubernetes.discovery.provider.KubernetesServiceInstanceEndpointProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

@Requires(property="kubernetes.client.discovery.mode-configuration.endpoint.watch.enabled",
          notEquals="true",
          defaultValue="false")
 @Singleton
public class KubernetesServiceInstanceEndpointProvider
extends AbstractV1EndpointsProvider

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

Since:

2.3

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

Fields inherited from class io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider

MODE

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

SECURE_LABEL

Constructor Summary

Constructors

Constructor and Description
KubernetesServiceInstanceEndpointProvider(CoreV1ApiReactorClient client, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration) Creates kubernetes instance endpoint provider.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Endpoints>	getEndpoints(java.lang.String name, java.lang.String namespace)
reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Endpoints>	listEndpoints(java.lang.String namespace)

Methods inherited from class io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider

getInstances, getMode, getServiceIds

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

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KubernetesServiceInstanceEndpointProvider

public KubernetesServiceInstanceEndpointProvider(CoreV1ApiReactorClient client,
                                                 KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Creates kubernetes instance endpoint provider.

Parameters:

client - client

discoveryConfiguration - discovery configuration

Method Detail

getEndpoints

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

Specified by:

getEndpoints in class AbstractV1EndpointsProvider

listEndpoints

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

Specified by:

listEndpoints in class AbstractV1EndpointsProvider