Merge pull request #1622 from jiacai2050/impl-metric

Author: zealchen

Cargo.lock

@@ -37,6 +37,7 @@ members = [
 
 [workspace.dependencies]
 anyhow = { version = "1.0" }
+seahash = { version = "4" }
 metric_engine = { path = "src/metric_engine" }
 horaedb_storage = { package = "storage", path = "src/storage" }
 common = { path = "src/common" }

Cargo.toml

@@ -29,6 +29,7 @@ description.workspace = true
 anyhow = { workspace = true }
 common = { workspace = true }
 horaedb_storage = { workspace = true }
+seahash = { workspace = true }
 thiserror = { workspace = true }
 tokio = { workspace = true }
 tracing = { workspace = true }

src/metric_engine/Cargo.toml

@@ -42,3 +42,9 @@ impl MetricManager {
 struct Inner {
     storage: TimeMergeStorageRef,
 }
+
+impl Inner {
+    async fn populate_metric_ids(&self, _samples: &mut [Sample]) -> Result<()> {
+        todo!()
+    }
+}

src/metric_engine/src/metric/mod.rs

@@ -35,3 +35,7 @@ pub struct Sample {
     /// hash of labels(sorted)
     pub series_id: Option<SeriesId>,
 }
+
+pub fn hash(buf: &[u8]) -> u64 {
+    seahash::hash(buf)
+}