Package io.micronaut.kubernetes.discovery.provider

Class KubernetesServiceInstanceServiceProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

io.micronaut.kubernetes.discovery.provider.AbstractV1ServiceProvider

io.micronaut.kubernetes.discovery.provider.KubernetesServiceInstanceServiceProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

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

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

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

EXTERNAL_NAME, MODE

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

SECURE_LABEL

Constructor Summary

Constructors

Constructor	Description
KubernetesServiceInstanceServiceProvider(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)	Creates kubernetes instance service provider.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Service>	getService(String name, String namespace)
reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Service>	listServices(String namespace)

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

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 Details

LOG

protected static final org.slf4j.Logger LOG

Constructor Details

KubernetesServiceInstanceServiceProvider

public KubernetesServiceInstanceServiceProvider(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client,
 KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Creates kubernetes instance service provider.

Parameters:

client - client

discoveryConfiguration - discovery configuration

Method Details

getService

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

Specified by:

getService in class AbstractV1ServiceProvider

listServices

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

Specified by:

listServices in class AbstractV1ServiceProvider