io.micronaut.kubernetes.discovery

Class AbstractKubernetesServiceInstanceProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

Direct Known Subclasses:

KubernetesServiceInstanceEndpointProvider, KubernetesServiceInstanceServiceProvider

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
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.
java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	compositePredicate(java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>... predicates) Creates composite of predicates.
boolean	hasValidPortConfiguration(java.util.List<AbstractKubernetesServiceInstanceProvider.PortBinder> ports, KubernetesServiceConfiguration serviceConfiguration) Validates the necessity of having port configuration based on number of declared ports.
boolean	isMetadataSecure(io.kubernetes.client.openapi.models.V1ObjectMeta objectMeta)
boolean	isPortSecure(AbstractKubernetesServiceInstanceProvider.PortBinder servicePort) Attempts to guess whether this port should be connected to using SSL.

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

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

buildServiceInstance

public 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 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 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 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 final 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