Track number of inflight forwarded requests

esatterwhite · Oct 22, 2015 · 2d74827 · 2d74827
1 parent e2ce3e4
commit 2d74827
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/request-proxy/index.js b/lib/request-proxy/index.js
@@ -58,6 +58,7 @@ proto.removeSend = function removeSend(send) {
 
     if (indexOf !== -1) {
         this.sends.splice(indexOf, 1);
+        this.ringpop.stat('gauge', 'requestProxy.inflight', this.sends.length);
     }
 
     send.destroy();
@@ -131,6 +132,7 @@ proto.proxyReq = function proxyReq(opts) {
         });
 
         self.sends.push(send);
+        self.ringpop.stat('gauge', 'requestProxy.inflight', self.sends.length);
 
         function onProxy(err, res1, res2) {
             self.removeSend(send);