From 89c51d9b8702c3c6ce94f4aae2858ee6337d74bb Mon Sep 17 00:00:00 2001 From: Ruihang Xia Date: Wed, 13 Mar 2024 23:32:22 +0800 Subject: [PATCH] reset Sample Signed-off-by: Ruihang Xia --- src/servers/src/prom_row_builder.rs | 3 ++- src/servers/src/proto.rs | 11 +++++++---- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/src/servers/src/prom_row_builder.rs b/src/servers/src/prom_row_builder.rs index 20a049f472..9bfdd02182 100644 --- a/src/servers/src/prom_row_builder.rs +++ b/src/servers/src/prom_row_builder.rs @@ -28,7 +28,7 @@ use crate::proto::PromLabel; use crate::repeated_field::Clear; /// [TablesBuilder] serves as an intermediate container to build [RowInsertRequests]. -#[derive(Default)] +#[derive(Default, Debug)] pub(crate) struct TablesBuilder { tables: HashMap, } @@ -68,6 +68,7 @@ impl TablesBuilder { } /// Builder for one table. +#[derive(Debug)] pub(crate) struct TableBuilder { /// Column schemas. schema: Vec, diff --git a/src/servers/src/proto.rs b/src/servers/src/proto.rs index 1a96cd9ed8..906a7ff52a 100644 --- a/src/servers/src/proto.rs +++ b/src/servers/src/proto.rs @@ -26,10 +26,13 @@ use crate::prom_store::METRIC_NAME_LABEL_BYTES; use crate::repeated_field::{Clear, RepeatedField}; impl Clear for Sample { - fn clear(&mut self) {} + fn clear(&mut self) { + self.timestamp = 0; + self.value = 0.0; + } } -#[derive(Default, Clone)] +#[derive(Default, Clone, Debug)] pub struct PromLabel { pub name: Bytes, pub value: Bytes, @@ -76,7 +79,7 @@ impl PromLabel { } } -#[derive(Default)] +#[derive(Default, Debug)] pub struct PromTimeSeries { pub table_name: String, pub labels: RepeatedField, @@ -161,7 +164,7 @@ impl PromTimeSeries { } } -#[derive(Default)] +#[derive(Default, Debug)] pub struct PromWriteRequest { table_data: TablesBuilder, series: PromTimeSeries,