Clickhouse backup on utils

Cargo.toml

@@ -10,6 +10,7 @@ exclude = [".github/"]
 [workspace]
 members = [
     "crates/rbuilder-primitives",
+    "crates/rbuilder-utils",
     "crates/rbuilder-config",
     "crates/rbuilder",
     "crates/rbuilder-operator",
@@ -28,6 +29,7 @@ default-members = [
     "crates/reth-rbuilder",
     "crates/rbuilder-rebalancer",
     "crates/rbuilder-primitives",
+    "crates/rbuilder-utils",
     "crates/test-relay",
     "crates/bid-scraper",
 ]
@@ -197,6 +199,7 @@ eth-sparse-mpt = { path = "crates/eth-sparse-mpt" }
 bid-scraper = { path = "crates/bid-scraper" }
 rbuilder = { path = "crates/rbuilder" }
 rbuilder-primitives = { path = "crates/rbuilder-primitives" }
+rbuilder-utils =  { path = "crates/rbuilder-utils" }
 rbuilder-config = { path = "crates/rbuilder-config" }
 sysperf = { path = "crates/sysperf" }
 metrics_macros = { path = "crates/rbuilder/src/telemetry/metrics_macros" }

crates/rbuilder-utils/Cargo.toml

@@ -0,0 +1,63 @@
+[package]
+name = "rbuilder-utils"
+version.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+license.workspace = true
+homepage.workspace = true
+repository.workspace = true
+exclude.workspace = true
+
+[dependencies]
+# misc
+derivative.workspace = true
+integer-encoding = "4.0.0"
+sha2 = { workspace = true, features = ["asm"] }
+uuid = { version = "1.6.1", features = ["serde", "v5", "v4"] }
+governor = "0.6.3"
+ahash.workspace = true
+reqwest = { workspace = true, features = ["blocking"] }
+serde_with = { workspace = true, features = ["time_0_3"] }
+toml.workspace = true
+tracing.workspace = true
+time.workspace = true
+thiserror.workspace = true
+eyre.workspace = true
+serde.workspace = true
+derive_more.workspace = true
+serde_json.workspace = true
+
+
+# alloy
+alloy-primitives.workspace = true
+
+strum = "0.27"
+strum_macros = "0.27"
+tokio = { version = "1.40.0", default-features = false, features = [
+  "sync",
+  "time",
+  "rt-multi-thread",
+  "macros",
+  "test-util"
+] }
+
+clickhouse = { git = "https://github.com/ClickHouse/clickhouse-rs", rev = "8cf3d2e138dd121367fa10e875d3f91374b075b2", features = [
+  "inserter",
+  "time",
+  "uuid",
+  "native-tls"
+] }
+clickhouse-derive = { version = "0.2.0" }
+redb = { version = "3.1.0" }
+tempfile = { version = "3.23.0" }
+rand = "0.9.2"
+futures = { version = "0.3" }
+futures-util = { version = "0.3.31" }
+
+# tracing
+tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
+tracing-futures = "0.2.5"
+
+# misc
+auto_impl = "1.3.0"
+dyn-clone = "1.0.20"

crates/rbuilder-utils/src/clickhouse/mod.rs

@@ -0,0 +1,38 @@
+use serde::{Deserialize, Serialize};
+
+/// Equilalent of `clickhouse::inserter::Quantities` with more traits derived.
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Default, Serialize, Deserialize)]
+pub struct Quantities {
+    pub bytes: u64,
+    pub rows: u64,
+    pub transactions: u64,
+}
+
+impl Quantities {
+    /// Just zero quantities, nothing special.
+    pub const ZERO: Quantities = Quantities {
+        bytes: 0,
+        rows: 0,
+        transactions: 0,
+    };
+}
+
+impl From<clickhouse::inserter::Quantities> for Quantities {
+    fn from(value: clickhouse::inserter::Quantities) -> Self {
+        Self {
+            bytes: value.bytes,
+            rows: value.rows,
+            transactions: value.transactions,
+        }
+    }
+}
+
+impl From<Quantities> for clickhouse::inserter::Quantities {
+    fn from(value: Quantities) -> Self {
+        Self {
+            bytes: value.bytes,
+            rows: value.rows,
+            transactions: value.transactions,
+        }
+    }
+}