From 5dc06c0ccd47dadc579f4df6c40dd1dac3e56182 Mon Sep 17 00:00:00 2001
From: Brian Olson <brian.olson@gmail.com>
Date: Fri, 15 Nov 2024 09:27:35 -0500
Subject: [PATCH] add gauge spl_active_clients

---
 splitter/metrics.go  | 5 +++++
 splitter/splitter.go | 2 ++
 2 files changed, 7 insertions(+)

diff --git a/splitter/metrics.go b/splitter/metrics.go
index a2173a63..76161ce4 100644
--- a/splitter/metrics.go
+++ b/splitter/metrics.go
@@ -9,3 +9,8 @@ var eventsSentCounter = promauto.NewCounterVec(prometheus.CounterOpts{
 	Name: "spl_events_sent_counter",
 	Help: "The total number of events sent to consumers",
 }, []string{"remote_addr", "user_agent"})
+
+var activeClientGauge = promauto.NewGauge(prometheus.GaugeOpts{
+	Name: "spl_active_clients",
+	Help: "Current number of active clients",
+})
diff --git a/splitter/splitter.go b/splitter/splitter.go
index c13d5e48..8f335063 100644
--- a/splitter/splitter.go
+++ b/splitter/splitter.go
@@ -269,6 +269,8 @@ func (s *Splitter) EventsHandler(c echo.Context) error {
 		"cursor", since,
 		"consumer_id", consumerID,
 	)
+	activeClientGauge.Inc()
+	defer activeClientGauge.Dec()
 
 	for {
 		select {
-- 
2.51.2