io.micronaut.kubernetes.configuration

Class KubernetesConfigMapWatcher

java.lang.Object

io.micronaut.kubernetes.configuration.KubernetesConfigMapWatcher

All Implemented Interfaces:

io.micronaut.context.event.ApplicationEventListener<io.micronaut.discovery.event.ServiceStartedEvent>, java.util.EventListener

@Singleton
 @Requires(env="k8s") @Requires(beans=KubernetesClient.class) @Requires(property="micronaut.config-client.enabled",value="true",defaultValue="false")
public class KubernetesConfigMapWatcher
extends java.lang.Object
implements io.micronaut.context.event.ApplicationEventListener<io.micronaut.discovery.event.ServiceStartedEvent>

Watches for ConfigMap changes and makes the appropriate changes to the Environment by adding or removing PropertySources.

Since:

1.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor and Description
KubernetesConfigMapWatcher(io.micronaut.context.env.Environment environment, KubernetesClient client, KubernetesConfiguration configuration, java.util.concurrent.ExecutorService executorService)

Method Summary

Modifier and Type	Method and Description
void	onApplicationEvent(io.micronaut.discovery.event.ServiceStartedEvent event)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.context.event.ApplicationEventListener

supports

Constructor Detail

KubernetesConfigMapWatcher

public KubernetesConfigMapWatcher(io.micronaut.context.env.Environment environment,
                                  KubernetesClient client,
                                  KubernetesConfiguration configuration,
                                  @Named(value="io")
                                  java.util.concurrent.ExecutorService executorService)

Parameters:

environment - the Environment

client - the {KubernetesClient}

configuration - the KubernetesConfiguration

executorService - the IO ExecutorService where the watch publisher will be scheduled on

Method Detail

onApplicationEvent

public void onApplicationEvent(io.micronaut.discovery.event.ServiceStartedEvent event)

Specified by:

onApplicationEvent in interface io.micronaut.context.event.ApplicationEventListener<io.micronaut.discovery.event.ServiceStartedEvent>