RBF: Registry HDFS Router's rpcserver & rpcclient metrics for PrometheusSink. (#3965)

This commit is contained in:
Neil 2022-02-11 01:17:30 +08:00 committed by GitHub
parent efdec92cab
commit c777142ed3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -189,41 +189,49 @@ public long getRouterFailureLockedOps() {
} }
@Override @Override
@Metric({"RpcServerCallQueue", "Length of the rpc server call queue"})
public int getRpcServerCallQueue() { public int getRpcServerCallQueue() {
return rpcServer.getServer().getCallQueueLen(); return rpcServer.getServer().getCallQueueLen();
} }
@Override @Override
@Metric({"RpcServerNumOpenConnections", "Number of the rpc server open connections"})
public int getRpcServerNumOpenConnections() { public int getRpcServerNumOpenConnections() {
return rpcServer.getServer().getNumOpenConnections(); return rpcServer.getServer().getNumOpenConnections();
} }
@Override @Override
@Metric({"RpcClientNumConnections", "Number of the rpc client open connections"})
public int getRpcClientNumConnections() { public int getRpcClientNumConnections() {
return rpcServer.getRPCClient().getNumConnections(); return rpcServer.getRPCClient().getNumConnections();
} }
@Override @Override
@Metric({"RpcClientNumActiveConnections", "Number of the rpc client active connections"})
public int getRpcClientNumActiveConnections() { public int getRpcClientNumActiveConnections() {
return rpcServer.getRPCClient().getNumActiveConnections(); return rpcServer.getRPCClient().getNumActiveConnections();
} }
@Override @Override
@Metric({"RpcClientNumIdleConnections", "Number of the rpc client idle connections"})
public int getRpcClientNumIdleConnections() { public int getRpcClientNumIdleConnections() {
return rpcServer.getRPCClient().getNumIdleConnections(); return rpcServer.getRPCClient().getNumIdleConnections();
} }
@Override @Override
@Metric({"RpcClientNumActiveConnectionsRecently", "Number of the rpc client active connections recently"})
public int getRpcClientNumActiveConnectionsRecently() { public int getRpcClientNumActiveConnectionsRecently() {
return rpcServer.getRPCClient().getNumActiveConnectionsRecently(); return rpcServer.getRPCClient().getNumActiveConnectionsRecently();
} }
@Override @Override
@Metric({"RpcClientNumCreatingConnections", "Number of the rpc client creating connections"})
public int getRpcClientNumCreatingConnections() { public int getRpcClientNumCreatingConnections() {
return rpcServer.getRPCClient().getNumCreatingConnections(); return rpcServer.getRPCClient().getNumCreatingConnections();
} }
@Override @Override
@Metric({"RpcClientNumConnectionPools", "Number of the rpc client connection pools"})
public int getRpcClientNumConnectionPools() { public int getRpcClientNumConnectionPools() {
return rpcServer.getRPCClient().getNumConnectionPools(); return rpcServer.getRPCClient().getNumConnectionPools();
} }