You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/09/04 13:42:23 UTC
(camel) 01/02: Kubernetes Secrets: Trigger context reloading on update - Add info for console with last update
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 <an...@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 <an...@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);
}
}