chore(deps): Bump rand from 0.8.5 to 0.9.0 (vectordotdev#22403)

* chore(deps): Bump rand from 0.8.5 to 0.9.0

Bumps [rand](https://github.com/rust-random/rand) from 0.8.5 to 0.9.0.
- [Release notes](https://github.com/rust-random/rand/releases)
- [Changelog](https://github.com/rust-random/rand/blob/master/CHANGELOG.md)
- [Commits](rust-random/rand@0.8.5...0.9.0)

---
updated-dependencies:
- dependency-name: rand
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <[email protected]>

* major updates

* revert changes to the dreaded patch file

* update test since rand behavior changed

* update seed for 'decode_shuffled_messages'

* rename to distr

* update portpicker

* dd-rust-license-tool write

---------

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Pavlos Rontidis <[email protected]>

Author: dependabot[bot]

Cargo.lock

@@ -155,7 +155,8 @@ prost = { version = "0.12", default-features = false, features = ["std"] }
 prost-build = { version = "0.12", default-features = false }
 prost-reflect = { version = "0.14", features = ["serde"], default-features = false }
 prost-types = { version = "0.12", default-features = false }
-rand = { version = "0.8.5", default-features = false, features = ["small_rng"] }
+rand = { version = "0.9.0", default-features = false, features = ["small_rng", "thread_rng"] }
+rand_distr = { version = "0.5.1", default-features = false }
 semver = { version = "1.0.25", default-features = false, features = ["serde", "std"] }
 serde_json = { version = "1.0.139", default-features = false, features = ["raw_value", "std"] }
 serde = { version = "1.0.218", default-features = false, features = ["alloc", "derive", "rc"] }
@@ -359,7 +360,7 @@ percent-encoding = { version = "2.3.1", default-features = false }
 postgres-openssl = { version = "0.5.1", default-features = false, features = ["runtime"], optional = true }
 pulsar = { version = "6.3.0", default-features = false, features = ["tokio-runtime", "auth-oauth2", "flate2", "lz4", "snap", "zstd"], optional = true }
 rand.workspace = true
-rand_distr = { version = "0.4.3", default-features = false }
+rand_distr.workspace = true
 rdkafka = { version = "0.37.0", default-features = false, features = ["curl-static", "tokio", "libz", "ssl", "zstd"], optional = true }
 redis = { version = "0.24.0", default-features = false, features = ["connection-manager", "tokio-comp", "tokio-native-tls-comp"], optional = true }
 regex = { version = "1.11.1", default-features = false, features = ["std", "perf"] }

Cargo.toml

@@ -493,7 +493,7 @@ radium,https://github.com/bitvecto-rs/radium,MIT,"Nika Layzell <nika@thelayzells
 radix_trie,https://github.com/michaelsproul/rust_radix_trie,MIT,Michael Sproul <[email protected]>
 rand,https://github.com/rust-random/rand,MIT OR Apache-2.0,"The Rand Project Developers, The Rust Project Developers"
 rand_chacha,https://github.com/rust-random/rand,MIT OR Apache-2.0,"The Rand Project Developers, The Rust Project Developers, The CryptoCorrosion Contributors"
-rand_distr,https://github.com/rust-random/rand,MIT OR Apache-2.0,The Rand Project Developers
+rand_distr,https://github.com/rust-random/rand_distr,MIT OR Apache-2.0,The Rand Project Developers
 rand_hc,https://github.com/rust-random/rand,MIT OR Apache-2.0,The Rand Project Developers
 rand_xorshift,https://github.com/rust-random/rngs,MIT OR Apache-2.0,"The Rand Project Developers, The Rust Project Developers"
 ratatui,https://github.com/ratatui/ratatui,MIT,"Florian Dehau <[email protected]>, The Ratatui Developers"

LICENSE-3rdparty.csv

@@ -1,12 +1,12 @@
 use criterion::{criterion_group, criterion_main, BatchSize, Criterion};
 use rand::{
-    distributions::{Distribution, Uniform},
+    distr::{Distribution, Uniform},
     seq::SliceRandom,
 };
 use vector::{event::metric::Sample, sinks::util::statistic::DistributionStatistic};
 
 fn generate_samples(mut size: u32, max_bin_count: u32) -> Vec<Sample> {
-    let mut rng = rand::thread_rng();
+    let mut rng = rand::rng();
     let range = Uniform::from(1..=max_bin_count);
     let mut value = 1.0;
     let mut samples = Vec::new();

benches/distribution_statistic.rs

@@ -511,7 +511,6 @@ impl Decoder for ChunkedGelfDecoder {
 
 #[cfg(test)]
 mod tests {
-
     use super::*;
     use bytes::{BufMut, BytesMut};
     use flate2::{write::GzEncoder, write::ZlibEncoder};
@@ -734,7 +733,7 @@ mod tests {
 
     #[tokio::test]
     async fn decode_shuffled_messages() {
-        let mut rng = SmallRng::seed_from_u64(420);
+        let mut rng = SmallRng::seed_from_u64(42);
         let total_chunks = 100u8;
         let first_message_id = 1u64;
         let first_payload = "first payload";

lib/codecs/src/decoding/framing/chunked_gelf.rs

@@ -9,4 +9,4 @@ license = "MPL-2.0"
 [dependencies]
 chrono.workspace = true
 fakedata_generator = "0.5.0"
-rand = "0.8.5"
+rand.workspace = true

lib/fakedata/Cargo.toml

@@ -4,7 +4,7 @@ use chrono::{
     SecondsFormat,
 };
 use fakedata_generator::{gen_domain, gen_ipv4, gen_username};
-use rand::{thread_rng, Rng};
+use rand::{rng, Rng};
 
 static APPLICATION_NAMES: [&str; 10] = [
     "auth", "data", "deploy", "etl", "scraper", "cron", "ingress", "egress", "alerter", "fwd",
@@ -217,13 +217,13 @@ fn syslog_version() -> usize {
 
 // Helper functions
 fn random_in_range(min: usize, max: usize) -> usize {
-    thread_rng().gen_range(min..max)
+    rng().random_range(min..max)
 }
 
 fn random_from_array<T: ?Sized>(v: &'static [&'static T]) -> &'static T {
-    v[thread_rng().gen_range(0..v.len())]
+    v[rng().random_range(0..v.len())]
 }
 
 fn random_from_array_copied<T: Copy>(v: &[T]) -> T {
-    v[thread_rng().gen_range(0..v.len())]
+    v[rng().random_range(0..v.len())]
 }

lib/fakedata/src/logs.rs

@@ -18,7 +18,7 @@ tokio = { version = "1.43.0", features = ["full"] }
 indoc = "2.0.5"
 env_logger = "0.11"
 tracing = { version = "0.1", features = ["log"] }
-rand = "0.8"
+rand.workspace = true
 
 [features]
 e2e-tests = []

lib/k8s-e2e-tests/Cargo.toml

@@ -10,6 +10,8 @@ use k8s_openapi::{
 use k8s_test_framework::{
     test_pod, wait_for_resource::WaitFor, CommandBuilder, Framework, Interface, Manager, Reader,
 };
+use rand::distr::{Alphanumeric, SampleString};
+use rand::rng;
 use tracing::{debug, error, info};
 
 pub mod metrics;
@@ -21,16 +23,9 @@ pub fn init() {
 }
 
 pub fn get_namespace() -> String {
-    use rand::Rng;
-
-    // Generate a random alphanumeric (lowercase) string to ensure each test is run with unique
-    // names.
+    // Generate a random alphanumeric (lowercase) string to ensure each test is run with unique names.
     // There is a 36 ^ 5 chance of a name collision, which is likely to be an acceptable risk.
-    let id: String = rand::thread_rng()
-        .sample_iter(&rand::distributions::Alphanumeric)
-        .take(5)
-        .map(|num| (num as char).to_ascii_lowercase())
-        .collect();
+    let id = Alphanumeric.sample_string(&mut rng(), 5).to_lowercase();
 
     format!("vector-{}", id)
 }

lib/k8s-e2e-tests/src/lib.rs

@@ -7,4 +7,4 @@ publish = false
 license = "Unlicense"
 
 [dependencies]
-rand = "0.8.5"
+rand.workspace = true

lib/portpicker/Cargo.toml

@@ -30,7 +30,7 @@
 
 use std::net::{IpAddr, SocketAddr, TcpListener, ToSocketAddrs, UdpSocket};
 
-use rand::{thread_rng, Rng};
+use rand::{rng, Rng};
 
 pub type Port = u16;
 
@@ -71,12 +71,12 @@ fn ask_free_tcp_port(ip: IpAddr) -> Option<Port> {
 /// let port: u16 = pick_unused_port(IpAddr::V4(Ipv4Addr::LOCALHOST));
 /// ```
 pub fn pick_unused_port(ip: IpAddr) -> Port {
-    let mut rng = thread_rng();
+    let mut rng = rng();
 
     loop {
         // Try random port first
         for _ in 0..10 {
-            let port = rng.gen_range(15000..25000);
+            let port = rng.random_range(15000..25000);
             if is_free(ip, port) {
                 return port;
             }

lib/portpicker/src/lib.rs

@@ -42,7 +42,7 @@ metrics-tracing-context.workspace = true
 metrics-util = { workspace = true, features = ["debugging"] }
 proptest = "1.6"
 quickcheck = "1.0"
-rand = "0.8.5"
+rand.workspace = true
 serde_yaml = { version = "0.9", default-features = false }
 temp-dir = "0.1.14"
 tokio-test = "0.4.4"

lib/vector-buffers/Cargo.toml

@@ -231,11 +231,11 @@ impl Configuration {
 }
 
 fn generate_record_cache(min: usize, max: usize) -> Vec<VariableMessage> {
-    let mut rng = rand::thread_rng();
+    let mut rng = rand::rng();
     let mut records = Vec::new();
     for i in 1..=200_000 {
-        let payload_size = rng.gen_range(min..max);
-        let payload = (0..payload_size).map(|_| rng.gen::<u8>()).collect();
+        let payload_size = rng.random_range(min..max);
+        let payload = (0..payload_size).map(|_| rng.random::<u8>()).collect();
         let message = VariableMessage::new(i, payload);
         records.push(message);
     }

lib/vector-buffers/examples/buffer_perf.rs

@@ -89,8 +89,8 @@ toml.workspace = true
 ndarray = "0.16.1"
 ndarray-stats = "0.6.0"
 noisy_float = "0.2.0"
-rand = "0.8.5"
-rand_distr = "0.4.3"
+rand.workspace = true
+rand_distr.workspace = true
 serde_yaml = { version = "0.9.34", default-features = false }
 tracing-subscriber = { version = "0.3.19", default-features = false, features = ["env-filter", "fmt", "ansi", "registry"] }
 vector-common = { path = "../vector-common", default-features = false, features = ["test"] }

lib/vector-core/Cargo.toml

@@ -1106,7 +1106,7 @@ mod tests {
     #[cfg(ddsketch_extended)]
     fn generate_pareto_distribution() -> Vec<OrderedFloat<f64>> {
         use ordered_float::OrderedFloat;
-        use rand::thread_rng;
+        use rand::rng;
         use rand_distr::{Distribution, Pareto};
 
         // Generate a set of samples that roughly correspond to the latency of a typical web
@@ -1116,7 +1116,7 @@ mod tests {
         //let distribution = Gamma::new(1.2, 100.0).unwrap();
         let distribution = Pareto::new(1.0, 1.0).expect("pareto distribution should be valid");
         let mut samples = distribution
-            .sample_iter(thread_rng())
+            .sample_iter(rng())
             // Scale by 10,000 to get microseconds.
             .map(|n| n * 10_000.0)
             .filter(|n| *n > 15_000.0 && *n < 10_000_000.0)

lib/vector-core/src/metrics/ddsketch.rs

@@ -20,5 +20,5 @@ vector-core = { path = "../vector-core" }
 
 [dev-dependencies]
 proptest = "1.6"
-rand = "0.8.5"
-rand_distr = "0.4.3"
+rand.workspace = true
+rand_distr.workspace = true

lib/vector-stream/Cargo.toml

@@ -360,9 +360,8 @@ mod tests {
         pub(crate) fn get_sleep_dur(&mut self) -> Duration {
             let lower = self.lower_bound_us;
             let upper = self.upper_bound_us;
-
-            // Generate a value between 10ms and 500ms, with a long tail shape to the distribution.
-            #[allow(clippy::cast_sign_loss)] // Value will be positive anyways
+            // Generate a value between `lower` and `upper`, with a long tail shape to the distribution.
+            #[allow(clippy::cast_sign_loss)] // Value will be positive anyway
             self.jitter
                 .sample_iter(&mut self.jitter_gen)
                 .map(|n| n * lower as f64)

lib/vector-stream/src/driver.rs

@@ -9,6 +9,7 @@ use encoding::EventEncodingType;
 use futures::{stream, Stream, StreamExt};
 use output::{from_tap_payload_to_output_events, OutputEventsPayload};
 use rand::{rngs::SmallRng, Rng, SeedableRng};
+use std::time::{SystemTime, UNIX_EPOCH};
 use tokio::{select, sync::mpsc, time};
 use tokio_stream::wrappers::ReceiverStream;
 use vector_lib::tap::{
@@ -81,7 +82,11 @@ pub(crate) fn create_events_stream(
 
         // Random number generator to allow for sampling. Speed trumps cryptographic security here.
         // The RNG must be Send + Sync to use with the `select!` loop below, hence `SmallRng`.
-        let mut rng = SmallRng::from_entropy();
+        let seed = SystemTime::now()
+            .duration_since(UNIX_EPOCH)
+            .unwrap()
+            .as_nanos() as u64;
+        let mut rng = SmallRng::seed_from_u64(seed);
 
         // Keep a count of the batch size, which will be used as a seed for random eviction
         // per the sampling strategy used below.
@@ -113,7 +118,7 @@ pub(crate) fn create_events_stream(
                         if limit > results.len() {
                             results.push(payload);
                         } else {
-                            let random_number = rng.gen_range(0..batch);
+                            let random_number = rng.random_range(0..batch);
                             if random_number < results.len() {
                                 results[random_number] = payload;
                             }

src/api/schema/events/mod.rs

@@ -462,8 +462,8 @@ impl MaxConnectionAgeLayer {
         // Ensure the jitter_factor is between 0.0 and 1.0
         let jitter_factor = jitter_factor.clamp(0.0, 1.0);
         // Generate a random jitter factor between `1 - jitter_factor`` and `1 + jitter_factor`.
-        let mut rng = rand::thread_rng();
-        let random_jitter_factor = rng.gen_range(-jitter_factor..=jitter_factor) + 1.;
+        let mut rng = rand::rng();
+        let random_jitter_factor = rng.random_range(-jitter_factor..=jitter_factor) + 1.;
         duration.mul_f64(random_jitter_factor)
     }
 }

src/http.rs

@@ -115,7 +115,7 @@ async fn cloudwatch_metrics_namespace_partitioning() {
         }
     }
 
-    events.shuffle(&mut rand::thread_rng());
+    events.shuffle(&mut rand::rng());
 
     run_and_assert_sink_compliance(sink, stream::iter(events), &AWS_SINK_TAGS).await;
 }

src/sinks/aws_cloudwatch_metrics/integration_tests.rs

@@ -7,7 +7,7 @@ use chrono::Utc;
 use databend_client::error::Error as DatabendError;
 use databend_client::APIClient as DatabendAPIClient;
 use futures::future::BoxFuture;
-use rand::{thread_rng, Rng};
+use rand::{rng, Rng};
 use rand_distr::Alphanumeric;
 use snafu::Snafu;
 use tower::Service;
@@ -117,7 +117,7 @@ impl DatabendService {
             .current_database()
             .await
             .unwrap_or("default".to_string());
-        let suffix = thread_rng()
+        let suffix = rng()
             .sample_iter(&Alphanumeric)
             .take(8)
             .map(char::from)