Skip to content

Commit d101ed7

Browse files
authored
IGNITE-27108 Added client router node metric. (#12520)
1 parent a53436d commit d101ed7

2 files changed

Lines changed: 10 additions & 1 deletion

File tree

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1500,7 +1500,10 @@ public long getCoordinatorSinceTimestamp() {
15001500

15011501
discoReg.register("CoordinatorSince", stats::coordinatorSinceTimestamp, "Coordinator since timestamp");
15021502
}
1503-
1503+
else {
1504+
discoReg.register("ClientRouterNodeId", () -> String.valueOf(locNode.clientRouterNodeId()), String.class,
1505+
"Client router node ID.");
1506+
}
15041507
}
15051508

15061509
/** {@inheritDoc} */

modules/core/src/test/java/org/apache/ignite/spi/discovery/datacenter/MultiDataCenterClientRoutingTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,10 +28,13 @@
2828
import org.apache.ignite.internal.IgniteEx;
2929
import org.apache.ignite.internal.IgniteNodeAttributes;
3030
import org.apache.ignite.internal.TestRecordingCommunicationSpi;
31+
import org.apache.ignite.internal.processors.metric.MetricRegistryImpl;
3132
import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode;
3233
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
3334
import org.junit.Test;
3435

36+
import static org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.DISCO_METRICS;
37+
3538
/** */
3639
public class MultiDataCenterClientRoutingTest extends GridCommonAbstractTest {
3740
/** */
@@ -88,6 +91,9 @@ public void testConnectionToProperDc() throws Exception {
8891
IgniteEx client = startClientGrid();
8992

9093
UUID routerId = ((TcpDiscoveryNode)client.localNode()).clientRouterNodeId();
94+
MetricRegistryImpl mreg = client.context().metric().registry(DISCO_METRICS);
95+
96+
assertEquals(routerId.toString(), mreg.findMetric("ClientRouterNodeId").getAsString());
9197

9298
List<ClusterNode> routers = client.cluster().nodes().stream()
9399
.filter(node -> node.id().equals(routerId))

0 commit comments

Comments
 (0)