kzkzzzz
/
mycommon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

main
lzf 2025-07-22 17:48:02 +08:00
parent 1eb10eb1af
commit 4ced8ae869
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
myhttp/httpsr/middleware.go
View File

@ -4,6 +4,7 @@ import (
"git.makemake.in/kzkzzzz/mycommon/mymetric" "git.makemake.in/kzkzzzz/mycommon/mymetric"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
"github.com/spf13/cast"
"time" "time"
) )
@ -11,7 +12,7 @@ const CtxCollectRequestFrom = "ctx_collect_request_from"
func QPSCollect(svcName string) gin.HandlerFunc { func QPSCollect(svcName string) gin.HandlerFunc {
hs := mymetric.NewQPSHistogram(svcName, []string{ hs := mymetric.NewQPSHistogram(svcName, []string{
"svc", "method", "route", "from", "svc", "method", "route", "status", "from",
}...) }...)
return func(ctx *gin.Context) { return func(ctx *gin.Context) {
@ -23,6 +24,7 @@ func QPSCollect(svcName string) gin.HandlerFunc {
"svc": svcName, "svc": svcName,
"method": ctx.Request.Method, "method": ctx.Request.Method,
"route": ctx.Request.URL.Path, "route": ctx.Request.URL.Path,
"status": cast.ToString(ctx.Writer.Status()),
"from": ctx.GetString(CtxCollectRequestFrom), "from": ctx.GetString(CtxCollectRequestFrom),
}).Observe(float64(time.Since(st).Milliseconds())) }).Observe(float64(time.Since(st).Milliseconds()))