更新指标

pkg/server/rpc_client.go

@@ -40,7 +40,6 @@ func rpcCallWithReconnect(client *rpc.Client, addr string, serverMethod string,
 
 // Call RPC call with reconnect and retry.
 func (client *RPCClient) Call(severName string, serverMethod string, args interface{}, reply interface{}) error {
-	startT := time.Now()
 	addrs, err := serverInstance.serverManager.GetServerHosts(severName, FlagRPCHost)
 	if err != nil {
 		return err
@@ -59,10 +58,6 @@ func (client *RPCClient) Call(severName string, serverMethod string, args interf
 				continue
 			}
 		}
-		if serverInstance.prome != nil {
-			elapsed := float64(time.Since(startT)) / float64(time.Second)
-			serverInstance.prome.CallDur.WithLabelValues(serverInstance.name, severName, serverMethod).Observe(elapsed)
-		}
 		err = rpcCallWithReconnect(client.clients[mapkey], addr, serverMethod, args, reply)
 		if err != nil {
 			Log.WithField("method", serverMethod).Warnf("RpcCallWithReconnect error : %s", err)