From c52d5693e91f7a8975d6f5f0de06a86d1360ef59 Mon Sep 17 00:00:00 2001 From: Kyren223 Date: Sat, 12 Jul 2025 14:27:12 +0300 Subject: Added server metrics (need to actually add metrics later) --- internal/server/metrics/metrics.go | 18 ++++++++++++++++++ internal/server/server.go | 2 ++ 2 files changed, 20 insertions(+) create mode 100644 internal/server/metrics/metrics.go (limited to 'internal/server') 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") }() -- cgit v1.3.1