|
@@ -59,6 +59,10 @@ func (client *RPCClient) Call(severName string, serverMethod string, args interf
|
|
continue
|
|
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)
|
|
err = rpcCallWithReconnect(client.clients[mapkey], addr, serverMethod, args, reply)
|
|
if err != nil {
|
|
if err != nil {
|
|
Log.WithField("method", serverMethod).Warnf("RpcCallWithReconnect error : %s", err)
|
|
Log.WithField("method", serverMethod).Warnf("RpcCallWithReconnect error : %s", err)
|
|
@@ -67,11 +71,6 @@ func (client *RPCClient) Call(severName string, serverMethod string, args interf
|
|
|
|
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
- if serverInstance.prome != nil {
|
|
|
|
-
|
|
|
|
- elapsed := float64(time.Since(startT)) / float64(time.Second)
|
|
|
|
- serverInstance.prome.CallDur.WithLabelValues(serverInstance.name, severName, serverMethod).Observe(elapsed)
|
|
|
|
- }
|
|
|
|
return errorf(err.Error())
|
|
return errorf(err.Error())
|
|
}
|
|
}
|
|
|
|
|