feat(cluster): preserve isolated replication over gRPC

[yordis]

• Preserves isolated replication topology and failure detection on the supported gRPC transport.

[cursor]

PR Summary

High Risk
Changes cluster topology, replication listening, and gossip serialization; misconfiguration or mixed-version behavior could break replication or client routing.

Overview
This PR drops legacy TCP cluster/client endpoints from gossip, MemberInfo, and the admin cluster UI, replacing them with HTTP/gRPC for clients and a dedicated ReplicationEndPoint carried over gRPC gossip (defaulting to HTTP when absent for mixed-version clusters).

Runtime wiring: Kestrel now listens on node and replication addresses separately; the replication listener is HTTP/2-only. ReplicationEndpointPolicy returns 404 unless replication gRPC hits the replication port (and blocks that path on the node port). NodeConnectionTracker wraps connections to record bytes, TLS, and HTTP vs gRPC metadata for observability. Replica catch-up in the UI maps subscription endpoints via HTTP instead of internal TCP.

Tests & config: Integration and cluster test harnesses use node + replication ports and gRPC streams instead of EventStore.ClientAPI TCP plugins; large TCP transport and ClientAPI test helper removals. New options/validation cover ReplicationPortAdvertiseAs (with deprecated alias) and non-overlapping node/replication listeners.

^{Reviewed by Cursor Bugbot for commit d04c94d. Bugbot is set up for automated code reviews on this repo. Configure here.}

[coderabbitai]

Warning

Review limit reached

Next included review available in 59 minutes.

Check out review usage here.

View limit details

Limit details: You’ve used the included review currently available.

You've used all free OSS reviews for now. Wait for the free limit to reset to keep reviewing this public repository.

Learn how review limits work.

Review configuration:

⚙️ Run configuration

Configuration used: Organization UI

Review profile: CHILL

Plan: Advanced

Run ID: 69854e44-553d-4513-b48e-01db363f21d2

📥 Commits

Reviewing files that changed from the base of the PR and between 9989238 and d04c94d.

📒 Files selected for processing (83)

