Merge pull request #748 from dolittle/9.0.0-hadhafang

9.0.0 Release

.github/workflows/benchmarks.yml

@@ -18,7 +18,6 @@ jobs:
           - 'Events.Store.Streams.StreamProcessorStateRepository'
           - 'Events.Processing.EventHandlers.EventHandler'
           - 'Events.Processing.EventHandlers.FastEventHandler'
-#          - 'Events.Processing.EventHandlers.FastEventHandlerWithImplicitFilter'
           - 'Events.Processing.EventHandlers.Filter'
           - 'Events.Processing.Projections.Projection'
     env:

.github/workflows/release.yml

@@ -1,7 +1,7 @@
 name: Release
 
 env:
-  PRERELEASE_BRANCHES: bad-aggregate
+  PRERELEASE_BRANCHES: hadhafang
 
 on:
   pull_request:
@@ -62,10 +62,8 @@ jobs:
           - 'Events.Store.FetchAggregateEvents'
           - 'Events.Store.Streams.StreamProcessorStateRepository'
           - 'Events.Processing.EventHandlers.EventHandler'
-          - 'Events.Processing.EventHandlers.FastEventHandler'
-#          - 'Events.Processing.EventHandlers.FastEventHandlerWithImplicitFilter'
           - 'Events.Processing.EventHandlers.Filter'
-          - 'Events.Processing.Projections.Projection'
+          - 'Events.Processing.Projections'
     env: 
       BENCHMARK_NAME: Integration.Benchmarks.${{ matrix.benchmark }}
     steps:

Configurations/consumer/.dolittle/runtime.yml

@@ -0,0 +1,48 @@
+opentelemetry:
+  serviceName: "Consumer-Runtime"
+endpoints: 
+  private:
+    port: 5055
+  public:
+    port: 5054
+  management:
+    port: 5252
+  managementweb:
+    port: 5452
+  metrics:
+    port: 9701
+  web:
+    port: 8009
+platform:
+  applicationName: "EventHorizon Tutorial"
+  applicationID: "5bd8762f-6c39-4ba2-a141-d041c8668894"
+  microserviceName: "Consumer"
+  microserviceID: "a14bb24e-51f3-4d83-9eba-44c4cffe6bb9"
+  customerName: "Dolittle Tacos"
+  customerID: "c2d49e3e-9bd4-4e54-9e13-3ea4e04d8230"
+  environment: "Tutorial"
+microservices:
+  f39b1f61-d360-4675-b859-53c05c87c0e6:
+    host: localhost
+    port: 5052
+tenants:
+  445f8ea8-1a6f-40d7-b2fc-796dba92dc44:
+    resources:
+      eventStore:
+        servers:
+        - localhost
+        database: "consumer_event_store"
+      projections:
+        servers:
+        - localhost
+        database: "consumer_projections"
+        maxConnectionPoolSize: 1000
+      embeddings:
+        servers:
+        - localhost
+        database: "consumer_embeddings"
+        maxConnectionPoolSize: 1000
+      readModels:
+        host: "mongodb://localhost:27017"
+        database: "consumer_readmodels"
+        useSSL: false

Configurations/producer/.dolittle/runtime.yml

@@ -0,0 +1,47 @@
+opentelemetry:
+  serviceName: "Producer-Runtime"
+endpoints:
+  private:
+    port: 5053
+  public:
+    port: 5052
+  management:
+    port: 5152
+  managementweb:
+    port: 5352
+platform:
+  applicationName: "EventHorizon Tutorial"
+  applicationID: "5bd8762f-6c39-4ba2-a141-d041c8668894"
+  microserviceName: "Producer"
+  microserviceID: "f39b1f61-d360-4675-b859-53c05c87c0e6"
+  customerName: "Dolittle Tacos"
+  customerID: "c2d49e3e-9bd4-4e54-9e13-3ea4e04d8230"
+  environment: "Tutorial"
+tenants:
+  445f8ea8-1a6f-40d7-b2fc-796dba92dc44:
+    resources:
+      eventStore:
+        servers:
+        - localhost
+        database: "producer_event_store"
+      projections:
+        servers:
+        - localhost
+        database: "producer_projections"
+        maxConnectionPoolSize: 1000
+      embeddings:
+        servers:
+        - localhost
+        database: "producer_embeddings"
+        maxConnectionPoolSize: 1000
+      readModels:
+        host: "mongodb://localhost:27017"
+        database: "producer_readmodels"
+        useSSL: false
+    eventHorizons:
+      a14bb24e-51f3-4d83-9eba-44c4cffe6bb9:
+        consents:
+        - consumerTenant: "445f8ea8-1a6f-40d7-b2fc-796dba92dc44"
+          stream: "2c087657-b318-40b1-ae92-a400de44e507"
+          partition: "Dolittle Tacos"
+          consent: "ad57aa2b-e641-4251-b800-dd171e175d1f"

Integration/Benchmarks/Events.Processing/EventHandlers/EventHandler.cs

@@ -11,11 +11,9 @@
 using Dolittle.Runtime.Events.Processing.Contracts;
 using Dolittle.Runtime.Events.Processing.EventHandlers;
 using Dolittle.Runtime.Events.Store;
-using Integration.Benchmarks.Events.Store;
 using Integration.Shared;
 using Microsoft.Extensions.DependencyInjection;
 using Moq;
-using ExecutionContext = Dolittle.Runtime.Execution.ExecutionContext;
 using ReverseCallDispatcher = Dolittle.Runtime.Services.IReverseCallDispatcher<
     Dolittle.Runtime.Events.Processing.Contracts.EventHandlerClientToRuntimeMessage,
     Dolittle.Runtime.Events.Processing.Contracts.EventHandlerRuntimeToClientMessage,
@@ -88,7 +86,7 @@ public void IterationSetup()
 
         var eventHandlers = new List<IEventHandler>();
         eventHandlers.AddRange(Enumerable.Range(0, EventHandlers).Select(_ => _eventHandlerFactory.Create(
-            new EventHandlerRegistrationArguments(Runtime.CreateExecutionContextFor("d9fd643f-ce74-4ae5-b706-b76859fd8827"), Guid.NewGuid(), _eventTypes, Partitioned, ScopeId.Default),
+            new EventHandlerRegistrationArguments(Runtime.CreateExecutionContextFor("d9fd643f-ce74-4ae5-b706-b76859fd8827"), Guid.NewGuid(), _eventTypes, Partitioned, ScopeId.Default, Concurrency),
             _dispatcher.Object,
             CancellationToken.None)));
         _eventHandlersToRun = eventHandlers;
@@ -125,6 +123,10 @@ public void IterationCleanup()
     // [Params(1, 10)] TODO: We can maybe enable this in the future, but as of now it seems that the performance depends on the amount of events processed.
     public int EventTypes { get; set; } = 1;
 
+
+    [Params(1, 20)]
+    public int Concurrency { get; set; } = 1;
+
     /// <summary>
     /// Gets the number of events committed per configured event type.
     /// </summary>