feat(spooler): Add initialization of stacks

CHANGELOG.md

@@ -19,6 +19,7 @@
 - Add `EnvelopeStore` trait and implement `DiskUsage` for tracking disk usage. ([#3925](https://github.com/getsentry/relay/pull/3925))
 - Increase replay recording limit to two hours. ([#3961](https://github.com/getsentry/relay/pull/3961))
 - Make EnvelopeBuffer a Service. ([#3965](https://github.com/getsentry/relay/pull/3965))
+- Add initialization of the `EnvelopeBuffer`. ([#3967](https://github.com/getsentry/relay/pull/3967))
 
 **Internal**:
 

relay-server/benches/benches.rs

@@ -259,7 +259,9 @@ fn benchmark_envelope_buffer(c: &mut Criterion) {
             |envelopes| {
                 runtime.block_on(async {
                     let mut buffer =
-                        PolymorphicEnvelopeBuffer::from_config(&config, memory_checker.clone());
+                        PolymorphicEnvelopeBuffer::from_config(&config, memory_checker.clone())
+                            .await
+                            .unwrap();
                     for envelope in envelopes.into_iter() {
                         buffer.push(envelope).await.unwrap();
                     }
@@ -289,7 +291,9 @@ fn benchmark_envelope_buffer(c: &mut Criterion) {
             |envelopes| {
                 runtime.block_on(async {
                     let mut buffer =
-                        PolymorphicEnvelopeBuffer::from_config(&config, memory_checker.clone());
+                        PolymorphicEnvelopeBuffer::from_config(&config, memory_checker.clone())
+                            .await
+                            .unwrap();
                     let n = envelopes.len();
                     for envelope in envelopes.into_iter() {
                         let public_key = envelope.meta().public_key();

relay-server/src/service.rs

@@ -241,7 +241,7 @@ impl ServiceState {
         .spawn_handler(processor_rx);
 
         let envelope_buffer = EnvelopeBufferService::new(
-            &config,
+            config.clone(),
             MemoryChecker::new(memory_stat.clone(), config.clone()),
             project_cache.clone(),
         )