Redis set support + RedisTempList managed expiring list, great for te…

…mp logs/events (#31)

opencollector.yaml

@@ -32,7 +32,7 @@ exporters:
       stream-name: default
   # Writes all opentelemetry logs, traces, metrics to a file, useful for testing:
   file/debug_file_writing:
-    path: /home/runner/work/bitbazaar/bitbazaar/logs/otlp_telemetry_out.log
+    path: /Users/zak/z/code/bitbazaar/logs/otlp_telemetry_out.log
     rotation:
       max_megabytes: 10
       max_days: 3

rust/Cargo.toml

@@ -31,6 +31,7 @@ redis = [
   'dep:rand',
   'dep:futures',
   'dep:futures-timer',
+  'dep:chrono',
 ]
 opentelemetry-grpc = [
   'dep:tracing-log',

rust/bitbazaar/log/global_log/setup.rs

@@ -178,16 +178,29 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
                     // Spinlock up to 10 seconds until the collector is listening, important not to lose startup logs, don't want to continue until we know the collector can receive logs.
                     let wait_start = std::time::Instant::now();
                     let mut found_collector = false;
+                    let mut is_first = true;
                     while wait_start.elapsed() < std::time::Duration::from_secs(10) {
                         if crate::misc::is_tcp_port_listening("localhost", port)? {
                             found_collector = true;
+
+                            // If printed the spinlocking message, confirm all good now:
+                            if !is_first {
+                                println!("Collector up after {:?}!", wait_start.elapsed());
+                            }
+
                             break;
                         }
+
+                        if is_first {
+                            println!("Spinlocking for up to 10 seconds for OpenTelemetry collector availability on local port {}...", port);
+                            is_first = false;
+                        }
+
                         // Don't want this to delay startup otherwise, so very short waits:
                         std::thread::sleep(std::time::Duration::from_millis(5));
                     }
                     if !found_collector {
-                        return Err(anyerr!("Can't connect to open telemetry collector on local port {} (waited for 10 seconds). Are you sure it's running?", port));
+                        return Err(anyerr!("Can't connect to open telemetry collector on local port {}. Are you sure it's running?", port));
                     }
 
                     let endpoint = format!("grpc://localhost:{}", port);