io.micronaut.kubernetes.discovery

Class AbstractKubernetesServiceInstanceProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

Direct Known Subclasses:

AbstractV1EndpointsProvider, AbstractV1ServiceProvider

public abstract class AbstractKubernetesServiceInstanceProvider
extends java.lang.Object
implements KubernetesServiceInstanceProvider

Abstract implementation of kubernetes service instance provider.

Since:

2.3

Author:

Pavol Gressa

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractKubernetesServiceInstanceProvider.PortBinder Utility class for transparent access to V1EndpointPort and V1ServicePort.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG
static java.lang.String	SECURE_LABEL

Constructor Summary

Constructors

Constructor and Description
AbstractKubernetesServiceInstanceProvider()

Method Summary

Modifier and Type	Method and Description
static io.micronaut.discovery.ServiceInstance	buildServiceInstance(java.lang.String serviceId, AbstractKubernetesServiceInstanceProvider.PortBinder servicePort, java.lang.String address, io.kubernetes.client.openapi.models.V1ObjectMeta metadata) Builds service instance.
static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	compositePredicate(java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>... predicates) Creates composite of predicates.
protected static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	discoveryConfigurationFilter(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration) Creates filter predicate for Kubernetes objects based on provided KubernetesConfiguration.KubernetesDiscoveryConfiguration.
static boolean	hasValidPortConfiguration(java.util.List<AbstractKubernetesServiceInstanceProvider.PortBinder> ports, KubernetesServiceConfiguration serviceConfiguration) Validates the necessity of having port configuration based on number of declared ports.
static boolean	isMetadataSecure(io.kubernetes.client.openapi.models.V1ObjectMeta objectMeta)
static boolean	isPortSecure(AbstractKubernetesServiceInstanceProvider.PortBinder servicePort) Attempts to guess whether this port should be connected to using SSL.
protected static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	serviceConfigurationDiscoveryFilter(KubernetesServiceConfiguration serviceConfiguration, KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration) Creates service specific filter based on KubernetesServiceConfiguration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.kubernetes.discovery.KubernetesServiceInstanceProvider

getInstances, getMode, getServiceIds

Field Detail

SECURE_LABEL

public static final java.lang.String SECURE_LABEL

See Also:

Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

AbstractKubernetesServiceInstanceProvider

public AbstractKubernetesServiceInstanceProvider()

Method Detail

discoveryConfigurationFilter

protected static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject> discoveryConfigurationFilter(KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Creates filter predicate for Kubernetes objects based on provided KubernetesConfiguration.KubernetesDiscoveryConfiguration.

Parameters:

discoveryConfiguration - configuration

Returns:

predicate

serviceConfigurationDiscoveryFilter

protected static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject> serviceConfigurationDiscoveryFilter(KubernetesServiceConfiguration serviceConfiguration,
                                                                                                                                KubernetesConfiguration.KubernetesDiscoveryConfiguration discoveryConfiguration)

Creates service specific filter based on KubernetesServiceConfiguration.

Parameters:

serviceConfiguration - service configuration

discoveryConfiguration - discovery configuration

Returns:

filter predicate

buildServiceInstance

public static io.micronaut.discovery.ServiceInstance buildServiceInstance(java.lang.String serviceId,
                                                                          @Nullable
                                                                          AbstractKubernetesServiceInstanceProvider.PortBinder servicePort,
                                                                          java.lang.String address,
                                                                          io.kubernetes.client.openapi.models.V1ObjectMeta metadata)

Builds service instance.

Parameters:

serviceId - service id

servicePort - servicePort

address - address

metadata - metadata

Returns:

service instance

isPortSecure

public static boolean isPortSecure(AbstractKubernetesServiceInstanceProvider.PortBinder servicePort)

Attempts to guess whether this port should be connected to using SSL. By default, port numbers ending in 443 or port named "https" are considered secure

Parameters:

servicePort - the AbstractKubernetesServiceInstanceProvider.PortBinder

Returns:

Whether the port is considered secure

isMetadataSecure

public static boolean isMetadataSecure(io.kubernetes.client.openapi.models.V1ObjectMeta objectMeta)

Parameters:

objectMeta - the V1ObjectMeta

Returns:

true if there is a label within V1ObjectMeta.getLabels() named SECURE_LABEL and with value "true"; false otherwise

hasValidPortConfiguration

public static boolean hasValidPortConfiguration(@Nullable
                                                java.util.List<AbstractKubernetesServiceInstanceProvider.PortBinder> ports,
                                                KubernetesServiceConfiguration serviceConfiguration)

Validates the necessity of having port configuration based on number of declared ports.

Parameters:

ports - list of ports

serviceConfiguration - service configuration

Returns:

true if the port configuration is valid otherwise false

compositePredicate

@SafeVarargs
public static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject> compositePredicate(java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>... predicates)

Creates composite of predicates.

Parameters:

predicates - predicates

Returns:

predicate