This is an automated email from the ASF dual-hosted git repository.
inigoiri pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new c777142 RBF: Registry HDFS Router's rpcserver & rpcclient metrics for
PrometheusSink. (#3965)
c777142 is described below
commit c777142ed3291ba0835803a1c8391fed67ec60ce
Author: Neil <[email protected]>
AuthorDate: Fri Feb 11 01:17:30 2022 +0800
RBF: Registry HDFS Router's rpcserver & rpcclient metrics for
PrometheusSink. (#3965)
---
.../hdfs/server/federation/metrics/FederationRPCMetrics.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/metrics/FederationRPCMetrics.java
b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/metrics/FederationRPCMetrics.java
index 018bf0c..823bc7b 100644
---
a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/metrics/FederationRPCMetrics.java
+++
b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/metrics/FederationRPCMetrics.java
@@ -189,41 +189,49 @@ public class FederationRPCMetrics implements
FederationRPCMBean {
}
@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();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
