rpc: fixed a typo (#24642)
This commit is contained in:
parent
aa123939c2
commit
0654014652
@ -341,7 +341,7 @@ func (h *handler) handleCall(cp *callProc, msg *jsonrpcMessage) *jsonrpcMessage
|
|||||||
if callb != h.unsubscribeCb {
|
if callb != h.unsubscribeCb {
|
||||||
rpcRequestGauge.Inc(1)
|
rpcRequestGauge.Inc(1)
|
||||||
if answer.Error != nil {
|
if answer.Error != nil {
|
||||||
failedReqeustGauge.Inc(1)
|
failedRequestGauge.Inc(1)
|
||||||
} else {
|
} else {
|
||||||
successfulRequestGauge.Inc(1)
|
successfulRequestGauge.Inc(1)
|
||||||
}
|
}
|
||||||
|
@ -25,7 +25,7 @@ import (
|
|||||||
var (
|
var (
|
||||||
rpcRequestGauge = metrics.NewRegisteredGauge("rpc/requests", nil)
|
rpcRequestGauge = metrics.NewRegisteredGauge("rpc/requests", nil)
|
||||||
successfulRequestGauge = metrics.NewRegisteredGauge("rpc/success", nil)
|
successfulRequestGauge = metrics.NewRegisteredGauge("rpc/success", nil)
|
||||||
failedReqeustGauge = metrics.NewRegisteredGauge("rpc/failure", nil)
|
failedRequestGauge = metrics.NewRegisteredGauge("rpc/failure", nil)
|
||||||
rpcServingTimer = metrics.NewRegisteredTimer("rpc/duration/all", nil)
|
rpcServingTimer = metrics.NewRegisteredTimer("rpc/duration/all", nil)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user