feat: add support for redis+sentinel url

package.json

@@ -36,6 +36,7 @@
     "bunyan": "^1.8.12",
     "express": "^4.17.1",
     "prom-client": "^12.0.0",
+    "redis-url-plus": "^1.0.0",
     "tslib": "^2.0.0",
     "uuid": "^8.0.0",
     "yargs": "^15.1.0"

src/metricCollector.ts

@@ -3,6 +3,7 @@ import * as Logger from 'bunyan';
 import { EventEmitter } from 'events';
 import IoRedis from 'ioredis';
 import { register as globalRegister, Registry } from 'prom-client';
+import redisUrlPlus from 'redis-url-plus';
 
 import { logger as globalLogger } from './logger';
 import { getJobCompleteStats, getStats, makeGuages, QueueGauges } from './queueGauges';
@@ -44,7 +45,7 @@ export class MetricCollector {
   ) {
     const { logger, autoDiscover, redis, metricPrefix, ...bullOpts } = opts;
     this.redisUri = redis;
-    this.defaultRedisClient = new IoRedis(this.redisUri);
+    this.defaultRedisClient = new IoRedis(redisUrlPlus(this.redisUri));
     this.defaultRedisClient.setMaxListeners(32);
     this.bullOpts = bullOpts;
     this.logger = logger || globalLogger;
@@ -56,7 +57,7 @@ export class MetricCollector {
     if (_type === 'client') {
       return this.defaultRedisClient!;
     }
-    return new IoRedis(this.redisUri, redisOpts);
+    return new IoRedis(Object.assign(redisUrlPlus(this.redisUri), redisOpts));
   }
 
   private addToQueueSet(names: string[]): void {

src/redis-url-plus.d.ts

@@ -0,0 +1,3 @@
+declare module 'redis-url-plus' {
+    export default function redisUrlPlus(url: string): import('ioredis').RedisOptions;
+}