Skip to content

Commit 8739874

Browse files
committed
fixup topic naming
1 parent 8df4aac commit 8739874

2 files changed

Lines changed: 5 additions & 5 deletions

File tree

src/gps.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,7 @@ fn parse_tpv(tpv: Tpv, time: u64) -> Vec<PublishableMessage> {
191191
ret
192192
}
193193

194-
const PPS: &str = "TPU/GPS2/PPS";
194+
const PPS: &str = "TPU/GPS/PPS";
195195
fn parse_pps(pps: Pps, time: u64) -> Vec<PublishableMessage> {
196196
if let Some(pps_precision) = pps.precision {
197197
vec![PublishableMessage {

src/numerical.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ pub async fn collect_data(
5656
},
5757
// STEP 2: add a block to gather the data and send the message, include topic and unit blocks
5858
_ = cpu_temp_int.tick() => {
59-
const TOPIC: &str = "TPU/OnBoard2/CpuTemp";
59+
const TOPIC: &str = "TPU/OnBoard/CpuTemp";
6060
const UNIT: &str = "celsius";
6161

6262
let value = match temperature_component {
@@ -74,10 +74,10 @@ pub async fn collect_data(
7474

7575
}
7676
_ = cpu_usage_int.tick() => {
77-
const TOPIC_C: &str = "TPU/OnBoard2/CpuUsage";
77+
const TOPIC_C: &str = "TPU/OnBoard/CpuUsage";
7878
const UNIT_C: &str = "%";
7979

80-
const TOPIC_B: &str = "TPU/OnBoard2/BrokerCpuUsage";
80+
const TOPIC_B: &str = "TPU/OnBoard/BrokerCpuUsage";
8181
const UNIT_B: &str = "%";
8282

8383

@@ -96,7 +96,7 @@ pub async fn collect_data(
9696
PublishableMessage{ topic: TOPIC_B.to_string(), data: vec![process.cpu_usage()], unit: UNIT_B, time: UNIX_EPOCH.elapsed().unwrap().as_micros() as u64 }]
9797
},
9898
_ = mem_avail_int.tick() => {
99-
const TOPIC: &str = "TPU/OnBoard2/MemAvailable";
99+
const TOPIC: &str = "TPU/OnBoard/MemAvailable";
100100
const UNIT: &str = "MB";
101101

102102
sys.refresh_memory_specifics(MemoryRefreshKind::nothing().with_ram());

0 commit comments

Comments
 (0)