update test payload in iggy-bench to json-like logs for compression

Author: haubur

Cargo.lock

@@ -481,9 +481,8 @@ logos-codegen: 0.15.1, "Apache-2.0 OR MIT",
 logos-derive: 0.15.1, "Apache-2.0 OR MIT",
 lru-slab: 0.1.2, "Apache-2.0 OR MIT OR Zlib",
 lz4_flex: 0.11.5, "MIT",
-lzma-rust2: 0.15.4, "Apache-2.0",
 lz4_flex: 0.12.0, "MIT",
-lzma-rust2: 0.13.0, "Apache-2.0",
+lzma-rust2: 0.15.4, "Apache-2.0",
 macro_rules_attribute: 0.1.3, "MIT",
 macro_rules_attribute-proc_macro: 0.1.3, "MIT",
 matchers: 0.2.0, "MIT",

DEPENDENCIES.md

@@ -47,7 +47,6 @@ human-repr = { workspace = true }
 iggy = { workspace = true }
 integration = { workspace = true }
 nonzero_lit = { workspace = true }
-rand = { workspace = true }
 rayon = "1.11.0"
 serde = { workspace = true }
 sysinfo = { workspace = true }

core/bench/Cargo.toml

@@ -41,14 +41,20 @@ impl BenchmarkBatchGenerator {
         let max_len = message_size.max() as usize;
         let is_fixed = message_size.is_fixed() && messages_per_batch.is_fixed();
 
-        let template = r#"{"name": "example messasge payload", "description": "simulating realistic compressible data", "user": "test-user", "id": 42, "trace_id": "812Fr%210"}"#;
-        let payload_bytes = template
-            .as_bytes()
-            .iter()
-            .cycle()
-            .take(max_len)
-            .copied()
-            .collect();
+        let mut buf = Vec::with_capacity(max_len);
+        let mut i = 0;
+        while buf.len() < max_len {
+            buf.extend_from_slice(
+                format!(
+                    r#"{{"ts": "2000-01-{:02}T{:02}:{:02}:{:02}Z", "level": "info", "trace":{}, "command": "command-{}", "status": 200, "latency_ms": {}}}"#,
+                    i % 28, i % 24, i % 60, i % 60, i, i % 1000, i % 120
+                )
+                .as_bytes(),
+            );
+            i += 1;
+        }
+        buf.truncate(max_len);
+        let payload_bytes: Bytes = Bytes::from(buf);
 
         let mut batch_generator = Self {
             message_size,

core/bench/src/utils/batch_generator.rs

@@ -56,8 +56,8 @@ figment = { workspace = true }
 flate2 = { workspace = true }
 human-repr = { workspace = true }
 humantime = { workspace = true }
-nix = { workspace = true }
 lz4_flex = { workspace = true }
+nix = { workspace = true }
 once_cell = { workspace = true }
 rcgen = "0.14.6"
 ring = "0.17.14"