refinements

Author: willg1983

Directory.Build.props

@@ -17,6 +17,7 @@
     <RepositoryType>git</RepositoryType>
     <PackageLicenseFile>LICENSE.md</PackageLicenseFile>
     <PackageReadmeFile>README.md</PackageReadmeFile>
+	<PackageIcon>icon.png</PackageIcon>
     <PackageTags>orleans;eventsourcing;kurrent;eventstore;eventstoredb;log-consistency</PackageTags>
     <PublishRepositoryUrl>true</PublishRepositoryUrl>
     <EmbedUntrackedSources>true</EmbedUntrackedSources>

LoadTest.Dashboard/LoadTest.Dashboard.csproj

@@ -0,0 +1,20 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Microsoft.Extensions.Hosting" />
+		<PackageReference Include="Microsoft.Orleans.Server" />
+		<PackageReference Include="Microsoft.Orleans.Dashboard" />
+	</ItemGroup>
+
+	<ItemGroup>
+	  <ProjectReference Include="..\src\Orleans.EventSourcing.Kurrent\Orleans.EventSourcing.Kurrent.csproj" />
+	</ItemGroup>
+	
+</Project>

LoadTest.Dashboard/Program.cs

@@ -0,0 +1,32 @@
+using KurrentDB.Client;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.Hosting;
+using Orleans.Dashboard;
+using Orleans.EventSourcing.Kurrent.Hosting;
+
+// Connection string for KurrentDB. The special host "kurrentemulator" selects the in-process,
+// in-memory Kurrent implementation so the load test runs without external infrastructure.
+// Point KURRENT_CONNECTION_STRING at a real KurrentDB instance to measure end-to-end performance.
+var connectionString = Environment.GetEnvironmentVariable("KURRENT_CONNECTION_STRING")
+                       ?? "esdb://localhost:2113?tls=false";
+
+var clientSettings = KurrentDBClientSettings.Create(connectionString);
+
+// Create a separate web application for the dashboard
+var dashboardBuilder = WebApplication.CreateBuilder(args);
+
+// Configure Orleans client
+dashboardBuilder.UseOrleansClient(clientBuilder =>
+{
+    clientBuilder.UseKurrentClustering(options => options.ClientSettings = clientSettings);
+        
+    // Add dashboard services to the client
+    clientBuilder.AddDashboard();
+});
+
+var dashboardApp = dashboardBuilder.Build();
+
+// Map dashboard endpoints on the client
+dashboardApp.MapOrleansDashboard();
+
+await dashboardApp.RunAsync();

Orleans.EventSourcing.Kurrent.slnx

@@ -17,8 +17,11 @@
     <Project Path="tests/Orleans.EventSourcing.Kurrent.Tests/Orleans.EventSourcing.Kurrent.Tests.csproj" />
   </Folder>
   <Folder Name="/samples/">
+    <Project Path="LoadTest.Dashboard/LoadTest.Dashboard.csproj" Id="732a0c1b-0c5a-4870-aa44-20219cbe65c7">
+      <Build Solution="Debug|*" Project="false" />
+    </Project>
+    <Project Path="samples/LoadTest.Client/LoadTest.Client.csproj" />
     <Project Path="samples/LoadTest.Grains/LoadTest.Grains.csproj" />
     <Project Path="samples/LoadTest.Silo/LoadTest.Silo.csproj" />
-    <Project Path="samples/LoadTest.Client/LoadTest.Client.csproj" />
   </Folder>
 </Solution>

README.md

@@ -76,10 +76,14 @@ builder.UseOrleansClient(client =>
 
 The storage extensions also have non-default overloads that take a provider `name` so you can register multiple instances side-by-side.
 
+To run KurrentDB locally (running **insecure** for testing only):
+```sh
+docker run --name kurrentdb-node -it -p 2113:2113 docker.kurrent.io/kurrent-latest/kurrentdb:latest --insecure
+```
+
 ## Using the clustering provider
 
-The clustering provider implements `IMembershipTable` as an event-sourced aggregate, which materialises a `MembershipView` by reading
-the events stored in the cluster's event stream.
+The clustering provider event-sources the orleans `IMembershipTable` and by writing membership events to the cluster's event stream.
 
 The stream contains `MembershipUpdate` events written by silos as they join or when their status or suspect list changes. Silos also update their `IAmAlive` value every 30 seconds by default; these are recorded as `SiloAlive` events.
 

icon.png

@@ -24,7 +24,7 @@
 // in-memory Kurrent implementation so the load test runs without external infrastructure.
 // Point KURRENT_CONNECTION_STRING at a real KurrentDB instance to measure end-to-end performance.
 var connectionString = Environment.GetEnvironmentVariable("KURRENT_CONNECTION_STRING")
-                       ?? "esdb://kurrentemulator:2113?tls=false";
+                       ?? "esdb://localhost:2113?tls=false";
 
 var builder = Host.CreateApplicationBuilder(args);
 builder.Logging.AddFilter("Orleans", LogLevel.Warning);

samples/LoadTest.Client/Program.cs

@@ -11,7 +11,7 @@
 // in-memory Kurrent implementation so the load test runs without external infrastructure.
 // Point KURRENT_CONNECTION_STRING at a real KurrentDB instance to measure end-to-end performance.
 var connectionString = Environment.GetEnvironmentVariable("KURRENT_CONNECTION_STRING")
-                       ?? "esdb://kurrentemulator:2113?tls=false";
+                       ?? "esdb://localhost:2113?tls=false";
 
 // GRAIN_SERIALIZER selects the event payload serializer for the log-consistency provider:
 //   "orleans" (default) — Orleans binary serializer
@@ -22,13 +22,14 @@
 
 var clientSettings = KurrentDBClientSettings.Create(connectionString);
 
-var builder = WebApplication.CreateBuilder(args);
+var builder = Host.CreateApplicationBuilder(args);
 
 builder.Logging.AddFilter("Orleans", LogLevel.Warning);
 builder.Logging.AddFilter("Microsoft", LogLevel.Warning);
 
 builder.UseOrleans(silo =>
 {
+    silo.ConfigureEndpoints(Random.Shared.Next(29170, 29998), Random.Shared.Next(29170, 29998));
     silo.AddDashboard();
     silo.UseKurrentClustering(o => { o.ClientSettings = clientSettings; o.EventCountBeforeSnapshot = 5; });
     //silo.UseLocalhostClustering();
@@ -45,8 +46,6 @@
 
 var host = builder.Build();
 
-host.MapOrleansDashboard();
-
 Console.WriteLine($"LoadTest silo starting (Kurrent: {connectionString}, serializer: {serializerName})...");
 await host.StartAsync();
 Console.WriteLine("LoadTest silo is running. Press Ctrl+C to shut down.");