feat: Enable Marten event store archived stream partitioning, event skipping, and quick append mode.

Author: aalmada

src/BookStore.ApiService/Infrastructure/Extensions/MartenConfigurationExtensions.cs

@@ -50,11 +50,16 @@ public static IServiceCollection AddMartenEventStore(
 
             // 50% improvement in throughput, less "event skipping"
             options.Events.AppendMode = EventAppendMode.Quick;
+            options.Events.UseArchivedStreamPartitioning = true;
 
             // These cause some database changes, so can't be defaults,
             // but these might help "heal" systems that have problems later
             options.Events.EnableAdvancedAsyncTracking = true;
 
+            // Enables you to mark events as just plain bad so they are skipped
+            // in projections from here on out.
+            options.Events.EnableEventSkippingInProjectionsOrSubscriptions = true;
+
             // This will optimize the usage of Inline projections, but will force
             // you to treat your aggregate projection "write models" as being
             // immutable in your command handler code
@@ -171,7 +176,6 @@ static void RegisterEventTypes(StoreOptions options)
         _ = options.Events.AddEventType<Events.PublisherAdded>();
         _ = options.Events.AddEventType<Events.PublisherUpdated>();
         _ = options.Events.AddEventType<Events.PublisherSoftDeleted>();
-        _ = options.Events.AddEventType<Events.PublisherSoftDeleted>();
         _ = options.Events.AddEventType<Events.PublisherRestored>();
 
         // User events

tests/BookStore.AppHost.Tests/AdminTenantTests.cs

@@ -2,6 +2,7 @@
 using BookStore.ApiService.Models;
 using BookStore.Client;
 using BookStore.Shared.Models;
+using JasperFx.Events;
 using Marten;
 using Refit;
 using Weasel.Core;
@@ -142,6 +143,11 @@ public async Task CreateTenant_WithEmailVerification_CreatesUnconfirmedUser()
             opts.Connection(connectionString!);
             opts.UseSystemTextJsonForSerialization(EnumStorage.AsString, Casing.CamelCase);
             _ = opts.Policies.AllDocumentsAreMultiTenanted();
+
+            opts.Events.AppendMode = EventAppendMode.Quick;
+            opts.Events.UseArchivedStreamPartitioning = true;
+            opts.Events.EnableEventSkippingInProjectionsOrSubscriptions = true;
+
             opts.Events.TenancyStyle = Marten.Storage.TenancyStyle.Conjoined;
         });
 

tests/BookStore.AppHost.Tests/GlobalSetup.cs

@@ -6,6 +6,7 @@
 using BookStore.Shared.Models;
 using JasperFx;
 using JasperFx.Core;
+using JasperFx.Events;
 using Marten;
 using Microsoft.Extensions.Logging;
 using Projects;
@@ -94,8 +95,11 @@ static async Task AuthenticateAdminAsync()
 
                    opts.Connection(connectionString);
                    _ = opts.Policies.AllDocumentsAreMultiTenanted();
-                   // Configure Multi-Tenancy (Conjoined)
-                   _ = opts.Policies.AllDocumentsAreMultiTenanted();
+
+                   opts.Events.AppendMode = EventAppendMode.Quick;
+                   opts.Events.UseArchivedStreamPartitioning = true;
+                   opts.Events.EnableEventSkippingInProjectionsOrSubscriptions = true;
+
                    opts.Events.MetadataConfig.CorrelationIdEnabled = true;
                    opts.Events.MetadataConfig.CausationIdEnabled = true;
                    opts.Events.MetadataConfig.HeadersEnabled = true;