bump deps (#109)

Signed-off-by: Matt Klein <mklein@bitdrift.io>

Author: mattklein123

Cargo.lock

@@ -16,14 +16,14 @@ ahash                  = "0.8"
 anyhow                 = "1"
 assert_matches         = "1.5.0"
 async-trait            = "0.1"
-aws-config             = "1.8.12"
-aws-credential-types   = "1.2.11"
-aws-sdk-sqs            = "1.92.0"
-aws-sigv4              = "1.3.7"
-aws-smithy-async       = "1.2.7"
-aws-smithy-http        = "0.62.6"
-aws-smithy-runtime-api = { version = "1.10.0", features = ["test-util"] }
-aws-smithy-types       = "1.3.6"
+aws-config             = "1.8.15"
+aws-credential-types   = "1.2.14"
+aws-sdk-sqs            = "1.97.0"
+aws-sigv4              = "1.4.2"
+aws-smithy-async       = "1.2.14"
+aws-smithy-http        = "0.63.6"
+aws-smithy-runtime-api = { version = "1.11.6", features = ["test-util"] }
+aws-smithy-types       = "1.4.7"
 axum                   = "0.8.8"
 backoff                = { version = "0.4.0", features = ["tokio"] }
 base64ct               = "1.8.3"
@@ -42,19 +42,19 @@ bd-test-helpers        = { git = "https://github.com/bitdriftlabs/shared-core.gi
 bd-time                = { git = "https://github.com/bitdriftlabs/shared-core.git" }
 built                  = { version = "0.8", features = ["git2"] }
 bytes                  = "1"
-cc                     = "1.2.54"
-clap                   = { version = "4.5.54", features = ["derive", "env"] }
+cc                     = "1.2.58"
+clap                   = { version = "4.6.0", features = ["derive", "env"] }
 comfy-table            = "7.2.2"
 console-subscriber     = "0.5.0"
 criterion              = { version = "0.8", features = ["html_reports"] }
-ctor                   = "0.6.3"
+ctor                   = "0.7.0"
 cuckoofilter           = "0.5.0"
 dashmap                = { version = "6", features = ["raw-api"] }
-deadpool               = { version = "0.12", features = ["managed", "rt_tokio_1"] }
+deadpool               = { version = "0.13", features = ["managed", "rt_tokio_1"] }
 event-listener         = "5.4.1"
 fst                    = "0.4.7"
 futures                = "0.3"
-futures-util           = "0.3.31"
+futures-util           = "0.3.32"
 gettid                 = "0.1.4"
 hashbrown              = "0.16.1"
 http                   = "1.4.0"
@@ -69,13 +69,13 @@ hyper-rustls = { version = "0.27.7", default-features = false, features = [
   "aws-lc-rs",
 ] }
 
-hyper-util            = { version = "0.1.19", features = ["client", "client-legacy"] }
+hyper-util            = { version = "0.1.20", features = ["client", "client-legacy"] }
 hyperloglogplus       = "0.4.1"
 intrusive-collections = "0.10.0"
 itertools             = "0.14.0"
-k8s-openapi           = { version = "0.27.0", features = ["v1_31"] }
+k8s-openapi           = { version = "0.27.1", features = ["v1_31"] }
 
-kube = { version = "3.0.0", features = [
+kube = { version = "3.1.0", features = [
   "runtime",
   "derive",
   "rustls-tls",
@@ -102,25 +102,25 @@ protobuf-json-mapping = { git = "https://github.com/bitdriftlabs/rust-protobuf.g
 
 quickcheck        = "1"
 quickcheck_macros = "1"
-rand              = { version = "0.9", features = ["small_rng"] }
-rand_xoshiro      = "0.7"
+rand              = { version = "0.10" }
+rand_xoshiro      = "0.8"
 regex             = "1"
 
-reqwest = { version = "0.13.1", features = ["json"] }
+reqwest = { version = "0.13.2", features = ["json"] }
 
 reusable-fmt               = "0.2.0"
-rustls                     = "0.23.36"
+rustls                     = "0.23.37"
 serde                      = { version = "1", features = ["derive"] }
 serde_json                 = "1"
 serde_yaml                 = "0.9.34"
 snap                       = "1"
-socket2                    = "0.6.2"
-tempfile                   = "3.24"
+socket2                    = "0.6.3"
+tempfile                   = "3.27"
 thiserror                  = "2"
 tikv-jemalloc-ctl          = "0.6.1"
 tikv-jemallocator.features = ["profiling", "stats", "unprefixed_malloc_on_supported_platforms"]
 tikv-jemallocator.version  = "0.6.1"
-time                       = { version = "0.3.45", features = ["formatting"] }
+time                       = { version = "0.3.47", features = ["formatting"] }
 tokio                      = { version = "1", features = ["full", "parking_lot", "tracing", "test-util"] }
 tokio-stream               = "0.1.18"
 tokio-test                 = "0.4"
@@ -129,7 +129,7 @@ topological-sort           = "0.2.2"
 tracing                    = "0.1.44"
 unwrap-infallible          = "1.0.0"
 url                        = "2.5.8"
-uuid                       = { version = "1.19.0", features = ["v4"] }
+uuid                       = { version = "1.23.0", features = ["v4"] }
 
 vrl = { git = "https://github.com/mattklein123/vrl.git", branch = "performance-20260113", default-features = false, features = [
   "compiler",

Cargo.toml

@@ -16,7 +16,7 @@ use crate::protos::metric::{
 };
 use pulse_protobuf::protos::pulse::config::common::v1::common::WireProtocol;
 use pulse_protobuf::protos::pulse::config::common::v1::common::wire_protocol::Protocol_type;
-use rand::Rng;
+use rand::RngExt;
 use rand::seq::IndexedRandom;
 use rand_xoshiro::Xoroshiro128StarStar;
 use rand_xoshiro::rand_core::SeedableRng;
@@ -102,10 +102,7 @@ impl MetricGenerator {
   }
 
   pub fn name_terms(&mut self, terms: usize) -> String {
-    let terms: Vec<_> = WORDS
-      .choose_multiple(&mut self.rng, terms)
-      .copied()
-      .collect();
+    let terms: Vec<_> = WORDS.sample(&mut self.rng, terms).copied().collect();
     terms.join(self.sep)
   }
 

pulse-metrics/src/metric_generator.rs

@@ -766,33 +766,43 @@ fn make_router(handler: &Arc<InternodeHandler>) -> Router {
     Some(&handler.endpoint_stats),
     false,
   )
-  .merge(make_unary_router(
-    &ServiceMethod::<PeersComparisonRequest, PeersComparisonResponse>::new(
-      "Internode",
-      "GetPeersComparison",
-    ),
-    handler.clone(),
-    |_| {},
-    None,
-    false,
-  ))
-  .merge(make_unary_router(
-    &ServiceMethod::<LastElidedTimestampRequest, LastElidedTimestampResponse>::new(
-      "Internode",
-      "LastElidedTimestamp",
-    ),
-    handler.clone(),
-    |_| {},
-    None,
-    false,
-  ))
-  .merge(make_unary_router(
-    &ServiceMethod::<ReadyRequest, ReadyResponse>::new("Internode", "Ready"),
-    handler.clone(),
-    |_| {},
-    None,
-    false,
-  ))
+  .unwrap()
+  .merge(
+    make_unary_router(
+      &ServiceMethod::<PeersComparisonRequest, PeersComparisonResponse>::new(
+        "Internode",
+        "GetPeersComparison",
+      ),
+      handler.clone(),
+      |_| {},
+      None,
+      false,
+    )
+    .unwrap(),
+  )
+  .merge(
+    make_unary_router(
+      &ServiceMethod::<LastElidedTimestampRequest, LastElidedTimestampResponse>::new(
+        "Internode",
+        "LastElidedTimestamp",
+      ),
+      handler.clone(),
+      |_| {},
+      None,
+      false,
+    )
+    .unwrap(),
+  )
+  .merge(
+    make_unary_router(
+      &ServiceMethod::<ReadyRequest, ReadyResponse>::new("Internode", "Ready"),
+      handler.clone(),
+      |_| {},
+      None,
+      false,
+    )
+    .unwrap(),
+  )
 }
 
 /// Generate a server for inbound grpc requests

pulse-metrics/src/pipeline/processor/internode/mod.rs

@@ -5,8 +5,8 @@
 // LICENSE file or at:
 // https://polyformproject.org/wp-content/uploads/2020/06/PolyForm-Shield-1.0.0.txt
 
+use rand::RngExt;
 use rand::rngs::SmallRng;
-use rand::{Rng, SeedableRng};
 use std::cell::RefCell;
 use std::sync::Arc;
 use std::sync::atomic::{AtomicI64, Ordering};
@@ -84,7 +84,7 @@ pub struct RealDurationJitter {}
 impl RealDurationJitter {
   fn jitter_worker(min_millis: u64, max_millis: u64) -> Duration {
     thread_local! {
-      static RANDOM: RefCell<SmallRng> = RefCell::new(SmallRng::from_os_rng());
+      static RANDOM: RefCell<SmallRng> = RefCell::new(rand::make_rng());
     }
 
     let jittered_as_millis =

pulse-metrics/src/pipeline/time.rs

@@ -5,8 +5,8 @@
 // LICENSE file or at:
 // https://polyformproject.org/wp-content/uploads/2020/06/PolyForm-Shield-1.0.0.txt
 
-use rand::{RngCore, SeedableRng};
-use rand_xoshiro::Xoshiro128StarStar;
+use rand::Rng;
+use rand::rngs::SmallRng;
 use std::cell::RefCell;
 
 // This is a basic reservoir sampling implementation adapted from statsrelay. A reservoir is kept
@@ -33,7 +33,7 @@ impl ReservoirTimer {
   pub fn aggregate(&mut self, value: f64, sample_rate: f64) {
     thread_local! {
       // Fast non crypto rng.
-      static RANDOM: RefCell<Xoshiro128StarStar> = RefCell::new(Xoshiro128StarStar::from_os_rng());
+      static RANDOM: RefCell<SmallRng> = RefCell::new(rand::make_rng());
     }
 
     // Do an initial fill if we haven't filled the full reservoir.

pulse-metrics/src/reservoir_timer.rs

@@ -91,6 +91,7 @@ impl Function for PulseIncCounter {
         )));
       };
 
+      #[allow(clippy::result_large_err)]
       let tag_names: Vec<String> = tag_names
         .into_iter()
         .map(|tag_name| Ok::<_, ValueError>(tag_name.try_bytes_utf8_lossy()?.to_string()))

pulse-metrics/src/vrl/pulse_inc_counter.rs

@@ -75,7 +75,7 @@ message InternodeConfig {
   repeated NodeConfig nodes = 4 [(validate.rules).repeated.min_items = 1];
 
   // Configuration for internode requests. If not specified, default values are used.
-  RequestPolicy request_policy = 5 [(validate.rules).duration.gt = {}];
+  RequestPolicy request_policy = 5;
 
   // Configuration for health checks. If not specified, health checks are disabled. Take great
   // care in configuring health checks as settings that are too aggressive can cause flapping

pulse-protobuf/proto/pulse/config/processor/v1/internode.proto

@@ -6,7 +6,7 @@
 // https://polyformproject.org/wp-content/uploads/2020/06/PolyForm-Shield-1.0.0.txt
 
 // This file is generated by rust-protobuf 4.0.0-alpha.0. Do not edit
-// .proto file is parsed by protoc 33.2
+// .proto file is parsed by protoc 34.1
 // @generated
 
 // https://github.com/rust-lang/rust-clippy/issues/702

pulse-protobuf/src/protos/opentelemetry/common.rs

@@ -6,7 +6,7 @@
 // https://polyformproject.org/wp-content/uploads/2020/06/PolyForm-Shield-1.0.0.txt
 
 // This file is generated by rust-protobuf 4.0.0-alpha.0. Do not edit
-// .proto file is parsed by protoc 33.2
+// .proto file is parsed by protoc 34.1
 // @generated
 
 // https://github.com/rust-lang/rust-clippy/issues/702