chore(cubestore): Introduc new metric - CACHESTORE_ROCKSDB_CF_DEFAULT_SIZE (#7063)

Author: ovr

rust/cubestore/Cargo.lock

@@ -53,8 +53,7 @@ tar = "0.4.38"
 
 [dev-dependencies]
 criterion = { version = "0.4.0", features = ["async_tokio", "html_reports"] }
-# Awaiting 0.20.2
-rocksdb = { git = "https://github.com/rust-rocksdb/rust-rocksdb", rev = "44dc84171adefbbe75a25b72c35f773a643655a0", default-features = false, features = ["bzip2", "snappy"] }
+rocksdb = { git = "https://github.com/cube-js/rust-rocksdb", branch = "cubestore", default-features = false, features = ["bzip2", "snappy"] }
 
 [[bench]]
 name = "in_process"

rust/cubestore/cubestore-sql-tests/Cargo.toml

@@ -42,8 +42,7 @@ simple_logger = "1.7.0"
 async-trait = "0.1.36"
 actix-rt = "2.7.0"
 regex = "1.3.9"
-# Awaiting 0.20.2
-rocksdb = { git = "https://github.com/rust-rocksdb/rust-rocksdb", rev = "44dc84171adefbbe75a25b72c35f773a643655a0", default-features = false, features = ["bzip2", "snappy"] }
+rocksdb = { git = "https://github.com/cube-js/rust-rocksdb", branch = "cubestore", default-features = false, features = ["bzip2", "snappy"] }
 uuid = { version = "0.8", features = ["serde", "v4"] }
 num = "0.3.0"
 enum_primitive = "0.1.1"

rust/cubestore/cubestore/Cargo.toml

@@ -58,6 +58,8 @@ pub static CACHESTORE_ROCKSDB_ESTIMATE_LIVE_DATA_SIZE: Gauge =
     metrics::gauge("cs.cachestore.rocksdb.estimate_live_data_size");
 pub static CACHESTORE_ROCKSDB_LIVE_SST_FILES_SIZE: Gauge =
     metrics::gauge("cs.cachestore.rocksdb.live_sst_files_size");
+pub static CACHESTORE_ROCKSDB_CF_DEFAULT_SIZE: Gauge =
+    metrics::gauge("cs.cachestore.rocksdb.cf.default.size");
 pub static CACHESTORE_SCHEDULER_GC_QUEUE: Gauge =
     metrics::gauge("cs.cachestore.scheduler.gc_queue");
 

rust/cubestore/cubestore/src/app_metrics.rs

@@ -260,6 +260,10 @@ impl RocksCacheStore {
                 .unwrap_or(0) as i64,
         );
 
+        let cf_metadata = self.store.db.get_column_family_metadata();
+
+        app_metrics::CACHESTORE_ROCKSDB_CF_DEFAULT_SIZE.report(cf_metadata.size as i64);
+
         Ok(())
     }