RBF: Registry HDFS Router's rpcserver & rpcclient metrics for Prometh…

…eusSink. (apache#3965)
HarshitGupta11 · Nov 28, 2022 · 371958a · 371958a
1 parent 8600962
commit 371958a
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/.../src/main/java/org/apache/hadoop/hdfs/server/federation/metrics/FederationRPCMetrics.java b/.../src/main/java/org/apache/hadoop/hdfs/server/federation/metrics/FederationRPCMetrics.java
@@ -189,41 +189,49 @@ public long getRouterFailureLockedOps() {
   }
 
   @Override
+  @Metric({"RpcServerCallQueue", "Length of the rpc server call queue"})
   public int getRpcServerCallQueue() {
     return rpcServer.getServer().getCallQueueLen();
   }
 
   @Override
+  @Metric({"RpcServerNumOpenConnections", "Number of the rpc server open connections"})
   public int getRpcServerNumOpenConnections() {
     return rpcServer.getServer().getNumOpenConnections();
   }
 
   @Override
+  @Metric({"RpcClientNumConnections", "Number of the rpc client open connections"})
   public int getRpcClientNumConnections() {
     return rpcServer.getRPCClient().getNumConnections();
   }
 
   @Override
+  @Metric({"RpcClientNumActiveConnections", "Number of the rpc client active connections"})
   public int getRpcClientNumActiveConnections() {
     return rpcServer.getRPCClient().getNumActiveConnections();
   }
 
   @Override
+  @Metric({"RpcClientNumIdleConnections", "Number of the rpc client idle connections"})
   public int getRpcClientNumIdleConnections() {
     return rpcServer.getRPCClient().getNumIdleConnections();
   }
 
   @Override
+  @Metric({"RpcClientNumActiveConnectionsRecently", "Number of the rpc client active connections recently"})
   public int getRpcClientNumActiveConnectionsRecently() {
     return rpcServer.getRPCClient().getNumActiveConnectionsRecently();
   }
 
   @Override
+  @Metric({"RpcClientNumCreatingConnections", "Number of the rpc client creating connections"})
   public int getRpcClientNumCreatingConnections() {
     return rpcServer.getRPCClient().getNumCreatingConnections();
   }
 
   @Override
+  @Metric({"RpcClientNumConnectionPools", "Number of the rpc client connection pools"})
   public int getRpcClientNumConnectionPools() {
     return rpcServer.getRPCClient().getNumConnectionPools();
   }