Read MongoDB member endpoints and expect server-ordered link payloads

The benchmark host read published endpoints only for HTTP targets, so the
MongoDB member address map received an empty list and both MongoDB cells
failed while creating the session. The host now reads the TCP endpoints
Aspire publishes for each MongoDB member.

The integration link golden sorted keys ordinally, while the server writes
a derived queue-graph link as from, to, label and attributes and keeps a
caller's own payload text. The golden now builds the server's field order
without serializing the production link type.

Verification: solution build with -warnaserror, dotnet format verify and the
governance check pass. FunctionalDatabaseGateTests, which commits documents,
vectors, text, events, a queue message, a topic, a graph edge and time-series
samples in one command and reads them back through SDK, MCP and SQL, passes
locally for one node (6m 51s) and a three-node cluster (9m 50s).

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

Author: KSemenenko

benchmarks/KeyLoad.ComparisonHost/Configuration/IsolatedHostConstants.cs

@@ -26,6 +26,7 @@ internal static class IsolatedHostConstants
     internal const string HelixDb = "HelixDB";
     internal const string Http = "http";
     internal const string Https = "https";
+    internal const string Tcp = "tcp";
     internal const string RootPath = "/";
     internal const string Basic = "Basic";
     internal const string CredentialSeparator = ":";

benchmarks/KeyLoad.ComparisonHost/Configuration/RuntimeIsolatedHostSettings.cs

@@ -23,7 +23,8 @@ or IsolatedHostConstants.Mongo or IsolatedHostConstants.Kurrent
         var endpoints = target is IsolatedHostConstants.KeyLoad or IsolatedHostConstants.Qdrant or IsolatedHostConstants.Rabbit
             or IsolatedHostConstants.Neo4j or IsolatedHostConstants.OpenSearch or IsolatedHostConstants.Kurrent
             or IsolatedHostConstants.SurrealDb or IsolatedHostConstants.HelixDb
-            ? ReadEndpoints(configuration, selection.NodeCount) : ImmutableArray<Uri>.Empty;
+            ? ReadEndpoints(configuration, selection.NodeCount, tcp: false)
+            : target == IsolatedHostConstants.Mongo ? ReadEndpoints(configuration, selection.NodeCount, tcp: true) : ImmutableArray<Uri>.Empty;
         var replicas = target == IsolatedHostConstants.Redis
             ? ReadArray(configuration, IsolatedHostConstants.ReplicaConnections, selection.NodeCount - PrimaryReplicaCount) : ImmutableArray<string>.Empty;
         var authenticated = target is IsolatedHostConstants.Rabbit or IsolatedHostConstants.Neo4j or IsolatedHostConstants.SurrealDb;
@@ -39,7 +40,8 @@ or IsolatedHostConstants.SurrealDb or IsolatedHostConstants.HelixDb
         return new(image, connection, endpoints, replicas, user, password, apiKey, admin);
     }
 
