feat: add config.client.weakDependent (#30)

README.md

@@ -85,8 +85,8 @@ config.redis = {
 config.redis = {
   client: {
     sentinels: [{          // Sentinel instances
-      port: 26379,         // Sentinel port  
-      host: '127.0.0.1',   // Sentinel host  
+      port: 26379,         // Sentinel port
+      host: '127.0.0.1',   // Sentinel host
     }],
     name: 'mymaster',      // Master name
     password: 'auth',
@@ -133,6 +133,20 @@ config.redis = {
 }
 ```
 
+**weakDependent**
+
+```javascript
+config.redis = {
+  client: {
+    port: 6379,          // Redis port
+    host: '127.0.0.1',   // Redis host
+    password: 'auth',
+    db: 0,
+    weakDependent: true, // this redis instance won't block app start
+  },
+}
+```
+
 ## Usage
 
 In controller, you can use `app.redis` to get the redis instance, check [ioredis](https://github.com/luin/ioredis#basic-usage) to see how to use.

lib/redis.js

@@ -52,6 +52,14 @@ function createClient(config, app) {
 
   app.beforeStart(async () => {
     const index = count++;
+    if (config.weakDependent) {
+      app.coreLogger.info(`[egg-redis] instance[${index}] is weak dependent and won't block app start`);
+      client.once('ready', () => {
+        app.coreLogger.info(`[egg-redis] instance[${index}] status OK`);
+      });
+      return;
+    }
+
     await awaitFirst(client, [ 'ready', 'error' ]);
     app.coreLogger.info(`[egg-redis] instance[${index}] status OK, client ready`);
   });

test/fixtures/apps/redisapp-weakdependent/app/controller/home.js

@@ -0,0 +1,11 @@
+'use strict';
+
+module.exports = app => {
+  return class HomeController extends app.Controller {
+    * index() {
+      const { ctx, app } = this;
+      yield app.redis.set('foo', 'bar');
+      ctx.body = yield app.redis.get('foo');
+    }
+  };
+};

test/fixtures/apps/redisapp-weakdependent/app/router.js

@@ -0,0 +1,5 @@
+'use strict';
+
+module.exports = function(app) {
+  app.get('/', 'home.index');
+};

test/fixtures/apps/redisapp-weakdependent/config/config.js

@@ -0,0 +1,20 @@
+'use strict';
+
+exports.redis = {
+  client: {
+    weakDependent: true,
+    host: '127.0.0.1',
+    port: 6379,
+    password: '',
+    db: '0',
+  },
+  agent:true,
+};
+
+exports.logger = {
+  coreLogger: {
+    level: 'INFO',
+  },
+};
+
+exports.keys = 'keys';

test/fixtures/apps/redisapp-weakdependent/package.json

@@ -0,0 +1,3 @@
+{
+  "name": "redisapp-weakdependent"
+}

test/redis.test.js

@@ -25,6 +25,25 @@ describe('test/redis.test.js', () => {
     });
   });
 
+  describe('weak dependent', () => {
+    let app;
+    before(async () => {
+      app = mm.app({
+        baseDir: 'apps/redisapp-weakdependent',
+      });
+      await app.ready();
+    });
+    after(() => app.close());
+    afterEach(mm.restore);
+
+    it('should query', () => {
+      return request(app.callback())
+        .get('/')
+        .expect(200)
+        .expect('bar');
+    });
+  });
+
   describe('single client supportTimeCommand = false', () => {
     let app;
     before(async () => {