(pmx) add benchmark npm command

examples/pmx/app.js

@@ -0,0 +1,42 @@
+
+const PM2 = require('../..');
+
+var pm2 = new PM2.custom({
+  cwd : __dirname + '/elements'
+});
+
+
+pm2.start([{
+  script : 'error.js'
+}, {
+  script : 'metric.js'
+}, {
+  script : 'counter.js'
+}, {
+  script : 'meter.js'
+}, {
+  script : 'histogram.js'
+}, {
+  script : 'event.js'
+}, {
+  script : 'notify.js'
+}, {
+  script : 'log.js'
+}, {
+  script : 'log-cluster.js',
+  instances : 2
+}, {
+  script : 'http.js'
+}, {
+  script : 'cluster.js',
+  instances : 4,
+  env : {
+    PORT : 9803
+  }
+}, {
+  script : 'trace.js',
+  trace : true
+}], (err, procs) => {
+  console.log(`${procs.length} test apps started`);
+  pm2.disconnect();
+});

examples/pmx/elements/cluster.js

@@ -0,0 +1,46 @@
+
+var http = require('http');
+
+http.createServer(function(req, res) {
+  res.writeHead(200);
+  setTimeout(function() {
+    res.end('transaction');
+  }, 10);
+}).listen(process.env.PORT || 9010);
+
+setInterval(function() {
+  request(['/user', '/bla', '/user/lol/delete', '/POST/POST'][Math.floor((Math.random() * 4))]);
+}, 140);
+
+function makeid()
+{
+  var text = "";
+  var possible = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
+
+  for( var i=0; i < 5; i++ )
+    text += possible.charAt(Math.floor(Math.random() * possible.length));
+
+  return text;
+}
+
+function request(path) {
+  var options = {
+    hostname: '127.0.0.1'
+    ,port: 9010
+    ,path: path || '/users'
+    ,method: 'GET'
+    ,headers: { 'Content-Type': 'application/json' }
+  };
+
+  var req = http.request(options, function(res) {
+    res.setEncoding('utf8');
+    res.on('data', function (data) {
+      //console.log(data);
+    });
+  });
+  req.on('error', function(e) {
+    console.log('problem with request: ' + e.message);
+  });
+  req.end();
+
+}

examples/pmx/elements/counter.js

@@ -0,0 +1,12 @@
+
+
+const pmx = require('pmx');
+const Probe = pmx.probe();
+
+var metric = Probe.counter({
+  name    : 'Counter'
+});
+
+setInterval(function() {
+  metric.inc()
+}, 500);

examples/pmx/elements/error.js

@@ -0,0 +1,4 @@
+
+setInterval(function() {
+  new Error('toto');
+}, 10);

examples/pmx/elements/event.js

@@ -0,0 +1,9 @@
+
+const pmx = require('pmx');
+
+setInterval(function() {
+  pmx.emit('user:register', {
+    user : 'Alex registered',
+    email : '[email protected]'
+  });
+}, 200);

examples/pmx/elements/histogram.js

@@ -0,0 +1,15 @@
+
+
+const pmx = require('pmx');
+const Probe = pmx.probe();
+
+var metric = Probe.histogram({
+  name    : 'Histogram'
+});
+
+var latency;
+
+setInterval(function() {
+  latency = Math.round(Math.random() * 100);
+  metric.update(latency);
+}, 100);

examples/pmx/elements/http.js

@@ -0,0 +1,46 @@
+
+var http = require('http');
+
+http.createServer(function(req, res) {
+  res.writeHead(200);
+  setTimeout(function() {
+    res.end('transaction');
+  }, 10);
+}).listen(process.env.PORT || 9010);
+
+setInterval(function() {
+  request(['/user', '/bla', '/user/lol/delete', '/POST/POST'][Math.floor((Math.random() * 4))]);
+}, 140);
+
+function makeid()
+{
+  var text = "";
+  var possible = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
+
+  for( var i=0; i < 5; i++ )
+    text += possible.charAt(Math.floor(Math.random() * possible.length));
+
+  return text;
+}
+
+function request(path) {
+  var options = {
+    hostname: '127.0.0.1'
+    ,port: 9010
+    ,path: path || '/users'
+    ,method: 'GET'
+    ,headers: { 'Content-Type': 'application/json' }
+  };
+
+  var req = http.request(options, function(res) {
+    res.setEncoding('utf8');
+    res.on('data', function (data) {
+      //console.log(data);
+    });
+  });
+  req.on('error', function(e) {
+    console.log('problem with request: ' + e.message);
+  });
+  req.end();
+
+}

examples/pmx/elements/log-cluster.js

@@ -0,0 +1,4 @@
+setInterval(function() {
+  console.log('log');
+  console.error('log');
+}, 200);

examples/pmx/elements/log.js

@@ -0,0 +1,5 @@
+
+setInterval(function() {
+  console.log('log');
+  console.error('log');
+}, 200);

examples/pmx/elements/meter.js

@@ -0,0 +1,11 @@
+
+const pmx = require('pmx');
+const Probe = pmx.probe();
+
+var metric = Probe.meter({
+  name    : 'Meter'
+});
+
+setInterval(function() {
+  metric.mark()
+}, 200);

examples/pmx/elements/metric.js

@@ -0,0 +1,16 @@
+
+const pmx = require('pmx');
+const Probe = pmx.probe();
+
+var data = 10;
+
+var metric = Probe.metric({
+  name    : 'Realtime user',
+  value   : function() {
+    return data;
+  }
+});
+
+setInterval(function() {
+  data = Math.random();
+}, 500);

examples/pmx/elements/notify.js

@@ -0,0 +1,6 @@
+
+const pmx = require('pmx');
+
+setInterval(function() {
+  pmx.notify({ success : false });
+}, 200);

examples/pmx/elements/trace.js

@@ -0,0 +1,46 @@
+
+var http = require('http');
+
+http.createServer(function(req, res) {
+  res.writeHead(200);
+  setTimeout(function() {
+    res.end('transaction');
+  }, 10);
+}).listen(9016);
+
+setInterval(function() {
+  request(['/user', '/bla', '/user/lol/delete', '/POST/POST'][Math.floor((Math.random() * 4))]);
+}, 140);
+
+function makeid()
+{
+  var text = "";
+  var possible = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
+
+  for( var i=0; i < 5; i++ )
+    text += possible.charAt(Math.floor(Math.random() * possible.length));
+
+  return text;
+}
+
+function request(path) {
+  var options = {
+    hostname: '127.0.0.1'
+    ,port: 9016
+    ,path: path || '/users'
+    ,method: 'GET'
+    ,headers: { 'Content-Type': 'application/json' }
+  };
+
+  var req = http.request(options, function(res) {
+    res.setEncoding('utf8');
+    res.on('data', function (data) {
+      //console.log(data);
+    });
+  });
+  req.on('error', function(e) {
+    console.log('problem with request: ' + e.message);
+  });
+  req.end();
+
+}

package.json

@@ -98,7 +98,8 @@
   "description": "Production process manager for Node.JS applications with a built-in load balancer.",
   "main": "index.js",
   "scripts": {
-    "test": "NODE_ENV=test bash test/pm2_programmatic_tests.sh && NODE_ENV=test bash test/pm2_behavior_tests.sh"
+    "test": "NODE_ENV=test bash test/pm2_programmatic_tests.sh && NODE_ENV=test bash test/pm2_behavior_tests.sh",
+    "bench-pmx" : "pm2 delete all; pm2 install pm2-probe; node examples/pmx/app.js; pm2 ls"
   },
   "keywords": [
     "cli",