added support for client opts

README.md

@@ -51,6 +51,20 @@ Once you've got your `env` instance, here are some things you can do with it
 `env.redis` will provide you with a singleton instance of a redis client or a new instance. It will use Redis Sentinel it it's configured.
+Example configuration:
+```json
+{
+  "redisDb": 1,
+  "sentinel": {
+    "master-name": "test-master",
+    "hosts": ["localhost:46379"]
+  },
+  clientOpts: {
+    "return_buffers": true
+  }
+}
+```
+
 * `env.redis.getClient()` - returns the main singleton Redis client.
 * `env.redis.createClient([options])` - returns a new Redis client. Uses `redis` config by default.
 * `env.redis.quitClient()` - closes a Redis client (don't do this with the main singleton client)

lib/redis-client.js

@@ -55,7 +55,7 @@ function createInstance(options, logger) {
     var host = options.host;
     var port = options.port;
-    client = redis.createClient(port, host);
+    client = redis.createClient(port, host, options.clientOpts);
   }
   switchDatabase(client, options.redisDb, logger);
@@ -66,8 +66,8 @@ function registerClient(client) {
   clients.push(client);
 }
-function setupTransientClient(port, host, redisDb, logger) {
-  var client = redis.createClient(port, host);
+function setupTransientClient(port, host, redisDb, clientOpts, logger) {
+  var client = redis.createClient(port, host, clientOpts);
   switchDatabase(client, redisDb, logger);
@@ -89,13 +89,16 @@ function setupTransientClient(port, host, redisDb, logger) {
 exports.createTransientClient = function(mainClient, options, logger, callback) {
   var host, port;
+  var redisDb = options.redisDb;
+  var clientOpts = options.clientOpts;
+
   if(options.sentinel) {
     var master = mainClient.activeMasterClient;
     /* No master yet? Wait... */
     if(!master) {
       mainClient.on('reconnected', function() {
-        var client = setupTransientClient(mainClient.activeMasterClient.port, mainClient.activeMasterClient.host, options.redisDb, logger);
+        var client = setupTransientClient(mainClient.activeMasterClient.port, mainClient.activeMasterClient.host, redisDb, clientOpts, logger);
         callback(null, client);
       });
@@ -109,7 +112,7 @@ exports.createTransientClient = function(mainClient, options, logger, callback)
     port = options.port;
   }
-  var client = setupTransientClient(port, host, options.redisDb, logger);
+  var client = setupTransientClient(port, host, redisDb, clientOpts, logger);
   /* Callback in a second */
   setImmediate(function() {