chore: fmt

Author: ovr

rust/cubestore/cubestore/benches/cachestore_queue.rs

@@ -55,13 +55,29 @@ async fn do_insert(
     }
 }
 
-fn do_insert_bench(c: &mut Criterion, runtime: &Runtime, total: usize, size_kb: usize, do_duplicates: bool) {
+fn do_insert_bench(
+    c: &mut Criterion,
+    runtime: &Runtime,
+    total: usize,
+    size_kb: usize,
+    do_duplicates: bool,
+) {
     let cachestore = runtime.block_on(async {
-        prepare_cachestore(&format!("cachestore_queue_add_{}_{}", size_kb, do_duplicates)).unwrap()
+        prepare_cachestore(&format!(
+            "cachestore_queue_add_{}_{}",
+            size_kb, do_duplicates
+        ))
+        .unwrap()
     });
 
     c.bench_with_input(
-        BenchmarkId::new(format!("queue_add duplicates_check: {} queues:1, size:{} kb", do_duplicates, size_kb), total),
+        BenchmarkId::new(
+            format!(
+                "queue_add duplicates_check: {} queues:1, size:{} kb",
+                do_duplicates, size_kb
+            ),
+            total,
+        ),
         &(total, size_kb),
         |b, (total, size_kb)| {
             let mut insert_id_padding = 0;

rust/cubestore/cubestore/src/cachestore/cache_rocksstore.rs

@@ -1081,7 +1081,7 @@ impl CacheStore for RocksCacheStore {
                             payload.priority,
                             payload.orphaned.clone(),
                         ),
-                        batch_pipe
+                        batch_pipe,
                     )?;
 
                     if added {

rust/cubestore/cubestore/src/metastore/rocks_table.rs

@@ -577,7 +577,12 @@ pub trait RocksTable: BaseRocksTable + Debug + Send + Sync {
         if let Some(row) = id_row_opt {
             Ok((row, false))
         } else {
-            let row = self.do_insert(None, row, batch_pipe, Some(RocksSecondaryIndex::get_id(secondary_index)))?;
+            let row = self.do_insert(
+                None,
+                row,
+                batch_pipe,
+                Some(RocksSecondaryIndex::get_id(secondary_index)),
+            )?;
 
             Ok((row, true))
         }