summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/collectd/monitor.rs
diff options
context:
space:
mode:
Diffstat (limited to 'crates/core/tedge_mapper/src/collectd/monitor.rs')
-rw-r--r--crates/core/tedge_mapper/src/collectd/monitor.rs4
1 files changed, 3 insertions, 1 deletions
diff --git a/crates/core/tedge_mapper/src/collectd/monitor.rs b/crates/core/tedge_mapper/src/collectd/monitor.rs
index f927f887..61de30a5 100644
--- a/crates/core/tedge_mapper/src/collectd/monitor.rs
+++ b/crates/core/tedge_mapper/src/collectd/monitor.rs
@@ -3,6 +3,7 @@ use std::process;
use batcher::{BatchConfigBuilder, BatchDriver, BatchDriverInput, BatchDriverOutput, Batcher};
use mqtt_channel::{Connection, Message, QoS, SinkExt, StreamExt, Topic, TopicFilter};
use serde_json::json;
+use time::OffsetDateTime;
use tracing::{error, info, instrument};
use super::{batcher::MessageBatch, collectd::CollectdMessage, error::DeviceMonitorError};
@@ -109,7 +110,8 @@ impl DeviceMonitor {
if health_check_topics.accept(&message) {
let health_status = json!({
"status": "up",
- "pid": process::id()
+ "pid": process::id(),
+ "time": OffsetDateTime::now_utc().unix_timestamp()
})
.to_string();
let health_message = Message::new(&health_status_topic, health_status);