add rpc method request gauge

unclezoro · unclezoro · commit 5bd73320ba78 · 2021-01-10T22:01:20.000+08:00
diff --git a/rpc/handler.go b/rpc/handler.go
@@ -340,6 +340,7 @@ func (h *handler) handleCall(cp *callProc, msg *jsonrpcMessage) *jsonrpcMessage
 			successfulRequestGauge.Inc(1)
 		}
 		rpcServingTimer.UpdateSince(start)
+		newRPCRequestGauge(msg.Method).Inc(1)
 		newRPCServingTimer(msg.Method, answer.Error == nil).UpdateSince(start)
 	}
 	return answer
diff --git a/rpc/metrics.go b/rpc/metrics.go
@@ -37,3 +37,8 @@ func newRPCServingTimer(method string, valid bool) metrics.Timer {
 	m := fmt.Sprintf("rpc/duration/%s/%s", method, flag)
 	return metrics.GetOrRegisterTimer(m, nil)
 }
+
+func newRPCRequestGauge(method string) metrics.Gauge {
+	m := fmt.Sprintf("rpc/count/%s", method)
+	return metrics.GetOrRegisterGauge(m, nil)
+}

Original file line number	Diff line number	Diff line change
`@@ -340,6 +340,7 @@ func (h handler) handleCall(cp callProc, msg jsonrpcMessage) jsonrpcMessage`
`340`	`340`	`successfulRequestGauge.Inc(1)`
`341`	`341`	`}`
`342`	`342`	`rpcServingTimer.UpdateSince(start)`
	`343`	`+ newRPCRequestGauge(msg.Method).Inc(1)`
`343`	`344`	`newRPCServingTimer(msg.Method, answer.Error == nil).UpdateSince(start)`
`344`	`345`	`}`
`345`	`346`	`return answer`
Original file line number	Diff line number	Diff line change
`@@ -37,3 +37,8 @@ func newRPCServingTimer(method string, valid bool) metrics.Timer {`
`37`	`37`	`m := fmt.Sprintf("rpc/duration/%s/%s", method, flag)`
`38`	`38`	`return metrics.GetOrRegisterTimer(m, nil)`
`39`	`39`	`}`
	`40`	`+`
	`41`	`+func newRPCRequestGauge(method string) metrics.Gauge {`
	`42`	`+ m := fmt.Sprintf("rpc/count/%s", method)`
	`43`	`+ return metrics.GetOrRegisterGauge(m, nil)`
	`44`	`+}`