Added benchmarks

Author: mcollina

.gitignore

@@ -57,3 +57,10 @@ typings/
 # dotenv environment variables file
 .env
 
+# diag files
+*clinic*
+*0x*
+
+# lock files
+
+package-lock.json

README.md

@@ -26,7 +26,8 @@ const server = Fastify()
 
 server.register(proxy, {
   upstream,
-  prefix: '/upstream' // optional
+  prefix: '/upstream', // optional
+  http2: false // optional
 })
 
 server.listen(3000)
@@ -53,11 +54,20 @@ The prefix to mount this plugin on. This is provided by fastify itself.
 A `beforeHandler` to be applied on all routes. Useful for performing
 authentication.
 
+### http2
+
+A `beforeHandler` to be applied on all routes. Useful for performing
+authentication.
+
+## Benchmarks
+
+The following benchmarks where generate on a Macbook 2018 with i5 and
+8GB of RAM.
+
 ## TODO
 
 * [ ] Generate unique request ids and implement request tracking
 * [ ] Perform validations for incoming data
-* [ ] Benchmarks
 
 ## License
 

benchmarks/express-http-proxy.js

@@ -0,0 +1,8 @@
+'use strict'
+
+var proxy = require('express-http-proxy')
+var app = require('express')()
+
+app.use('/', proxy('localhost:3001'))
+
+app.listen(3000)

benchmarks/fastify-proxy.js

@@ -0,0 +1,17 @@
+'use strict'
+
+const Fastify = require('fastify')
+const proxy = require('..')
+
+async function startProxy (upstream) {
+  const server = Fastify()
+  server.register(proxy, {
+    upstream,
+    http2: !!process.env.HTTP2
+  })
+
+  await server.listen(3000)
+  return server
+}
+
+startProxy('http://localhost:3001')

benchmarks/http-proxy.js

@@ -0,0 +1,20 @@
+'use strict'
+
+var httpProxy = require('http-proxy')
+var { Agent } = require('http')
+
+var proxy = httpProxy.createProxyServer({
+  target: 'http://localhost:3001',
+  agent: new Agent({
+    keepAlive: true,
+    keepAliveMsecs: 60 * 1000, // 1 minute
+    maxSockets: 2048,
+    maxFreeSockets: 2048
+  })
+})
+
+proxy.on('error', function (e) {
+  console.log(e)
+})
+
+proxy.listen(3000)

benchmarks/origin.js

@@ -0,0 +1,29 @@
+'use strict'
+
+const Fastify = require('fastify')
+
+async function startOrigin () {
+  const origin = Fastify({
+    http2: !!process.env.HTTP2
+  })
+  origin.get('/', async (request, reply) => {
+    return 'this is root'
+  })
+
+  origin.get('/a', async (request, reply) => {
+    return 'this is a'
+  })
+
+  origin.post('/this-has-data', async (request, reply) => {
+    if (request.body.hello === 'world') {
+      return { something: 'posted' }
+    }
+    throw new Error('kaboom')
+  })
+
+  await origin.listen(3001)
+
+  return origin
+}
+
+startOrigin()

index.js

@@ -10,7 +10,8 @@ module.exports = async function (fastify, opts) {
   const beforeHandler = opts.beforeHandler
 
   fastify.register(From, {
-    base: opts.upstream
+    base: opts.upstream,
+    http2: opts.http2
   })
 
   fastify.addContentTypeParser('application/json', bodyParser)

package.json

@@ -22,17 +22,20 @@
   },
   "homepage": "https://github.com/fastify/fastify-http-proxy#readme",
   "devDependencies": {
-    "fastify": "^1.4.0",
+    "express": "^4.16.3",
+    "express-http-proxy": "^1.2.0",
+    "fastify": "^1.5.0",
     "got": "^8.3.1",
     "http-errors": "^1.6.3",
+    "http-proxy": "^1.17.0",
     "make-promises-safe": "^1.1.0",
     "pre-commit": "^1.2.2",
-    "simple-get": "^2.8.1",
+    "simple-get": "^3.0.0",
     "snazzy": "^7.1.1",
     "standard": "^11.0.0",
     "tap": "^12.0.0"
   },
   "dependencies": {
-    "fastify-reply-from": "^0.4.1"
+    "fastify-reply-from": "^0.4.2"
   }
 }