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
Modifier and TypeFieldDescriptionprotected static final org.slf4j.Logger
protected static final String
Fields inherited from class io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider
MODE
Fields inherited from class io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider
SECURE_LABEL
-
Constructor Summary
ConstructorDescriptionKubernetesServiceInstanceEndpointInformerProvider
(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration, InstanceProviderInformerNamespaceResolver informerNamespaceResolver, IndexerCompositeFactory indexerCompositeFactory) Creates kubernetes instance endpoint provider. -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Endpoints>
getEndpoints
(String name, String namespace) reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Endpoints>
listEndpoints
(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
-
Field Details
-
RESOURCE_PLURAL
- See Also:
-
LOG
protected static final org.slf4j.Logger LOG
-
-
Constructor Details
-
KubernetesServiceInstanceEndpointInformerProvider
public KubernetesServiceInstanceEndpointInformerProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration, InstanceProviderInformerNamespaceResolver informerNamespaceResolver, IndexerCompositeFactory indexerCompositeFactory) Creates kubernetes instance endpoint provider.- Parameters:
discoveryConfiguration
- discovery configurationindexerCompositeFactory
- service instance provider informer factoryinformerNamespaceResolver
- namespace resolver
-
-
Method Details
-
getEndpoints
public reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Endpoints> getEndpoints(String name, String namespace) - Specified by:
getEndpoints
in classAbstractV1EndpointsProvider
-
listEndpoints
public reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Endpoints> listEndpoints(String namespace) - Specified by:
listEndpoints
in classAbstractV1EndpointsProvider
-