[camel-karavan] 02/02: Clear statuses on startup

[marat]

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

marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git

commit 6bf976ab3a6032846e8736da7acdd3c15c673789
Author: Marat Gubaidullin <marat.gubaidul...@gmail.com>
AuthorDate: Fri Dec 16 18:31:47 2022 -0500

    Clear statuses on startup
---
 .../java/org/apache/camel/karavan/service/InfinispanService.java | 9 +++++++++
 .../java/org/apache/camel/karavan/service/KaravanService.java    | 1 +
 .../java/org/apache/camel/karavan/service/KubernetesService.java | 1 +
 3 files changed, 11 insertions(+)

diff --git 
a/karavan-app/src/main/java/org/apache/camel/karavan/service/InfinispanService.java
 
b/karavan-app/src/main/java/org/apache/camel/karavan/service/InfinispanService.java
index adc641e..d86a37e 100644
--- 
a/karavan-app/src/main/java/org/apache/camel/karavan/service/InfinispanService.java
+++ 
b/karavan-app/src/main/java/org/apache/camel/karavan/service/InfinispanService.java
@@ -45,6 +45,7 @@ import java.time.Instant;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 
 @ApplicationScoped
@@ -292,4 +293,12 @@ public class InfinispanService {
     }
 
 
+    protected void clearAllStatuses() {
+        CompletableFuture.allOf(
+            deploymentStatuses.clearAsync(),
+            podStatuses.clearAsync(),
+            pipelineStatuses.clearAsync(),
+            camelStatuses.clearAsync()
+        ).join();
+    }
 }
diff --git 
a/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
 
b/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
index cd3f5bf..d235d17 100644
--- 
a/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
+++ 
b/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
@@ -47,6 +47,7 @@ public class KaravanService {
     void onStart(@Observes StartupEvent ev) {
         LOGGER.info("Start Karavan");
         infinispanService.start();
+        infinispanService.clearAllStatuses();
         setEnvironment();
         initialImport();
         startInformers();
diff --git 
a/karavan-app/src/main/java/org/apache/camel/karavan/service/KubernetesService.java
 
b/karavan-app/src/main/java/org/apache/camel/karavan/service/KubernetesService.java
index b349e15..62175b2 100644
--- 
a/karavan-app/src/main/java/org/apache/camel/karavan/service/KubernetesService.java
+++ 
b/karavan-app/src/main/java/org/apache/camel/karavan/service/KubernetesService.java
@@ -130,6 +130,7 @@ public class KubernetesService {
     void stopInformers(String data) {
         LOGGER.info("Stop Kubernetes Informers");
         informers.forEach(informer -> informer.close());
+        informers.clear();
     }
 
     private String getPipelineName(Project project) {