updated persy implementation for use tracing

Cargo.lock

@@ -246,6 +246,7 @@ version = "0.1.0"
 dependencies = [
  "base64 0.13.0",
  "bytes",
+ "chrono",
  "crossbeam",
  "directories",
  "heed",
@@ -275,6 +276,7 @@ dependencies = [
  "sled",
  "thiserror",
  "threadpool",
+ "timer",
  "tokio",
  "tracing",
  "tracing-flame",
@@ -2934,6 +2936,15 @@ dependencies = [
  "syn",
 ]
 
+[[package]]
+name = "timer"
+version = "0.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "31d42176308937165701f50638db1c31586f183f1aab416268216577aec7306b"
+dependencies = [
+ "chrono",
+]
+
 [[package]]
 name = "tinyvec"
 version = "1.3.1"

src/database/abstraction/persy.rs

@@ -17,6 +17,8 @@ use std::{
     time::{Duration, Instant},
 };
 
+use tracing::warn;
+
 pub struct PersyEngine {
     persy: Persy,
     write_cache: Arc<RwLock<WriteCache>>,
@@ -415,7 +417,7 @@ impl Tree for PersyTree {
                 self.write_cache.read().unwrap().iter(&self.name, result)
             }
             Err(e) => {
-                log::warn!("error iterating {:?}", e);
+                warn!("error iterating {:?}", e);
                 Box::new(std::iter::empty())
             }
         }
@@ -453,7 +455,7 @@ impl Tree for PersyTree {
                     .iter_from(&self.name, from, backwards, result)
             }
             Err(e) => {
-                log::warn!("error iterating with prefix {:?}", e);
+                warn!("error iterating with prefix {:?}", e);
                 Box::new(std::iter::empty())
             }
         }
@@ -493,7 +495,7 @@ impl Tree for PersyTree {
                     .scan_prefix(&self.name, prefix, result)
             }
             Err(e) => {
-                log::warn!("error scanning prefix {:?}", e);
+                warn!("error scanning prefix {:?}", e);
                 Box::new(std::iter::empty())
             }
         }