Package io.micronaut.kubernetes.discovery.provider

Class AbstractV1ServiceProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

io.micronaut.kubernetes.discovery.provider.AbstractV1ServiceProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

Direct Known Subclasses:

KubernetesServiceInstanceServiceInformerProvider, KubernetesServiceInstanceServiceProvider

public abstract class AbstractV1ServiceProvider
extends AbstractKubernetesServiceInstanceProvider

Service instance provider uses Kubernetes Service 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	Description
protected static final String	EXTERNAL_NAME
protected static final org.slf4j.Logger	LOG
static final String	MODE

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

SECURE_LABEL

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractV1ServiceProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<List<io.micronaut.discovery.ServiceInstance>>	getInstances(KubernetesServiceConfiguration serviceConfiguration)
String	getMode()
abstract reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Service>	getService(String name, String namespace)
org.reactivestreams.Publisher<String>	getServiceIds(String namespace)
abstract reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Service>	listServices(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 Details

MODE

public static final String MODE

See Also:

• Constant Field Values

EXTERNAL_NAME

protected static final String EXTERNAL_NAME

See Also:

• Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

Constructor Details

AbstractV1ServiceProvider

protected AbstractV1ServiceProvider(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Method Details

getMode

public String getMode()

Returns:

the provider mode name.

getInstances

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

Parameters:

serviceConfiguration - service discovery configuration

Returns:

discovered service instances

getServiceIds

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

Parameters:

namespace - namespace

Returns:

provider service ids for given namespace

getService

public abstract reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Service> getService(String name,
 String namespace)

listServices

public abstract reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Service> listServices(String namespace)