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 io.reactivex.Flowable<java.lang.String>	computePodLabelSelector(KubernetesClient client, java.util.List<java.lang.String> podLabelKeys, java.lang.String namespace, java.util.Map<java.lang.String,java.lang.String> labels)
static io.micronaut.context.env.PropertySource	configMapAsPropertySource(ConfigMap configMap) Converts a ConfigMap into a PropertySource.
static io.reactivex.functions.Predicate<KubernetesObject>	getExcludesFilter(java.util.Collection<java.lang.String> excludes)
static io.reactivex.functions.Predicate<KubernetesObject>	getIncludesFilter(java.util.Collection<java.lang.String> includes)
static io.reactivex.functions.Predicate<KubernetesObject>	getLabelsFilter(java.util.Map<java.lang.String,java.lang.String> labels)
static io.micronaut.context.env.PropertySource	secretAsPropertySource(Secret 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(ConfigMap configMap)

Converts a ConfigMap into a PropertySource.

Parameters:

configMap - the ConfigMap

Returns:

A PropertySource

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(Secret secret)

Parameters:

secret - The Secret to transform

Returns:

The converted PropertySource.

getIncludesFilter

public static io.reactivex.functions.Predicate<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 io.reactivex.functions.Predicate<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 io.reactivex.functions.Predicate<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 io.reactivex.Flowable<java.lang.String> computePodLabelSelector(KubernetesClient client,
                                                                              java.util.List<java.lang.String> podLabelKeys,
                                                                              java.lang.String namespace,
                                                                              java.util.Map<java.lang.String,java.lang.String> labels)

Parameters:

client - the KubernetesClient

podLabelKeys - the list of labels inside a pod

namespace - in the configuration

labels - the labels

Returns:

the filtered labels of the current pod