added ability to count disconnects and reconnects

Author: GlenTiki

anger.js

@@ -43,6 +43,8 @@ function anger (opts) {
   const again = tryAgain(xtend(defaultAgainOpts, opts.retryOpts))
 
   let timedOutResponses = 0
+  let disconnects = 0
+  let reconnects = -clients.length // will be 0 after connecting each client
 
   for (let i = 0; i < clients.length; i++) {
     clients[i] = new Client(opts.url)
@@ -51,6 +53,8 @@ function anger (opts) {
       sender: false
     }
     retries[i] = 0
+    clients[i].onDisconnect = () => { disconnects++ }
+    clients[i].onConnect = () => { reconnects++ }
     if (i < opts.senders) {
       senders[i] = clients[i]
       clients[i].anger.sender = true
@@ -178,7 +182,9 @@ function anger (opts) {
       connectLatencies: histUtil.addPercentiles(connectLatencies, histUtil.histAsObj(connectLatencies)),
       retriesAvg: mean(retries),
       connections: clients.length,
-      senders: opts.senders
+      senders: opts.senders,
+      disconnects: disconnects,
+      reconnects: reconnects
     })
   }
 

test/basic.test.js

@@ -66,5 +66,8 @@ require('./server')((err, server) => {
     t.ok(result.connectLatencies.p999 >= 0, 'connectLatencies.p999 exists')
     t.ok(result.connectLatencies.p9999 >= 0, 'connectLatencies.p9999 exists')
     t.ok(result.connectLatencies.p99999 >= 0, 'connectLatencies.p99999 exists')
+
+    t.ok(result.disconnects >= 0, 'disconnects exist')
+    t.ok(result.reconnects >= 0, 'reconnects exists')
   })
 })