Merge branch 'main' into crepererum/rub_str_rle_shrink_to_fit

Cargo.lock

@@ -191,9 +191,9 @@ dependencies = [
 
 [[package]]
 name = "assert_cmd"
-version = "1.0.8"
+version = "2.0.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c98233c6673d8601ab23e77eb38f999c51100d46c5703b17288c57fddf3a1ffe"
+checksum = "54f002ce7d0c5e809ebb02be78fd503aeed4a511fd0fcaff6e6914cbdabbfa33"
 dependencies = [
  "bstr",
  "doc-comment",
@@ -602,9 +602,9 @@ dependencies = [
 
 [[package]]
 name = "cloud-storage"
-version = "0.9.0"
+version = "0.10.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e781cbdd8c1c39dc43698f7a0f736abe624b9fa5f2aa952fb1fa2478291349b0"
+checksum = "6882d1c3788951dcfa4afe71da40a2a3913b3a81e2485b130f64714ce76b39c2"
 dependencies = [
  "base64 0.13.0",
  "bytes",
@@ -3983,9 +3983,9 @@ checksum = "388a1df253eca08550bef6c72392cfe7c30914bf41df5269b68cbd6ff8f570a3"
 
 [[package]]
 name = "serde"
-version = "1.0.127"
+version = "1.0.128"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f03b9878abf6d14e6779d3f24f07b2cfa90352cfec4acc5aab8f1ac7f146fae8"
+checksum = "1056a0db1978e9dbf0f6e4fca677f6f9143dc1c19de346f22cac23e422196834"
 dependencies = [
  "serde_derive",
 ]
@@ -4014,9 +4014,9 @@ dependencies = [
 
 [[package]]
 name = "serde_derive"
-version = "1.0.127"
+version = "1.0.128"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a024926d3432516606328597e0f224a51355a493b49fdd67e9209187cbe55ecc"
+checksum = "13af2fbb8b60a8950d6c72a56d2095c28870367cc8e10c55e9745bac4995a2c4"
 dependencies = [
  "proc-macro2",
  "quote",

Cargo.toml

@@ -142,7 +142,7 @@ parking_lot = "0.11.1"
 write_buffer = { path = "write_buffer" }
 
 # Crates.io dependencies, in alphabetical order
-assert_cmd = "1.0.0"
+assert_cmd = "2.0.0"
 flate2 = "1.0"
 hex = "0.4.2"
 predicates = "2.0.2"

influxdb_iox_client/Cargo.toml

@@ -21,7 +21,7 @@ http = "0.2.3"
 hyper = "0.14"
 prost = "0.8"
 rand = "0.8.3"
-serde = "1.0.118"
+serde = "1.0.128"
 serde_json = { version = "1.0.44", optional = true }
 thiserror = "1.0.23"
 tokio = { version = "1.0", features = ["macros"] }

iox_data_generator/src/agent.rs

@@ -135,11 +135,9 @@ impl<T: DataGenRng> Agent<T> {
         let mut total_points = 0;
 
         let mut points = self.generate().await?;
-        let mut batches = 1;
         while !points.is_empty() {
-            while batches < batch_size {
+            for _ in 0..batch_size {
                 points.append(&mut self.generate().await?);
-                batches += 1;
             }
             info!("[agent {}] sending {} points", self.name, points.len());
             total_points += points.len();
@@ -148,7 +146,6 @@ impl<T: DataGenRng> Agent<T> {
                 .await
                 .context(CouldNotWritePoints)?;
             points = self.generate().await?;
-            batches = 1;
         }
         Ok(total_points)
     }

object_store/Cargo.toml

@@ -13,7 +13,7 @@ azure_storage = { git = "https://github.com/Azure/azure-sdk-for-rust.git", rev =
 bytes = "1.0"
 chrono = "0.4"
 # Google Cloud Storage integration
-cloud-storage = {version = "0.9.0", optional = true}
+cloud-storage = {version = "0.10.2", optional = true}
 futures = "0.3"
 itertools = "0.10.1"
 percent-encoding = "2.1"