-    private static ImmutableArray<Uri> ReadEndpoints(IConfiguration configuration, int count)
+    // MongoDB members publish raw TCP endpoints; every other endpoint-bound target is an HTTP(S) origin.
+    private static ImmutableArray<Uri> ReadEndpoints(IConfiguration configuration, int count, bool tcp)
     {
         const int EmptyUserInfoLength = 0;
         const int EmptyQueryLength = 0;
@@ -50,7 +52,8 @@ private static ImmutableArray<Uri> ReadEndpoints(IConfiguration configuration, i
         foreach (var value in values)
         {
             if (!Uri.TryCreate(value, UriKind.Absolute, out var endpoint)
-                || endpoint.Scheme is not (IsolatedHostConstants.Http or IsolatedHostConstants.Https)
+                || (tcp ? endpoint.Scheme != IsolatedHostConstants.Tcp
+                    : endpoint.Scheme is not (IsolatedHostConstants.Http or IsolatedHostConstants.Https))
                 || string.IsNullOrWhiteSpace(endpoint.Host) || endpoint.UserInfo.Length != EmptyUserInfoLength
                 || endpoint.Query.Length != EmptyQueryLength || endpoint.Fragment.Length != EmptyFragmentLength || endpoint.AbsolutePath != IsolatedHostConstants.RootPath)
             {

tests/KeyLoad.IntegrationTests/DatabaseComposition/Assertions/DatabaseCompositionClusterPayload.cs

@@ -1,8 +1,33 @@
+using System.Text.Json;
+
 namespace KeyLoad.IntegrationTests.DatabaseComposition;
 
-/// <summary>Independent ordinal-key golden for every public field of the Orleans link fixture.</summary>
+/// <summary>Independent golden for every public field of a queue graph link, in the field order the server writes.</summary>
+/// <remarks>The server serializes a derived link as from, to, label and attributes, and preserves a caller's own
+/// payload text exactly; this literal shape is built without serializing the production link type.</remarks>
 internal static class DatabaseCompositionClusterPayload
 {
-    internal static string OrdinalGolden(QueueGraphLink link)
-        => FunctionalGateBoundJson.Serialize(link);
+    internal static string Golden(QueueGraphLink link)
+        => JsonSerializer.Serialize(new
+        {
+            from = Reference(link.From),
+            to = Reference(link.To),
+            label = link.Label,
+            attributesJson = link.AttributesJson
+        }, JsonDefaults.Options);
+
+    private static object Reference(EntityRef reference)
+    {
+        var partition = new
+        {
+            tenantId = reference.Partition.TenantId,
+            databaseId = reference.Partition.DatabaseId,
+            transactionDomainId = reference.Partition.TransactionDomainId,
+            partitionKey = reference.Partition.PartitionKey,
+            atomicPartitionId = reference.Partition.AtomicPartitionId
+        };
+        return reference.Lifetime is { } lifetime
+            ? (object)new { partition, collection = reference.Collection, id = reference.Id, lifetime = new { incarnation = lifetime.Incarnation } }
+            : new { partition, collection = reference.Collection, id = reference.Id };
+    }
 }

tests/KeyLoad.IntegrationTests/DatabaseComposition/Assertions/Links/DeclarativeReverseQuotaAssertions.cs

@@ -76,7 +76,7 @@ private static async Task MessageAsync(RequestCqrsClusterCallers callers, Declar
         }
         var link = new QueueGraphLink(state.Scenario.First, state.Scenario.Second, RelationalSqlClusterTokens.EdgeLabel);
         var expected = new MessageInspection(new MessageMetadata(id, MessageState.Ready, NoAttempts,
-            InitialVersion, sequence, null, null), DatabaseCompositionClusterPayload.OrdinalGolden(link), Headers);
+            InitialVersion, sequence, null, null), DatabaseCompositionClusterPayload.Golden(link), Headers);
         await SqlClusterProtocol.EqualAsync(expected, actual);
         await SqlClusterProtocol.EqualAsync(expected, official);
     }

tests/KeyLoad.IntegrationTests/DatabaseComposition/Assertions/Links/TypedEndpointJoinReverseAssertions.cs

@@ -91,7 +91,7 @@ private static async Task MessageAsync(RequestCqrsClusterCallers admin, TypedEnd
             TypedEndpointJoinProtocol.To(state.Seed.Partition), TypedEndpointJoinProtocol.Label, TypedEndpointJoinProtocol.Attributes);
         var expected = new MessageInspection(new MessageMetadata(id, MessageState.Ready, NoAttempts,
             InitialVersion, sequence, null, null),
-            DatabaseCompositionClusterPayload.OrdinalGolden(link), TypedEndpointJoinProtocol.Attributes);
+            DatabaseCompositionClusterPayload.Golden(link), TypedEndpointJoinProtocol.Attributes);
         await SqlClusterProtocol.EqualAsync(expected, actual);
         await SqlClusterProtocol.EqualAsync(expected, official);
     }

tests/KeyLoad.IntegrationTests/DatabaseComposition/Assertions/Sql/CompositionSqlColdAssertions.cs

