io.micronaut.kubernetes.discovery.provider

Class KubernetesServiceInstanceEndpointInformerProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider

io.micronaut.kubernetes.discovery.provider.KubernetesServiceInstanceEndpointInformerProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

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

Service instance provider uses Kubernetes Endpoints Informer 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
protected static java.lang.String	RESOURCE_PLURAL

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
KubernetesServiceInstanceEndpointInformerProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration, InstanceProviderInformerNamespaceResolver informerNamespaceResolver, IndexerCompositeFactory indexerCompositeFactory) 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

RESOURCE_PLURAL

protected static final java.lang.String RESOURCE_PLURAL

See Also:

Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KubernetesServiceInstanceEndpointInformerProvider

public KubernetesServiceInstanceEndpointInformerProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration,
                                                         InstanceProviderInformerNamespaceResolver informerNamespaceResolver,
                                                         IndexerCompositeFactory indexerCompositeFactory)

Creates kubernetes instance endpoint provider.

Parameters:

discoveryConfiguration - discovery configuration

indexerCompositeFactory - service instance provider informer factory

informerNamespaceResolver - namespace resolver

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