From a82921193c1e383ce048cf7a5883942dfd184a56 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 3 Mar 2026 16:44:53 +0800 Subject: [PATCH] PointNewValue --- src/connection.rs | 6 +++--- src/event.rs | 2 +- src/telemetry.rs | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/connection.rs b/src/connection.rs index 2e104cf..e01e7e2 100644 --- a/src/connection.rs +++ b/src/connection.rs @@ -262,7 +262,7 @@ impl ConnectionManager { .unwrap_or(crate::telemetry::PointQuality::Unknown); let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange( - crate::telemetry::PointValueChangeEvent { + crate::telemetry::PointNewValue { source_id, point_id: Some(point_id), client_handle: 0, @@ -759,7 +759,7 @@ impl ConnectionManager { if let Some(event_manager) = &self.event_manager { for (source_id, point_id, variant) in success_events { if let Err(e) = event_manager.send(crate::event::ReloadEvent::PointValueChange( - crate::telemetry::PointValueChangeEvent { + crate::telemetry::PointNewValue { source_id, point_id: Some(point_id), client_handle: 0, @@ -884,7 +884,7 @@ impl ConnectionManager { if let Some(event_manager) = &manager.event_manager { let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange( - crate::telemetry::PointValueChangeEvent { + crate::telemetry::PointNewValue { source_id: current_source_id, point_id: None, client_handle, diff --git a/src/event.rs b/src/event.rs index 88cc159..5f10b12 100644 --- a/src/event.rs +++ b/src/event.rs @@ -24,7 +24,7 @@ pub enum ReloadEvent { source_id: Uuid, point_ids: Vec, }, - PointValueChange(crate::telemetry::PointValueChangeEvent), + PointValueChange(crate::telemetry::PointNewValue), } pub struct EventManager { diff --git a/src/telemetry.rs b/src/telemetry.rs index 3cba9ed..6de3132 100644 --- a/src/telemetry.rs +++ b/src/telemetry.rs @@ -94,7 +94,7 @@ impl PointMonitorInfo { } #[derive(Debug, Clone)] -pub struct PointValueChangeEvent { +pub struct PointNewValue { pub source_id: Uuid, pub point_id: Option, pub client_handle: u32,