From 769b26e09926d5f3a838956ac481e32915057b22 Mon Sep 17 00:00:00 2001 From: Riccardo Busetti Date: Wed, 16 Oct 2024 10:01:59 +0200 Subject: [PATCH] Fix --- relay-server/src/services/buffer/envelope_store/file_backed.rs | 2 +- relay-server/src/statsd.rs | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/relay-server/src/services/buffer/envelope_store/file_backed.rs b/relay-server/src/services/buffer/envelope_store/file_backed.rs index 41b892aafa..e37f087ff8 100644 --- a/relay-server/src/services/buffer/envelope_store/file_backed.rs +++ b/relay-server/src/services/buffer/envelope_store/file_backed.rs @@ -548,7 +548,7 @@ mod tests { store.remove_file(&project_key_pair).await.unwrap(); // Verify the file no longer exists in cache or on disk - assert!(!store.files_cache.cache.get_mut(&project_key_pair).is_some()); + assert!(store.files_cache.cache.get_mut(&project_key_pair).is_none()); assert!(!file_path.exists()); // Removing a non-existent file should not error diff --git a/relay-server/src/statsd.rs b/relay-server/src/statsd.rs index 25d3840279..46c7bf1a48 100644 --- a/relay-server/src/statsd.rs +++ b/relay-server/src/statsd.rs @@ -596,6 +596,9 @@ impl TimerMetric for RelayTimers { RelayTimers::BufferPop => "buffer.pop.duration", RelayTimers::BufferDrain => "buffer.drain.duration", RelayTimers::BufferEnvelopesSerialization => "buffer.envelopes_serialization", + RelayTimers::BufferEnvelopeSerialization => "buffer.envelope_serialization", + RelayTimers::BufferEnvelopeFileWriting => "buffer.envelope_file_writing", + RelayTimers::BufferTotalCountReading => "buffer.total_count_reading", } } }