(ignite) branch master updated: IGNITE-27108 Added client router node metric. (#12520)

[namelchev]

This is an automated email from the ASF dual-hosted git repository.

namelchev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new d101ed7cc35 IGNITE-27108 Added client router node metric. (#12520)
d101ed7cc35 is described below

commit d101ed7cc35b50ce4189695486448a14ab032635
Author: Nikita Amelchev <nsamelc...@gmail.com>
AuthorDate: Thu Nov 20 13:12:15 2025 +0300

    IGNITE-27108 Added client router node metric. (#12520)
---
 .../java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java   | 5 ++++-
 .../spi/discovery/datacenter/MultiDataCenterClientRoutingTest.java  | 6 ++++++
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index 1ce14f60cdd..49c0127b821 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -1500,7 +1500,10 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter 
implements IgniteDiscovery
 
             discoReg.register("CoordinatorSince", 
stats::coordinatorSinceTimestamp, "Coordinator since timestamp");
         }
-
+        else {
+            discoReg.register("ClientRouterNodeId", () -> 
String.valueOf(locNode.clientRouterNodeId()), String.class,
+                "Client router node ID.");
+        }
     }
 
     /** {@inheritDoc} */
diff --git 
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/datacenter/MultiDataCenterClientRoutingTest.java
 
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/datacenter/MultiDataCenterClientRoutingTest.java
index 1a997ada7db..437d39628e6 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/datacenter/MultiDataCenterClientRoutingTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/datacenter/MultiDataCenterClientRoutingTest.java
@@ -28,10 +28,13 @@ import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.internal.IgniteEx;
 import org.apache.ignite.internal.IgniteNodeAttributes;
 import org.apache.ignite.internal.TestRecordingCommunicationSpi;
+import org.apache.ignite.internal.processors.metric.MetricRegistryImpl;
 import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode;
 import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
 import org.junit.Test;
 
+import static 
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.DISCO_METRICS;
+
 /** */
 public class MultiDataCenterClientRoutingTest extends GridCommonAbstractTest {
     /** */
@@ -88,6 +91,9 @@ public class MultiDataCenterClientRoutingTest extends 
GridCommonAbstractTest {
         IgniteEx client = startClientGrid();
 
         UUID routerId = 
((TcpDiscoveryNode)client.localNode()).clientRouterNodeId();
+        MetricRegistryImpl mreg = 
client.context().metric().registry(DISCO_METRICS);
+
+        assertEquals(routerId.toString(), 
mreg.findMetric("ClientRouterNodeId").getAsString());
 
         List<ClusterNode> routers = client.cluster().nodes().stream()
             .filter(node -> node.id().equals(routerId))