You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ma...@apache.org on 2022/10/28 23:57:35 UTC
[camel-karavan] 02/03: Pod status test demo
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 f69721ffea962c314684df1be2e4e8b6604e5874
Author: Marat Gubaidullin <ma...@gmail.com>
AuthorDate: Fri Oct 28 19:54:12 2022 -0400
Pod status test demo
---
.../org/apache/camel/karavan/informer/PodEventHandler.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/karavan-app/src/main/java/org/apache/camel/karavan/informer/PodEventHandler.java b/karavan-app/src/main/java/org/apache/camel/karavan/informer/PodEventHandler.java
index 4e68379..440d154 100644
--- a/karavan-app/src/main/java/org/apache/camel/karavan/informer/PodEventHandler.java
+++ b/karavan-app/src/main/java/org/apache/camel/karavan/informer/PodEventHandler.java
@@ -4,6 +4,7 @@ import io.fabric8.kubernetes.api.model.Pod;
import io.fabric8.kubernetes.api.model.PodCondition;
import io.fabric8.kubernetes.client.informers.ResourceEventHandler;
import org.apache.camel.karavan.model.PodStatus;
+import org.apache.camel.karavan.model.ServiceStatus;
import org.apache.camel.karavan.service.InfinispanService;
import org.apache.camel.karavan.service.KubernetesService;
import org.jboss.logging.Logger;
@@ -28,8 +29,9 @@ public class PodEventHandler implements ResourceEventHandler<Pod> {
PodStatus ps = getPodStatus(pod);
infinispanService.savePodStatus(ps);
// TODO: Delete after UI design
- ps.setEnv("test");
- infinispanService.savePodStatus(ps);
+ PodStatus ds1 = getPodStatus(pod);
+ ds1.setEnv("test");
+ infinispanService.savePodStatus(ds1);
} catch (Exception e){
LOGGER.error(e.getMessage());
}
@@ -42,8 +44,9 @@ public class PodEventHandler implements ResourceEventHandler<Pod> {
PodStatus ps = getPodStatus(newPod);
infinispanService.savePodStatus(ps);
// TODO: Delete after UI design
- ps.setEnv("test");
- infinispanService.savePodStatus(ps);
+ PodStatus ds1 = getPodStatus(newPod);
+ ds1.setEnv("test");
+ infinispanService.savePodStatus(ds1);
} catch (Exception e){
LOGGER.error(e.getMessage());
}