@@ -22,7 +22,7 @@ internal static async Task OriginalAsync(RequestCqrsClusterCallers callers, Comp
         await Assert.That(actual.Derived.Metadata.State).IsEqualTo(MessageState.Ready);
         await Assert.That(actual.Derived.Metadata.Attempts).IsEqualTo(RelationalSqlClusterTokens.NoResults);
         await Assert.That(actual.Derived.Metadata.LeaseOwner).IsNull();
-        await Assert.That(actual.Source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.OrdinalGolden(state.Link));
+        await Assert.That(actual.Source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.Golden(state.Link));
         var traversal = new TraverseRequest(state.Scenario.Partition, RelationalSqlClusterTokens.Graph, state.Scenario.First);
         await SqlClusterProtocol.EqualAsync(state.Graph, (await McpCallerAssertions.SuccessAsync<global::KeyLoad.GraphTraversal>(
             await callers.Mcp.CallAsync(McpCallerTools.GraphTraverse, traversal, token))).Value);

tests/KeyLoad.IntegrationTests/DatabaseComposition/Assertions/TypedEndpoints/TypedEndpointJoinAssertions.cs

@@ -75,7 +75,7 @@ internal static async Task LiteralAsync(TypedEndpointJoinModels models, Partitio
             };
             var link = new QueueGraphLink(new(partition, TypedEndpointJoinProtocol.FromCollection, fromId),
                 TypedEndpointJoinProtocol.To(partition), TypedEndpointJoinProtocol.Label, TypedEndpointJoinProtocol.Attributes);
-            await Assert.That(source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.OrdinalGolden(link));
+            await Assert.That(source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.Golden(link));
         }
         var from = TypedEndpointJoinProtocol.From(partition);
         var to = TypedEndpointJoinProtocol.To(partition);
@@ -152,7 +152,7 @@ private static async Task MalformedSourceAsync(TypedEndpointJoinModels models, P
         await Assert.That(actual.Metadata.SafeFailureCode).IsNull();
         await Assert.That(actual.HeadersJson).IsEqualTo(TypedEndpointJoinProtocol.Attributes);
         var to = TypedEndpointJoinProtocol.To(partition);
-        await Assert.That(actual.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.OrdinalGolden(
+        await Assert.That(actual.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.Golden(
             new QueueGraphLink(to, to, TypedEndpointJoinProtocol.Label, TypedEndpointJoinProtocol.Attributes)));
     }
 }

tests/KeyLoad.IntegrationTests/DatabaseComposition/Cases/Database/DatabaseCompositionClusterTests.cs

@@ -95,7 +95,7 @@ await SqlClusterProtocol.EqualAsync(graph, await SqlClusterProtocol.McpAsync<glo
         var source = await PublicReadAssertions.MessageAsync(await sdk.InspectAsync(scenario.Inspect(Message), cancellationToken));
         await Assert.That(source!.Metadata.State).IsEqualTo(MessageState.Ready);
         await Assert.That(source.Metadata.Attempts).IsEqualTo(RelationalSqlClusterTokens.NoResults);
-        await Assert.That(source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.OrdinalGolden(link));
+        await Assert.That(source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.Golden(link));
         await Assert.That(JsonSerializer.Deserialize<QueueGraphLink>(source.PayloadJson!, JsonDefaults.Options)).IsEqualTo(link);
     }
 

tests/KeyLoad.IntegrationTests/DatabaseComposition/Cases/DeclarativeComposition/DeclarativeCompositionClusterTests.cs

@@ -126,7 +126,7 @@ await SqlClusterProtocol.EqualAsync(graph, await SqlClusterProtocol.McpAsync<glo
         var source = await PublicReadAssertions.MessageAsync(await sdk.InspectAsync(scenario.Inspect(Message), cancellationToken));
         await Assert.That(source!.Metadata.State).IsEqualTo(MessageState.Ready);
         await Assert.That(source.Metadata.Attempts).IsEqualTo(RelationalSqlClusterTokens.NoResults);
-        await Assert.That(source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.OrdinalGolden(link));
+        await Assert.That(source.PayloadJson).IsEqualTo(DatabaseCompositionClusterPayload.Golden(link));
         await Assert.That(JsonSerializer.Deserialize<QueueGraphLink>(source.PayloadJson!, JsonDefaults.Options)).IsEqualTo(link);
     }
 

tests/KeyLoad.IntegrationTests/DatabaseComposition/Scenarios/FunctionalGates/Queues/FunctionalGateQueueGraph.cs

@@ -17,7 +17,7 @@ internal static async Task RunAsync(FunctionalGateContext ctx, CancellationToken
         var returnedId = returnPrefix + edgeId;
         var source = new QueueLaneRef(ctx.Partition, FunctionalGateQueues.Queue(P.SourceQueue));
         var target = new QueueLaneRef(ctx.Partition, FunctionalGateQueues.Queue(P.TargetQueue));
-        var payload = DatabaseCompositionClusterPayload.OrdinalGolden(link);
+        var payload = DatabaseCompositionClusterPayload.Golden(link);
         await SeedAsync(ctx, link, source, sourceId, payload, token);
         var original = await FunctionalGateQueueGraphQueue.ReadyAsync(ctx, source, sourceId, payload, token);
         await ForwardAsync(ctx, source, edgePrefix, edgeId, token);