• src/EventStore.ClusterNode/Components/Pages/Cluster.razor
• src/EventStore.ClusterNode/Components/Services/ClusterStatusService.cs
• src/EventStore.ClusterNode/Components/Services/NodeConnectionTracker.cs
• src/EventStore.ClusterNode/Components/Services/ReplicationEndpointPolicy.cs
• src/EventStore.ClusterNode/Program.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/EventDataComparer.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/EventsStream.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/TcpType.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/TestConnection.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/TestConnectionLifecycle.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/TestEvent.cs
• src/EventStore.Core.Tests/ClientAPI/Helpers/Writer.cs
• src/EventStore.Core.Tests/ClientAPI/SpecificationWithMiniNode.cs
• src/EventStore.Core.Tests/Cluster/MemberInfoTests.cs
• src/EventStore.Core.Tests/DefaultData.cs
• src/EventStore.Core.Tests/Helpers/ClientApiLoggerBridge.cs
• src/EventStore.Core.Tests/Helpers/MiniClusterNode.cs
• src/EventStore.Core.Tests/Helpers/MiniNode.cs
• src/EventStore.Core.Tests/Integration/Archive/when_archiving_and_restoring_a_cluster.cs
• src/EventStore.Core.Tests/Integration/specification_with_cluster.cs
• src/EventStore.Core.Tests/Integration/when_cluster_nodes_are_restarted.cs
• src/EventStore.Core.Tests/Services/ElectionsService/ClusterSettingsFactory.cs
• src/EventStore.Core.Tests/Services/ElectionsService/ClusterVNodeSettings.cs
• src/EventStore.Core.Tests/Services/ElectionsService/ElectionServiceUnit.cs
• src/EventStore.Core.Tests/Services/ElectionsService/ElectionsServiceTests.cs
• src/EventStore.Core.Tests/Services/ElectionsService/LeaderNode/ElectionsServiceUnitTests.cs
• src/EventStore.Core.Tests/Services/ElectionsService/Randomized/RandomizedElectionsTestCase.cs
• src/EventStore.Core.Tests/Services/ElectionsService/Randomized/UpdateGossipProcessor.cs
• src/EventStore.Core.Tests/Services/ElectionsService/Randomized/elections_service_5_nodes_with_1_known_when_started_and_set_full_imediately.cs
• src/EventStore.Core.Tests/Services/ElectionsService/Randomized/elections_service_5_nodes_with_1_known_when_started_and_set_to_full_later.cs
• src/EventStore.Core.Tests/Services/GossipService/NodeGossipServiceTests.cs
• src/EventStore.Core.Tests/Services/Replication/LogReplication/LogReplicationFixture.cs
• src/EventStore.Core.Tests/Services/Replication/ReadOnlyReplica/connecting_to_read_only_replica.cs
• src/EventStore.Core.Tests/Services/RequestForwarding/GrpcRequestForwardingServiceTests.cs
• src/EventStore.Core.Tests/Services/RequestForwarding/GrpcRequestForwardingTransportSecurityTests.cs
• src/EventStore.Core.Tests/Services/RequestForwarding/RequestForwardingServiceTests.cs
• src/EventStore.Core.Tests/Services/RequestManagement/Service/when_writing_and_deposed_as_leader.cs
• src/EventStore.Core.Tests/Services/RequestManagement/Service/when_writing_and_deposed_as_leader_and_replica_moves_forward.cs
• src/EventStore.Core.Tests/Services/Transport/Grpc/Forwarding/ForwardingGrpcCodecTests.cs
• src/EventStore.Core.Tests/Services/Transport/Grpc/Replication/GrpcReplicaServiceFactoryTests.cs
• src/EventStore.Core.Tests/Services/Transport/Grpc/Replication/GrpcReplicaServiceSupervisorTests.cs
• src/EventStore.Core.Tests/Services/Transport/Tcp/core_tcp_package.cs
• src/EventStore.Core.Tests/Services/Transport/Tcp/ssl_connection.cs
• src/EventStore.Core.Tests/Services/Transport/Tcp/ssl_connections_mutual_auth.cs
• src/EventStore.Core.Tests/Services/VNode/InaugurationManager/InaugurationManagerTests.cs
• src/EventStore.Core.Tests/Services/VNode/ShutdownServiceTests.cs
• src/EventStore.Core.Tests/Services/VNode/leader_info_provider.cs
• src/EventStore.Core.Tests/TcpApiTestPlugin/PublicTcpApiTestService.cs
• src/EventStore.Core.Tests/TcpApiTestPlugin/TcpApiTestOptions.cs
• src/EventStore.Core.Tests/TcpApiTestPlugin/TcpApiTestPlugin.cs
• src/EventStore.Core.XUnit.Tests/Configuration/ClusterNodeOptionsTests/when_building/with_default_settings.cs
• src/EventStore.Core.XUnit.Tests/Configuration/ClusterVNodeOptionsTests.cs
• src/EventStore.Core.XUnit.Tests/Configuration/ClusterVNodeOptionsValidatorTests.cs
• src/EventStore.Core.XUnit.Tests/Metrics/ElectionsCounterTrackerTests.cs
• src/EventStore.Core.XUnit.Tests/Services/Storage/InMemory/GossipListenerServiceTests.cs
• src/EventStore.Core.XUnit.Tests/Telemetry/TelemetryServiceTests.cs
• src/EventStore.Core/Cluster/ClientClusterInfo.cs
• src/EventStore.Core/Cluster/ClusterInfo.cs
• src/EventStore.Core/Cluster/MemberInfo.cs
• src/EventStore.Core/ClusterVNode.cs
• src/EventStore.Core/Configuration/ClusterVNodeOptions.cs
• src/EventStore.Core/Configuration/ClusterVNodeOptionsExtensions.cs
• src/EventStore.Core/Configuration/ClusterVNodeOptionsValidator.cs
• src/EventStore.Core/Data/GossipAdvertiseInfo.cs
• src/EventStore.Core/Data/VNodeInfo.cs
• src/EventStore.Core/Messages/ClientMessage.cs
• src/EventStore.Core/Messages/ClusterInfoDto.cs
• src/EventStore.Core/Messages/MemberInfoDto.cs
• src/EventStore.Core/Services/ElectionsService.cs
• src/EventStore.Core/Services/Gossip/GossipServiceBase.cs
• src/EventStore.Core/Services/Gossip/NodeGossipService.cs
• src/EventStore.Core/Services/Monitoring/MonitoringService.cs
• src/EventStore.Core/Services/Replication/GrpcReplicaServiceSupervisor.cs
• src/EventStore.Core/Services/Replication/ReplicationGrpcClient.cs
• src/EventStore.Core/Services/RequestForwarding/GrpcRequestForwardingSupervisor.cs
• src/EventStore.Core/Services/RequestForwardingService.cs
• src/EventStore.Core/Services/Transport/Grpc/Forwarding/ForwardingGrpcCodec.cs
• src/EventStore.Core/Services/Transport/Grpc/Forwarding/ForwardingService.cs
• src/EventStore.Core/Services/VNode/ClusterVNodeController.cs
• src/EventStore.Core/Services/VNode/LeaderInfoProvider.cs
• src/EventStore.Projections.Core.Tests/Services/projections_system/when_starting_up.cs
• src/Protos/Grpc/cluster.proto
• src/Protos/Grpc/forwarding.proto

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands.}

[cursor]

Cursor Bugbot has reviewed your changes using default effort and found 1 potential issue.

^{❌ Bugbot Autofix is OFF. To automatically fix reported issues with cloud agents, have a team admin enable autofix in the Cursor dashboard.}

^{Reviewed by Cursor Bugbot for commit dbf4cb3. Configure here.}