(camel) 01/02: Kubernetes Secrets: Trigger context reloading on update - Add info for console with last update

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch CAMEL-21171
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 7e6bede96f49c08effccf9bfb121cd42656ee607
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Sep 4 15:23:39 2024 +0200

    Kubernetes Secrets: Trigger context reloading on update - Add info for 
console with last update
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../kubernetes/secrets/vault/SecretsReloadTriggerTask.java     | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/vault/SecretsReloadTriggerTask.java
 
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/vault/SecretsReloadTriggerTask.java
index 205b0bddc97..4ccf011f9db 100644
--- 
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/vault/SecretsReloadTriggerTask.java
+++ 
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/vault/SecretsReloadTriggerTask.java
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.component.kubernetes.secrets.vault;
 
+import java.time.Instant;
 import java.util.Collections;
 import java.util.HashSet;
 import java.util.Set;
@@ -46,6 +47,7 @@ public class SecretsReloadTriggerTask extends ServiceSupport 
implements CamelCon
     private String secrets;
     private KubernetesClient kubernetesClient;
     private SecretPropertiesFunction propertiesFunction;
+    private volatile Instant lastReloadTime;
 
     private static final Logger LOG = 
LoggerFactory.getLogger(SecretsReloadTriggerTask.class);
 
@@ -70,6 +72,13 @@ public class SecretsReloadTriggerTask extends ServiceSupport 
implements CamelCon
         this.reloadEnabled = reloadEnabled;
     }
 
+    /**
+     * Last time Kubernetes secrets update triggered reload.
+     */
+    public Instant getLastReloadTime() {
+        return lastReloadTime;
+    }
+
     @Override
     protected void doStart() throws Exception {
         super.doStart();
@@ -119,6 +128,7 @@ public class SecretsReloadTriggerTask extends 
ServiceSupport implements CamelCon
                                 ContextReloadStrategy reload = 
camelContext.hasService(ContextReloadStrategy.class);
                                 if (reload != null) {
                                     // trigger reload
+                                    lastReloadTime = Instant.now();
                                     reload.onReload(this);
                                 }
                             }