Update deps and fix warnings

.github/workflows/static.yml

@@ -15,7 +15,7 @@ jobs:
           ubuntu-latest,
         ]
         toolchain: [
-          1.75.0,
+          1.77.2,
           stable,
         ]
     steps:

.github/workflows/test.yml

@@ -15,10 +15,11 @@ jobs:
         os: [
           ubuntu-latest,
           macos-latest,
+          macos-13,
           windows-latest,
         ]
         toolchain: [
-          1.75.0,
+          1.77.2,
           stable,
         ]
     steps:

Cargo.toml

@@ -20,17 +20,17 @@ futures = "0.3"
 hex = "0.4"
 hex-literal = "0.4"
 influxdb = "0.7"
-influxive-core = { version = "0.0.2-alpha.1", path = "crates/influxive-core" }
-influxive-writer = { version = "0.0.2-alpha.1", path = "crates/influxive-writer" }
-influxive-downloader = { version = "0.0.2-alpha.1", path = "crates/influxive-downloader" }
-influxive-child-svc = { version = "0.0.2-alpha.1", path = "crates/influxive-child-svc" }
-influxive-otel = { version = "0.0.2-alpha.1", path = "crates/influxive-otel" }
-influxive-otel-atomic-obs = { version = "0.0.2-alpha.1", path = "crates/influxive-otel-atomic-obs" }
+influxive-core = { version = "0.0.3-alpha.1", path = "crates/influxive-core" }
+influxive-writer = { version = "0.0.3-alpha.1", path = "crates/influxive-writer" }
+influxive-downloader = { version = "0.0.3-alpha.1", path = "crates/influxive-downloader" }
+influxive-child-svc = { version = "0.0.3-alpha.1", path = "crates/influxive-child-svc" }
+influxive-otel = { version = "0.0.3-alpha.1", path = "crates/influxive-otel" }
+influxive-otel-atomic-obs = { version = "0.0.3-alpha.1", path = "crates/influxive-otel-atomic-obs" }
 opentelemetry_api = { version = "0.20.0", features = [ "metrics" ] }
-reqwest = "0.11"
+reqwest = "0.12"
 sha2 = "0.10"
 tar = "0.4"
 tempfile = "3"
 tokio = "1"
 tracing = "0.1"
-zip = "0.6"
+zip = "2.1"

crates/influxive-child-svc/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive-child-svc"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "Run influxd as a child process"
 license = "MIT OR Apache-2.0"

crates/influxive-child-svc/src/download_binaries.rs

@@ -4,15 +4,15 @@ use influxive_downloader::*;
 mod tgt {
     use super::*;
     pub const DL_DB: Option<DownloadSpec> = Some(DownloadSpec {
-        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.1-linux-amd64.tar.gz",
+        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.6_linux_amd64.tar.gz",
         archive: Archive::TarGz {
-            inner_path: "influxdb2_linux_amd64/influxd",
+            inner_path: "influxdb2-2.7.6/usr/bin/influxd",
         },
         archive_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "e5ecfc15c35af55641ffc92680ad0fb043aa51a942944252e214e2a551c60ebb"
+            "a29d56dbd18edeeb893f61fa0517f5d9140d2e073f2ecf805912f4b91f308825"
         )),
         file_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "68547e6e8b05088f1d824c9923412d22045003026f4f6e844630a126c10a97e1"
+            "5c8fcb17accb9b0e689e0c6259aaace16ac42e5c0a2c99cef158de843d14d759"
         )),
         file_prefix: "influxd",
         file_extension: "",
@@ -37,15 +37,15 @@ mod tgt {
 mod tgt {
     use super::*;
     pub const DL_DB: Option<DownloadSpec> = Some(DownloadSpec {
-        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.1-linux-arm64.tar.gz",
+        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.6_linux_arm64.tar.gz",
         archive: Archive::TarGz {
-            inner_path: "influxdb2_linux_arm64/influxd",
+            inner_path: "influxdb2-2.7.6/usr/bin/influxd",
         },
         archive_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "b88989dae0c802fdee499fa07aae837139da3c786293c74e9d7c46b8460510d4"
+            "96b5574a2772da7d54f496d881e741f3339027a563502e55d8084504b0e22e90"
         )),
         file_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "b966602eb1b43b5d9633446f91d3b84cdd15abfdcaa3aac3dd210368e4eca85e"
+            "e2d8b81c11e6bec68bc61adb224ba58d87be951c6a0ce9f9907c55a3b69ed864"
         )),
         file_prefix: "influxd",
         file_extension: "",
