diff options
Diffstat (limited to 'internal/server')
| -rw-r--r-- | internal/server/metrics/metrics.go | 18 | ||||
| -rw-r--r-- | internal/server/server.go | 2 |
2 files changed, 20 insertions, 0 deletions
diff --git a/internal/server/metrics/metrics.go b/internal/server/metrics/metrics.go new file mode 100644 index 0000000..9c80665 --- /dev/null +++ b/internal/server/metrics/metrics.go @@ -0,0 +1,18 @@ +package metrics + +import ( + "github.com/prometheus/client_golang/prometheus" + "github.com/prometheus/client_golang/prometheus/promauto" +) + +var ( + reg = prometheus.DefaultRegisterer + + namespace = "eko" + + RequestsProcessed = promauto.With(reg).NewCounter(prometheus.CounterOpts{ + Namespace: namespace, + Name: "processed_requests_total", + Help: "The total number of processed requests", + }) +) diff --git a/internal/server/server.go b/internal/server/server.go index 1f6d27c..0ca3200 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -25,6 +25,7 @@ import ( "github.com/kyren223/eko/internal/packet" "github.com/kyren223/eko/internal/server/api" "github.com/kyren223/eko/internal/server/ctxkeys" + "github.com/kyren223/eko/internal/server/metrics" "github.com/kyren223/eko/internal/server/session" "github.com/kyren223/eko/pkg/assert" "github.com/kyren223/eko/pkg/snowflake" @@ -292,6 +293,7 @@ func (server *server) handleConnection(conn net.Conn) { for request := range framer.Out { processPacket(localCtx, sess, request) + metrics.RequestsProcessed.Inc() } slog.InfoContext(ctx, "processor done") }() |