test(replays): jemalloc and serde struct deserialization

Dockerfile

@@ -4,7 +4,7 @@ ARG DOCKER_ARCH=amd64
 ### Deps stage ###
 ##################
 
-FROM getsentry/sentry-cli:1 AS sentry-cli
+FROM getsentry/sentry-cli:2 AS sentry-cli
 FROM $DOCKER_ARCH/centos:7 AS relay-deps
 
 ARG DOCKER_ARCH
@@ -47,6 +47,7 @@ FROM relay-deps AS relay-builder
 
 ARG RELAY_FEATURES=ssl,processing,crash-handler
 ENV RELAY_FEATURES=${RELAY_FEATURES}
+ENV JEMALLOC_SYS_WITH_MALLOC_CONF=background_thread:true,abort_conf:true
 
 COPY . .
 

relay-replays/Cargo.toml

@@ -10,18 +10,16 @@ license-file = "../LICENSE"
 publish = false
 
 [dependencies]
-flate2 = "1.0.19"
-once_cell = "1.13.1"
-rand = "0.8.5"
-rand_pcg = "0.3.1"
 relay-common = { path = "../relay-common" }
-relay-filter = { path = "../relay-filter" }
 relay-general = { path = "../relay-general" }
 relay-log = { path = "../relay-log" }
 serde = { version = "1.0.114", features = ["derive"] }
 serde_json = "1.0.55"
-serde-transcode = "1.1.1"
+relay-filter = { path = "../relay-filter" }
+rand = "0.8.5"
+rand_pcg = "0.3.1"
 unicase = "2.6.0"
+flate2 = "1.0.19"
 
 [dev-dependencies]
 criterion = "0.4"

relay-replays/benches/benchmarks.rs

@@ -1,34 +1,12 @@
-use std::io::Read;
-
 use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion};
-use flate2::{bufread::ZlibEncoder, Compression};
 
-use relay_general::pii::DataScrubbingConfig;
-use relay_replays::recording::ReplayScrubber;
+use relay_replays::recording::_deserialize_event;
 
 fn bench_recording(c: &mut Criterion) {
     let payload = include_bytes!("../tests/fixtures/rrweb.json");
 
-    // Compress the payload to mimic real-world behavior. The replay processor can also handle
-    // uncompressed payloads, but those happen infrequently.
-    let mut compressed = Vec::new();
-    let mut encoder = ZlibEncoder::new(payload.as_slice(), Compression::default());
-    encoder.read_to_end(&mut compressed).unwrap();
-
-    let mut scrubbing_config = DataScrubbingConfig::default();
-    scrubbing_config.scrub_data = true;
-    scrubbing_config.scrub_defaults = true;
-    scrubbing_config.scrub_ip_addresses = true;
-    let pii_config = scrubbing_config.pii_config_uncached().unwrap().unwrap();
-
-    let mut scrubber = ReplayScrubber::new(usize::MAX, Some(&pii_config), None);
-
-    c.bench_with_input(BenchmarkId::new("rrweb", 1), &compressed, |b, &_| {
-        b.iter(|| {
-            let mut buf = Vec::new();
-            scrubber.transcode_replay(&compressed, &mut buf).ok();
-            buf
-        });
+    c.bench_with_input(BenchmarkId::new("rrweb", 1), &payload, |b, &_| {
+        b.iter(|| _deserialize_event(payload));
     });
 }
 

relay-replays/src/lib.rs

@@ -1,2 +1 @@
 pub mod recording;
-mod transform;