diff --git a/rpc/handler.go b/rpc/handler.go index 34f38128fb..035b557a47 100644 --- a/rpc/handler.go +++ b/rpc/handler.go @@ -335,9 +335,9 @@ func (h *handler) handleCall(cp *callProc, msg *jsonrpcMessage) *jsonrpcMessage if callb != h.unsubscribeCb { jsonrpcRequestGauge.Inc(1) if answer.Error != nil { - invalidReqeustGauge.Inc(1) + failedReqeustGauge.Inc(1) } else { - validRequestGauge.Inc(1) + successfulRequestGauge.Inc(1) } jsonrpcServingTimer.UpdateSince(start) newJsonrpcServingTimer(msg.Version, msg.Method, answer.Error == nil).UpdateSince(start) diff --git a/rpc/metrics.go b/rpc/metrics.go index 1e3c99d369..c062dae5ea 100644 --- a/rpc/metrics.go +++ b/rpc/metrics.go @@ -23,10 +23,10 @@ import ( ) var ( - jsonrpcRequestGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/count/in", nil) - validRequestGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/count/valid", nil) - invalidReqeustGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/count/invalid", nil) - jsonrpcServingTimer = metrics.NewRegisteredTimer("rpc/jsonrpc/duration/all", nil) + jsonrpcRequestGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/count/in", nil) + successfulRequestGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/count/success", nil) + failedReqeustGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/count/failure", nil) + jsonrpcServingTimer = metrics.NewRegisteredTimer("rpc/jsonrpc/duration/all", nil) ) func newJsonrpcServingTimer(version string, method string, valid bool) metrics.Timer {