@@ -68,20 +68,20 @@ mod tgt {
 
 #[cfg(all(
     any(target_os = "macos", target_os = "ios", target_os = "tvos"),
-    target_arch = "x86_64"
+    any(target_arch = "x86_64", target_arch = "aarch64")
 ))]
 mod tgt {
     use super::*;
     pub const DL_DB: Option<DownloadSpec> = Some(DownloadSpec {
-        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.1-darwin-amd64.tar.gz",
+        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.6_darwin_amd64.tar.gz",
         archive: Archive::TarGz {
-            inner_path: "influxdb2_darwin_amd64/influxd",
+            inner_path: "influxdb2-2.7.6/influxd",
         },
         archive_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "af709215dce8767ae131802f050c139d0ae179c13f29bb68ca5baa2716aa1874"
+            "f484a41ad390ccae7a4cc99960ed0eb6a0309487696cf646b63122c96dbd139d"
         )),
         file_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "8eb1e1391f6c6619c44b5edd27a39806cb7de89adb8712f66e74379801da4ce3"
+            "01d6a032a9508c8e860726824e9c50e177d3afa5333c69c753d6c776c5d89e4a"
         )),
         file_prefix: "influxd",
         file_extension: "",
@@ -106,15 +106,15 @@ mod tgt {
 mod tgt {
     use super::*;
     pub const DL_DB: Option<DownloadSpec> = Some(DownloadSpec {
-        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.1-windows-amd64.zip",
+        url: "https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.6-windows.zip",
         archive: Archive::Zip {
-            inner_path: "influxdb2_windows_amd64\\influxd.exe",
+            inner_path: "influxd.exe",
         },
         archive_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "8e0acbc7dba55a794450fa53d72cd48958d11d39e619394a268e06a6c03af672"
+            "a874451d9e41dbcd63486c382b9d8bd4c3e06d7ebfdd78b0c7cdfa16bf7e5df3"
         )),
         file_hash: Hash::Sha2_256(&hex_literal::hex!(
-            "841f6739607765fc2ffc39be9514dfdce597381368987bab48f5d9cab8d544c7"
+            "c6ad343c46eff73fcebcbeead06d30564293c6ece2dfaa829dfe1811370450ed"
         )),
         file_prefix: "influxd",
         file_extension: ".exe",
@@ -142,7 +142,7 @@ mod tgt {
     ),
     all(
         any(target_os = "macos", target_os = "ios", target_os = "tvos"),
-        target_arch = "x86_64"
+        any(target_arch = "x86_64", target_arch = "aarch64")
     ),
     all(target_os = "windows", target_arch = "x86_64")
 )))]

crates/influxive-child-svc/src/lib.rs

@@ -1,5 +1,4 @@
 #![deny(missing_docs)]
-#![deny(warnings)]
 #![deny(unsafe_code)]
 //! Run influxd as a child process.
 //!
