From f66f1ef39fb7ae84e931484d1676af1d33ff57ae Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Sat, 9 Nov 2024 22:51:43 +0100
Subject: [PATCH] metrics for queues

---
 synced-pool.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/synced-pool.go b/synced-pool.go
index 564f061..f79808b 100644
--- a/synced-pool.go
+++ b/synced-pool.go
@@ -172,6 +172,10 @@ var (
 		Name: "cart_remote_lookup_total",
 		Help: "The total number of remote lookups",
 	})
+	packetQueue = promauto.NewGauge(prometheus.GaugeOpts{
+		Name: "cart_packet_queue_size",
+		Help: "The total number of packets in the queue",
+	})
 )
 
 const (
@@ -211,6 +215,7 @@ func NewPacketQueue(connection net.Conn) *PacketQueue {
 
 				//return
 			}
+			packetQueue.Inc()
 			queue.mu.Lock()
 			queue.Packets = append(queue.Packets, PacketWithData{
 				MessageType: messageType,
@@ -226,7 +231,9 @@ func NewPacketQueue(connection net.Conn) *PacketQueue {
 			queue.mu.Lock()
 			for i, packet := range queue.Packets {
 				if time.Since(packet.Added) < time.Second*3 {
+
 					queue.Packets = queue.Packets[i:]
+					packetQueue.Set(float64(len(queue.Packets)))
 					break
 				}
 			}