Sync/0.9

Cargo.toml

@@ -14,8 +14,8 @@ tokio = { version = "1.29.1", features = ["full", "tracing"] }
 byteorder = "1.4.3"
 rand = "0.8.5"
 maligned = "0.2.1"
-atomic = "0.5.3"
-tabled = { version = "0.12.2", features = ["ansi-str", "color"] }
+atomic = "0.6.0"
+tabled = { version = "0.14.0", features = ["ansi-str", "color"] }
 memmap = "0.7.0"
 bytes = "1.4.0"
 bloom = "0.3.2"
@@ -30,7 +30,7 @@ parking_lot = "0.12.1"
 bitflags = "2.3.3"
 libc = "0.2.147"
 log = { version = "0.4.19", features = ["kv_unstable", "kv_unstable_serde", "kv_unstable_sval"] }
-async-channel = "1.9.0"
+async-channel = "2.0.0"
 file-guard = "0.1.0"
 fs2 = "0.4.3"
 awaitgroup = "0.7.0"
@@ -45,13 +45,13 @@ eieio = "1.0.0"
 either = "1.8.1"
 enum-unitary = "0.5.0"
 atom_box = "0.1.2"
-console-subscriber = "0.1.10"
+console-subscriber = "0.2.0"
 uuid = { version = "1.4.1", features = ["v5", "v4"] }
 winapi = "0.3.9"
 itertools = "0.11.0"
-tokio-metrics = "0.2.2"
+tokio-metrics = "0.3.1"
 metrics = "0.21.1"
-metrics-prometheus = "0.4.1"
+metrics-prometheus = "0.5.0"
 prometheus = "0.13.3"
 lazy_static = "1.4.0"
 getset = "0.1.2"
@@ -60,14 +60,18 @@ async-stream = "0.3.5"
 futures-core = "0.3.28"
 backtrace-on-stack-overflow = "0.3.0"
 protobuf = { version = "3.0.0-alpha.2", features = ["with-bytes"] }
+clap = { version = "4.4.6", features = ["derive"] }
+structopt = "0.3.26"
+farmhash = "1.1.5"
+arc-cell = "0.3.3"
 [dev-dependencies]
 tracing-subscriber = "0.3.17"
-tracing-log = "0.1.3"
+tracing-log = "0.2.0"
 chrono = "0.4.26"
 env_logger = "0.10.0"
 console_log = { version = "1.0.0", features = ["color"] }
 itertools = "0.11.0"
-tokio-metrics = { version = "0.2.2", default-features = false }
+tokio-metrics = { version = "0.3.1", default-features = false }
 tokio = { version = "1.29.1", features = ["full", "rt", "time", "macros", "test-util"] }
 criterion = { version = "0.5.1", features = ["tokio"] }
 

examples/badger.rs

@@ -1,20 +1,39 @@
+use std::path::PathBuf;
+use structopt::StructOpt;
+
+
+#[derive(StructOpt)]
+#[structopt(about = "BadgerDB demo")]
+enum Opt {
+    BackUp,
+}
+
+
 #[tokio::main]
 async fn main() {
+
     let env = tracing_subscriber::EnvFilter::from_default_env();
     tracing_subscriber::FmtSubscriber::builder()
         .with_env_filter(env)
         .try_init()
         .unwrap();
-    let opt = badger_rs::Options::default();
-    let kv = badger_rs::KV::open(opt).await.unwrap();
-    kv.set(
-        b"hello word".to_vec(),
-        b">>>>>I LOVE YOU!<<<<<".to_vec(),
-        0x0,
-    )
-    .await
-    .unwrap();
-
-    let got = kv.get(b"hello word").await.unwrap();
-    println!("{}", String::from_utf8_lossy(&got));
-}
+
+
+    let opt = Opt::from_args();
+    match opt {
+        Opt::BackUp => {
+            let opt = badger_rs::Options::default();
+            let kv = badger_rs::DB::open(opt).await.unwrap();
+            kv.set(
+                b"hello word".to_vec(),
+                b">>>>>I LOVE YOU!<<<<<".to_vec(),
+                0x0,
+            )
+                .await
+                .unwrap();
+
+            let got = kv.get(b"hello word").await.unwrap();
+            println!("{}", String::from_utf8_lossy(&got));
+        }
+    }
+}

src/backup.rs

@@ -1,9 +1,12 @@
-use std::io::Write;
+use crate::pb::backup::KVPair;
 use byteorder::{LittleEndian, WriteBytesExt};
 use protobuf::Message;
-use crate::pb::backup::KVPair;
+use std::io::Write;
 
-pub fn write_to<W>(entry: &KVPair, wt: &mut W) -> crate::Result<()> where W: Write {
+pub fn write_to<W>(entry: &KVPair, wt: &mut W) -> crate::Result<()>
+where
+    W: Write,
+{
     let buf = entry.write_to_bytes().unwrap();
     wt.write_u64::<LittleEndian>(buf.len() as u64)?;
     wt.write_all(&buf)?;