From 70ea78fd6ce21fee86f9d63d59d0438f80b129b3 Mon Sep 17 00:00:00 2001
From: Philip O'Toole <philip.otoole@yahoo.com>
Date: Mon, 28 Nov 2022 08:59:49 -0500
Subject: [PATCH] More Queued Writes instrumentation

---
 http/service.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/http/service.go b/http/service.go
index 6c5cf391..b15f9d3b 100644
--- a/http/service.go
+++ b/http/service.go
@@ -178,6 +178,8 @@ const (
 	numExecutions               = "executions"
 	numQueuedExecutions         = "queued_executions"
 	numQueuedExecutionsOK       = "queued_executions_ok"
+	numQueuedExecutionsStmtsRx  = "queued_executions_num_stmts_rx"
+	numQueuedExecutionsStmtsTx  = "queued_executions_num_stmts_tx"
 	numQueuedExecutionsNoLeader = "queued_executions_no_leader"
 	numQueuedExecutionsFailed   = "queued_executions_failed"
 	numQueuedExecutionsWait     = "queued_executions_wait"
@@ -220,6 +222,8 @@ func ResetStats() {
 	stats.Add(numExecutions, 0)
 	stats.Add(numQueuedExecutions, 0)
 	stats.Add(numQueuedExecutionsOK, 0)
+	stats.Add(numQueuedExecutionsStmtsRx, 0)
+	stats.Add(numQueuedExecutionsStmtsTx, 0)
 	stats.Add(numQueuedExecutionsNoLeader, 0)
 	stats.Add(numQueuedExecutionsFailed, 0)
 	stats.Add(numQueuedExecutionsWait, 0)
@@ -1569,6 +1573,7 @@ func (s *Service) runQueue() {
 					Transaction: s.DefaultQueueTx,
 				},
 			}
+			stats.Add(numQueuedExecutionsStmtsRx, int64(len(req.Statements)))
 
 			// Nil statements are valid, as clients may want to just send
 			// a "checkpoint" through the queue.
@@ -1609,6 +1614,7 @@ func (s *Service) runQueue() {
 			s.seqNum = req.SequenceNumber
 			s.seqNumMu.Unlock()
 			req.Close()
+			stats.Add(numQueuedExecutionsStmtsTx, int64(len(req.Statements)))
 			stats.Add(numQueuedExecutionsOK, 1)
 		}
 	}