io.micronaut.kubernetes.util

Class KubernetesUtils

java.lang.Object

io.micronaut.kubernetes.util.KubernetesUtils

public class KubernetesUtils
extends java.lang.Object

Utility class with methods to help with ConfigMaps and Secrets.

Since:

1.0.0

Author:

Álvaro Sánchez-Mariscal

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ENV_KUBERNETES_SERVICE_HOST

Constructor Summary

Constructors

Constructor and Description
KubernetesUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	computeLabelSelector(java.util.Map<java.lang.String,java.lang.String> labels) Determines the value of a Kubernetes labelSelector filter based on the passed labels.
static reactor.core.publisher.Mono<java.lang.String>	computePodLabelSelector(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client, java.util.List<java.lang.String> podLabelKeys, java.lang.String namespace, java.util.Map<java.lang.String,java.lang.String> labels, boolean exceptionOnPodLabelsMissing)
static java.util.List<io.micronaut.context.env.PropertySource>	configMapAsPropertySource(java.lang.String mountPoint, java.util.Map<java.lang.String,java.lang.String> data) Converts config map mounted as volume into property sources.
static io.micronaut.context.env.PropertySource	configMapAsPropertySource(io.kubernetes.client.openapi.models.V1ConfigMap configMap) Converts a V1ConfigMap into a PropertySource.
static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	getExcludesFilter(java.util.Collection<java.lang.String> excludes)
static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	getIncludesFilter(java.util.Collection<java.lang.String> includes)
static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject>	getLabelsFilter(java.util.Map<java.lang.String,java.lang.String> labels)
static io.micronaut.context.env.PropertySource	secretAsPropertySource(io.kubernetes.client.openapi.models.V1Secret secret)

Methods inherited from class java.lang.Object

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

Field Detail

ENV_KUBERNETES_SERVICE_HOST

public static final java.lang.String ENV_KUBERNETES_SERVICE_HOST

See Also:

Constant Field Values

Constructor Detail

KubernetesUtils

public KubernetesUtils()

Method Detail

configMapAsPropertySource

public static io.micronaut.context.env.PropertySource configMapAsPropertySource(io.kubernetes.client.openapi.models.V1ConfigMap configMap)

Converts a V1ConfigMap into a PropertySource.

Parameters:

configMap - the ConfigMap

Returns:

A PropertySource

configMapAsPropertySource

public static java.util.List<io.micronaut.context.env.PropertySource> configMapAsPropertySource(java.lang.String mountPoint,
                                                                                                java.util.Map<java.lang.String,java.lang.String> data)

Converts config map mounted as volume into property sources.

Parameters:

mountPoint - the mount point

data - the configmaps data in the mounted volume where keys are file names and values is the file content

Returns:

list of property sources

computeLabelSelector

public static java.lang.String computeLabelSelector(java.util.Map<java.lang.String,java.lang.String> labels)

Determines the value of a Kubernetes labelSelector filter based on the passed labels.

Parameters:

labels - the labels

Returns:

the value of the labelSelector filter

secretAsPropertySource

public static io.micronaut.context.env.PropertySource secretAsPropertySource(io.kubernetes.client.openapi.models.V1Secret secret)

Parameters:

secret - The V1Secret to transform

Returns:

The converted PropertySource.

getIncludesFilter

public static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject> getIncludesFilter(java.util.Collection<java.lang.String> includes)

Parameters:

includes - the objects to include

Returns:

a Predicate based on a collection of object names to include

getExcludesFilter

public static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject> getExcludesFilter(java.util.Collection<java.lang.String> excludes)

Parameters:

excludes - the objects to excludes

Returns:

a Predicate based on a collection of object names to excludes

getLabelsFilter

public static java.util.function.Predicate<io.kubernetes.client.common.KubernetesObject> getLabelsFilter(java.util.Map<java.lang.String,java.lang.String> labels)

Parameters:

labels - the labels to include

Returns:

a Predicate based on labels the kubernetes objects has to match to return true

computePodLabelSelector

public static reactor.core.publisher.Mono<java.lang.String> computePodLabelSelector(io.micronaut.kubernetes.client.reactor.CoreV1ApiReactorClient client,
                                                                                    java.util.List<java.lang.String> podLabelKeys,
                                                                                    java.lang.String namespace,
                                                                                    java.util.Map<java.lang.String,java.lang.String> labels,
                                                                                    boolean exceptionOnPodLabelsMissing)

Parameters:

client - the CoreV1ApiReactorClient

podLabelKeys - the list of labels inside a pod

namespace - in the configuration

labels - the labels

exceptionOnPodLabelsMissing - should and exception be thrown if configured pod label is not found

Returns:

the filtered labels of the current pod