Redis Connection Pool

gistfile1.js

'use strict';
var uri = require('../util/url');
var pool = require('generic-pool');
var driver = require('redis');
var flag = require('node-env-flag');

module.exports = function(url) {
  var connection_settings = uri(url || process.env.REDIS_URL);

  return pool.Pool({
    name: 'redis',
    create: function(callback) {
      var redis = require('redis');
      var client = redis.createClient(connection_settings.port, connection_settings.hostname, connection_settings.server);

      if (connection_settings.password) {
        client.auth(connection_settings.password, function(err, reply) {
          if (err) {
            callback(err, null);
            return;
          }

          callback(null, client);
        });
      } else {
        callback(null, client);
      }
    },
    destroy: function(client) {
      client.end();
    },
    max: process.env.POOL_MAX_REDIS || 10,
    min: process.env.POOL_MIN_REDIS || 1,
    idleTimeoutMillis: process.env.POOL_TIMEOUT_REDIS || 10000,
    log: flag(process.env.POOL_LOG_REDIS, false)
  });
};