@@ -514,7 +513,7 @@ async fn validate_influx(
     // alas, the cli prints out the unhelpful version "dev".
     if is_cli && !ver.contains("build_date: 2023-04-28") {
         return Err(err_other(format!("invalid build_date: {ver}")));
-    } else if !is_cli && !ver.contains("InfluxDB v2.7.1") {
+    } else if !is_cli && !ver.contains("InfluxDB v2.7.6") {
         return Err(err_other(format!("invalid version: {ver}")));
     }
 

crates/influxive-child-svc/src/test.rs

@@ -7,8 +7,8 @@ const DASHBOARD_TEMPLATE: &[u8] =
 async fn sanity() {
     let tmp = tempfile::tempdir().unwrap();
 
-    const METRIC: &'static str = "my.metric";
-    const VALUE: &'static str = "value";
+    const METRIC: &str = "my.metric";
+    const VALUE: &str = "value";
 
     let i = InfluxiveChildSvc::new(
         InfluxiveChildSvcConfig::default()
@@ -56,7 +56,7 @@ async fn sanity() {
         .unwrap();
 
     // make sure the result contains at least 10 of the entries
-    let line_count = result.split("\n").count();
+    let line_count = result.split('\n').count();
     assert!(line_count >= 10, "{result}");
 
     drop(i);

crates/influxive-core/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive-core"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "Core types for influxive crates"
 license = "MIT OR Apache-2.0"

crates/influxive-downloader/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive-downloader"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "Influxive system download utility"
 license = "MIT OR Apache-2.0"

crates/influxive-downloader/src/lib.rs

@@ -1,5 +1,4 @@
 #![deny(missing_docs)]
-#![deny(warnings)]
 #![deny(unsafe_code)]
 //! Influxive system download utility. It's probably not useful to use this
 //! crate directly. It mainly exists as separate from the

crates/influxive-otel-atomic-obs/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive-otel-atomic-obs"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "Opentelemetry observable metric implementations based on std::sync::atomic types"
 license = "MIT OR Apache-2.0"

crates/influxive-otel-atomic-obs/src/lib.rs

@@ -1,5 +1,4 @@
 #![deny(missing_docs)]
-#![deny(warnings)]
 #![deny(unsafe_code)]
 //! Opentelemetry observable metric implementations based on std::sync::atomic
 //! types.
@@ -135,7 +134,10 @@ impl Drop for Unreg {
 /// Observable counter based on std::sync::atomic::AtomicU64
 /// (but storing f64 bits).
 #[derive(Debug, Clone)]
-pub struct AtomicObservableCounterF64(Arc<AtomicU64>, Arc<Unreg>);
+pub struct AtomicObservableCounterF64(
+    Arc<AtomicU64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableCounterF64 {
     /// Construct a new AtomicObservableCounterF64, and associated
@@ -205,7 +207,10 @@ impl AtomicObservableCounterF64 {
 /// Observable up down counter based on std::sync::atomic::AtomicU64
 /// (but storing f64 bits).
 #[derive(Debug, Clone)]
-pub struct AtomicObservableUpDownCounterF64(Arc<AtomicU64>, Arc<Unreg>);
+pub struct AtomicObservableUpDownCounterF64(
+    Arc<AtomicU64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableUpDownCounterF64 {
     /// Construct a new AtomicObservableUpDownCounterF64,
@@ -270,7 +275,10 @@ impl AtomicObservableUpDownCounterF64 {
 /// Observable gauge based on std::sync::atomic::AtomicU64
 /// (but storing f64 bits).
 #[derive(Debug, Clone)]
-pub struct AtomicObservableGaugeF64(Arc<AtomicU64>, Arc<Unreg>);
+pub struct AtomicObservableGaugeF64(
+    Arc<AtomicU64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableGaugeF64 {
     /// Construct a new AtomicObservableGaugeF64, and associated opentelemetry metric.
@@ -326,7 +334,10 @@ impl AtomicObservableGaugeF64 {
 
 /// Observable gauge based on std::sync::atomic::AtomicI64.
 #[derive(Debug, Clone)]
-pub struct AtomicObservableGaugeI64(Arc<AtomicI64>, Arc<Unreg>);
+pub struct AtomicObservableGaugeI64(
+    Arc<AtomicI64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableGaugeI64 {
     /// Construct a new ObsGaugeAtomicI64, and associated opentelemetry metric.
@@ -382,7 +393,10 @@ impl AtomicObservableGaugeI64 {
 
 /// Observable up down counter based on std::sync::atomic::AtomicI64.
 #[derive(Debug, Clone)]
-pub struct AtomicObservableUpDownCounterI64(Arc<AtomicI64>, Arc<Unreg>);
+pub struct AtomicObservableUpDownCounterI64(
+    Arc<AtomicI64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableUpDownCounterI64 {
     /// Construct a new AtomicObservableUpDownCounterI64,
@@ -440,7 +454,10 @@ impl AtomicObservableUpDownCounterI64 {
 
 /// Observable counter based on std::sync::atomic::AtomicU64.
 #[derive(Debug, Clone)]
-pub struct AtomicObservableCounterU64(Arc<AtomicU64>, Arc<Unreg>);
+pub struct AtomicObservableCounterU64(
+    Arc<AtomicU64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableCounterU64 {
     /// Construct a new AtomicObservableCounterU64,
@@ -498,7 +515,10 @@ impl AtomicObservableCounterU64 {
 
 /// Observable gauge based on std::sync::atomic::AtomicU64.
 #[derive(Debug, Clone)]
-pub struct AtomicObservableGaugeU64(Arc<AtomicU64>, Arc<Unreg>);
+pub struct AtomicObservableGaugeU64(
+    Arc<AtomicU64>,
+    #[allow(unused)] Arc<Unreg>,
+);
 
 impl AtomicObservableGaugeU64 {
     /// Construct a new AtomicObservableGaugeU64,

crates/influxive-otel/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive-otel"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "Opentelemetry metrics bindings for influxive-child-svc"
 license = "MIT OR Apache-2.0"

crates/influxive-writer/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive-writer"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "Rust utility for efficiently writing metrics to a running InfluxDB instance"
 license = "MIT OR Apache-2.0"

crates/influxive-writer/src/test.rs

@@ -123,7 +123,7 @@ async fn writer_stress() {
             );
             writer.write_metric(
                 Metric::new(std::time::SystemTime::now(), "my.metric")
-                    .with_field("val", 3.14)
+                    .with_field("val", 3.77)
                     .with_tag("tag", "test-tag"),
             );
         }
@@ -150,7 +150,7 @@ async fn writer_stress() {
             );
             writer.write_metric(
                 Metric::new(std::time::SystemTime::now(), "my.metric")
-                    .with_field("val", 3.14)
+                    .with_field("val", 3.77)
                     .with_tag("tag", "test-tag"),
             );
         }

crates/influxive/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "influxive"
-version = "0.0.2-alpha.1"
+version = "0.0.3-alpha.1"
 edition = "2021"
 description = "High-level Rust integration of opentelemetry metrics and InfluxDB"
 license = "MIT OR Apache-2.0"