Fix: debugging the odd hanging when Redis hicks up

eigenein · Jun 3, 2022 · eab3d4d · eab3d4d
1 parent a2d02d2
commit eab3d4d
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/rusty-shared-opts/src/heartbeat.rs b/rusty-shared-opts/src/heartbeat.rs
@@ -1,7 +1,7 @@
 use anyhow::Result;
 use clap::Parser;
 use reqwest::{Client, Url};
-use tracing::{debug, instrument, warn};
+use tracing::{debug, info, instrument, warn};
 
 #[derive(Parser)]
 pub struct Opts {
@@ -34,6 +34,7 @@ impl Heartbeat {
     pub async fn send(&self) {
         match &self.endpoint {
             Some((client, url)) => {
+                info!("sending heartbeat…");
                 if let Err(error) = client.post(url.clone()).send().await {
                     warn!("heartbeat error: {:#}", error);
                 }

diff --git a/rusty-shared-redis/src/lib.rs b/rusty-shared-redis/src/lib.rs
@@ -108,6 +108,7 @@ fn new_configuration(addresses: &[SocketAddr], service_name: String) -> Result<R
             }
         },
         blocking: Blocking::Error,
+        tracing: true,
         ..Default::default()
     };
     Ok(config)

diff --git a/rusty-shared-tractive/Cargo.toml b/rusty-shared-tractive/Cargo.toml
@@ -9,5 +9,3 @@ chrono = "0.4.19"
 fred = { version = "5.0.0", default-features = false }
 kv-derive = "1.0.0-rc.9"
 serde = "1.0.137"
-serde_json = "1.0.79"
-serde_with = { version = "1.13.0", features = ["chrono"] }
diff --git a/rusty-tractive/src/service.rs b/rusty-tractive/src/service.rs
@@ -118,6 +118,7 @@ impl Service {
             info!("⌚ timestamp is not updated");
             return Ok(());
         }
+        info!("⌚ pushing new entry…");
         self.redis
             .client
             .xadd(
@@ -154,6 +155,7 @@ impl Service {
             info!("🎯 timestamp is not updated");
             return Ok(());
         }
+        info!("🎯 pushing new entry…");
         self.redis
             .client
             .xadd(