1
0
Fork 0

Merge pull request #1263 from rqlite/otoolep-http-execute-stmts-rx

Count number of received Execute statements by HTTP layer
master
Philip O'Toole 1 year ago committed by GitHub
commit 61b3bbe5a4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -191,6 +191,7 @@ var stats *expvar.Map
const ( const (
numLeaderNotFound = "leader_not_found" numLeaderNotFound = "leader_not_found"
numExecutions = "executions" numExecutions = "executions"
numExecuteStmtsRx = "execute_stmts_rx"
numQueuedExecutions = "queued_executions" numQueuedExecutions = "queued_executions"
numQueuedExecutionsOK = "queued_executions_ok" numQueuedExecutionsOK = "queued_executions_ok"
numQueuedExecutionsStmtsRx = "queued_executions_num_stmts_rx" numQueuedExecutionsStmtsRx = "queued_executions_num_stmts_rx"
@ -240,6 +241,7 @@ func ResetStats() {
stats.Init() stats.Init()
stats.Add(numLeaderNotFound, 0) stats.Add(numLeaderNotFound, 0)
stats.Add(numExecutions, 0) stats.Add(numExecutions, 0)
stats.Add(numExecuteStmtsRx, 0)
stats.Add(numQueuedExecutions, 0) stats.Add(numQueuedExecutions, 0)
stats.Add(numQueuedExecutionsOK, 0) stats.Add(numQueuedExecutionsOK, 0)
stats.Add(numQueuedExecutionsStmtsRx, 0) stats.Add(numQueuedExecutionsStmtsRx, 0)
@ -1342,6 +1344,7 @@ func (s *Service) execute(w http.ResponseWriter, r *http.Request) {
http.Error(w, err.Error(), http.StatusBadRequest) http.Error(w, err.Error(), http.StatusBadRequest)
return return
} }
stats.Add(numExecuteStmtsRx, int64(len(stmts)))
if err := command.Rewrite(stmts, !noRewriteRandom); err != nil { if err := command.Rewrite(stmts, !noRewriteRandom); err != nil {
http.Error(w, fmt.Sprintf("SQL rewrite: %s", err.Error()), http.StatusInternalServerError) http.Error(w, fmt.Sprintf("SQL rewrite: %s", err.Error()), http.StatusInternalServerError)
return return

Loading…
Cancel
Save