Checkpoint concurrent telemetry capture updates

Include all current working-tree changes produced during the preceding full-scope commit and push. Full solution and Aspire acceptance remain unverified; the last complete solution build failed.

Author: KSemenenko

tests/KeyLoad.IntegrationTests/Features/ClusterReplication/Helpers/ClusterFixtureDiagnostics.cs

@@ -188,7 +188,7 @@ private async Task<string> ReadDiscoveryAsync(string name, ReadOnlyMemory<byte>
         {
             using var deadline = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
             deadline.CancelAfter(DiagnosticRequestTimeout);
-            using var security = new PeerSecurity(peerSecret, TimeProvider.System);
+            using var security = new PeerSecurity(peerSecret, TimeProvider.System, IntegrationRoutingOptions.Discovery());
             using var http = new HttpClient(security.CreateHandler())
             { Timeout = Timeout.InfiniteTimeSpan };
             using var request = new HttpRequestMessage(HttpMethod.Get,

tests/KeyLoad.IntegrationTests/Features/ClusterRouting/Helpers/PhysicalShardCatalogInterface34DeniedWriteOracle.cs

@@ -27,9 +27,7 @@ private static async Task VerifyNodeAsync(string dataRoot, NodeEpochRf3Profile p
     {
         var nodeRoot = Path.Combine(dataRoot, node);
         var options = NodeEpochRf3OfflineOptions.Create(nodeRoot, profile, node);
-        await using var host = new PartitionHost(options, new AuthorizationPolicy(),
-            new CommandAdmissionGovernor(options.CommandAdmission), TimeProvider.System,
-            NullLogger<ReplicaConsensus>.Instance);
+        await using var host = new PartitionHost(ServerRuntimeTestOptions.Runtime(options), new AuthorizationPolicy(),             new CommandAdmissionGovernor(IntegrationAdmissionOptions.Command(options.CommandAdmission)), TimeProvider.System,             NullLogger<ReplicaConsensus>.Instance);
         cancellationToken.ThrowIfCancellationRequested();
         if (host.Database.GetDocument(PartitionStoreProtocol.AdministratorId, reference) is not null)
         { throw new InvalidOperationException(InvalidStore); }

tests/KeyLoad.IntegrationTests/Features/ClusterRouting/Helpers/PhysicalShardCatalogStoppedOracle.cs

@@ -23,9 +23,7 @@ internal static async Task VerifyAsync(string dataRoot, NodeEpochRf3Profile prof
             var nodeRoot = Path.Combine(dataRoot, node);
             var options = NodeEpochRf3OfflineOptions.Create(nodeRoot, profile, node);
             var configured = options.CreateReplicaConfiguration(Path.GetFullPath(nodeRoot));
-            await using var host = new PartitionHost(options, new AuthorizationPolicy(),
-                new CommandAdmissionGovernor(options.CommandAdmission), TimeProvider.System,
-                NullLogger<ReplicaConsensus>.Instance);
+            await using var host = new PartitionHost(ServerRuntimeTestOptions.Runtime(options), new AuthorizationPolicy(),                 new CommandAdmissionGovernor(IntegrationAdmissionOptions.Command(options.CommandAdmission)), TimeProvider.System,                 NullLogger<ReplicaConsensus>.Instance);
             var catalog = host.Database.ReadPhysicalShardCatalog(PartitionStoreProtocol.AdministratorId);
             await Assert.That(catalog.Version).IsEqualTo(CurrentCatalogVersion);
             await Assert.That(catalog.Revision).IsEqualTo(InitialCatalogRevision);

tests/KeyLoad.IntegrationTests/Features/ClusterRouting/Helpers/RequestCqrsRf3SignedDiscovery.cs

@@ -39,7 +39,7 @@ internal static async Task<ReplicaSiloDiscovery> ReadForProfileAsync(Distributed
     private static async Task<ReplicaSiloDiscovery> ReadOwnedAsync(DistributedApplication app, string nodeName,
         Guid incarnation, ReadOnlyMemory<byte> credential, CancellationToken cancellationToken)
     {
-        using var signer = new PeerSecurity(credential, TimeProvider.System);
+        using var signer = new PeerSecurity(credential, TimeProvider.System, IntegrationRoutingOptions.Discovery());
         using var http = McpCallerHttp.Create(app, nodeName);
         using var request = new HttpRequestMessage(HttpMethod.Get,
             new Uri(http.BaseAddress ?? throw new InvalidOperationException(InvalidSignedObservation), DiscoveryPath));

tests/KeyLoad.IntegrationTests/Features/ClusterRouting/Helpers/TwoRf3MembershipSignedDiscovery.cs

@@ -15,7 +15,7 @@ internal static class TwoRf3MembershipSignedDiscovery
     internal static async Task<ReplicaSiloDiscovery> ReadAsync(DistributedApplication app, string node,
         string clusterId, Guid incarnation, ReadOnlyMemory<byte> secret, CancellationToken token)
     {
-        using var security = new PeerSecurity(secret, TimeProvider.System);
+        using var security = new PeerSecurity(secret, TimeProvider.System, IntegrationRoutingOptions.Discovery());
         using var http = McpCallerHttp.Create(app, node);
         using var request = new HttpRequestMessage(HttpMethod.Get,
             new Uri(http.BaseAddress ?? throw new InvalidOperationException(Invalid), ReplicaProtocol.DiscoveryPath));

tests/KeyLoad.UnitTests/Features/BlobStorage/Cases/BlobAdmissionTests.cs

@@ -15,7 +15,7 @@ internal sealed class BlobAdmissionTests
     [Test]
     public async Task AcBlob004CleanupUsesTwoBoundedControlReservationsDuringDataSaturation()
     {
-        var governor = new HttpAdmissionGovernor(Limits());
+        var governor = new HttpAdmissionGovernor(UnitAdmissionOptions.Http(Limits()));
         using var data = Begin(governor, BlobAgentCases.PartRoute, 0);
         data.Bind(Principal);
         using var abort = Begin(governor, BlobAgentCases.AbortRoute, ControlBodyLimit);
@@ -39,7 +39,7 @@ await Assert.That(Assert.ThrowsExactly<KeyLoadException>(() => Begin(governor, B
     [Test]
     public async Task AcBlob004OnlyAbortAndReclaimUseTheBoundedCleanupLane()
     {
-        var governor = new HttpAdmissionGovernor(Limits());
+        var governor = new HttpAdmissionGovernor(UnitAdmissionOptions.Http(Limits()));
         foreach (var item in BlobAgentCases.All().Where(item => item.CommandKind.HasValue))
         {
             var cleanup = item.Name is BlobAgentCases.Abort or BlobAgentCases.Reclaim;

tests/KeyLoad.UnitTests/Features/BlobStorage/Cases/BlobGrainRoutingTests.cs

@@ -15,7 +15,7 @@ internal sealed class BlobGrainRoutingTests
     public async Task AcBlob006FreshSignedActorsPreserveEachStableCommandAndAtomicPartition()
     {
         using var fixture = new TestDatabase();
-        var codec = new GrainRequestCodec(fixture.Database, TimeProvider.System);
+        var codec = new GrainRequestCodec(fixture.Database, TimeProvider.System, UnitRoutingOptions.Routing());
         foreach (var item in BlobAgentCases.All().Where(item => item.CommandKind.HasValue))
         {
             var first = codec.Verify(Sign(codec, item, Guid.NewGuid()));
@@ -33,7 +33,7 @@ public async Task AcBlob006FreshSignedActorsPreserveEachStableCommandAndAtomicPa
     public async Task AcBlob006SignedReadActorsRequireTheirFreshRequestIdentity()
     {
         using var fixture = new TestDatabase();
-        var codec = new GrainRequestCodec(fixture.Database, TimeProvider.System);
+        var codec = new GrainRequestCodec(fixture.Database, TimeProvider.System, UnitRoutingOptions.Routing());
         foreach (var item in BlobAgentCases.All().Where(item => item.ReadKind.HasValue))
         {
             var id = Guid.NewGuid();
@@ -51,7 +51,7 @@ await Assert.That(Assert.ThrowsExactly<KeyLoadException>(() => codec.VerifyRead(
     public async Task AcBlob003WrongCommandIdentityOrAtomicActorCannotExecuteAnyBlobCommand()
     {
         using var fixture = new TestDatabase();
-        var codec = new GrainRequestCodec(fixture.Database, TimeProvider.System);
+        var codec = new GrainRequestCodec(fixture.Database, TimeProvider.System, UnitRoutingOptions.Routing());
         var executor = new GrainCommandExecutor(fixture.Database, new EmbeddedCoordinator(fixture.Database), TimeProvider.System);
         var keys = new[]
         {

tests/KeyLoad.UnitTests/Features/ClientApi/Cases/McpNativeAuthenticationMalformedTests.cs

@@ -57,7 +57,7 @@ public async Task WrongNativeRootsDefaultCollectionsAndTrailingBytesReleaseEvery
         {
             await Assert.That(Assert.ThrowsExactly<KeyLoadException>(() => McpNativeAuthentication.ReadPrincipal(payload, CancellationToken.None)).Code)
                 .IsEqualTo(ErrorCode.Validation);
-            using (var state = new McpRequestState(new HttpAdmissionGovernor(), memory, RequestCapacity, CancellationToken.None))
+            using (var state = new McpRequestState(new HttpAdmissionGovernor(UnitAdmissionOptions.Http()), memory, RequestCapacity, CancellationToken.None))
             {
                 await Assert.That(Assert.ThrowsExactly<KeyLoadException>(() => state.Authenticate(payload, CancellationToken.None)).Code)
                     .IsEqualTo(ErrorCode.Validation);

tests/KeyLoad.UnitTests/Features/ClientApi/Cases/McpNativeAuthenticationTests.cs

@@ -52,7 +52,7 @@ public async Task PersistedPrincipalAdmissionOwnsDecodedValuesAndReturnsEveryRes
         var payload = NativeSerialization.Serialize(new GrainValue(principal));
         var limits = new McpMemoryLimits();
         var memory = new McpMemoryBudget(limits.DataBytes, limits.ControlBytes, limits.IngressBytes);
-        var governor = new HttpAdmissionGovernor();
+        var governor = new HttpAdmissionGovernor(UnitAdmissionOptions.Http());
         using (var state = new McpRequestState(governor, memory, RequestCapacity, CancellationToken.None))
         {
             state.Authenticate(payload, CancellationToken.None);

tests/KeyLoad.UnitTests/Features/ClientApi/Cases/McpUnknownLengthAdmissionTests.cs

@@ -24,7 +24,7 @@ public async Task SmallUnknownLengthDiscoveryAdmitsAndReleasesDefaultMemoryAndEx
         var principalBytes = NativeSerialization.Serialize(new GrainValue(principal));
         var limits = new McpMemoryLimits();
         var memory = new McpMemoryBudget(limits.DataBytes, limits.ControlBytes, limits.IngressBytes);
-        var governor = new HttpAdmissionGovernor();
+        var governor = new HttpAdmissionGovernor(UnitAdmissionOptions.Http());
         var wire = Encoding.UTF8.GetBytes(DiscoveryFrame);
 
         using (var state = new McpRequestState(governor, memory, DefaultHttpBodyLimitBytes, CancellationToken.None))