multiple-redis
Advanced tools
Comparing version 0.0.3 to 0.0.4
@@ -10,2 +10,4 @@ <a name="MultiRedisClient"></a> | ||
* [new MultiRedisClient(params)](#new_MultiRedisClient_new) | ||
* [.connected](#MultiRedisClient.connected) : <code>boolean</code> | ||
* [.server_info](#MultiRedisClient.server_info) : <code>object</code> | ||
* [#resetState()](#MultiRedisClient+resetState) ℗ | ||
@@ -31,2 +33,12 @@ * [.setupPrototype()](#MultiRedisClient.setupPrototype) ℗ | ||
<a name="MultiRedisClient.connected"></a> | ||
### MultiRedisClient.connected : <code>boolean</code> | ||
True when at least one internal redis client is connected. | ||
**Access:** public | ||
<a name="MultiRedisClient.server_info"></a> | ||
### MultiRedisClient.server_info : <code>object</code> | ||
After the ready probe completes, the results from the INFO command are saved in this attribute. | ||
**Access:** public | ||
<a name="MultiRedisClient+resetState"></a> | ||
@@ -33,0 +45,0 @@ ### MultiRedisClient#resetState() ℗ |
@@ -36,4 +36,2 @@ 'use strict'; | ||
} | ||
self.resetState(); | ||
} else { | ||
@@ -52,2 +50,4 @@ var options = params.options || {}; | ||
self.resetState(); | ||
//proxy events | ||
@@ -68,2 +68,3 @@ ['ready', 'connect', 'error', 'end', 'drain', 'idle', 'message', 'pmessage', 'subscribe', 'psubscribe', 'unsubscribe', 'punsubscribe'].forEach(function createProxy(event) { | ||
self.on('connect', onStateChange); | ||
self.on('ready', onStateChange); | ||
self.on('error', onStateChange); | ||
@@ -77,2 +78,28 @@ self.on('end', onStateChange); | ||
/** | ||
* True when at least one internal redis client is connected. | ||
* | ||
* @member {boolean} | ||
* @alias MultiRedisClient.connected | ||
* @memberof! MultiRedisClient | ||
* @public | ||
*/ | ||
MultiRedisClient.prototype.connected = false; | ||
/*jshint camelcase: false*/ | ||
//jscs:disable requireCamelCaseOrUpperCaseIdentifiers | ||
/*eslint-disable camelcase*/ | ||
/** | ||
* After the ready probe completes, the results from the INFO command are saved in this attribute. | ||
* | ||
* @member {object} | ||
* @alias MultiRedisClient.server_info | ||
* @memberof! MultiRedisClient | ||
* @public | ||
*/ | ||
MultiRedisClient.prototype.server_info = null; | ||
/*eslint-enable camelcase*/ | ||
//jscs:enable requireCamelCaseOrUpperCaseIdentifiers | ||
/*jshint camelcase: true*/ | ||
/** | ||
* Resets the redis attributes based on the status of the internal redis clients. | ||
@@ -79,0 +106,0 @@ * |
{ | ||
"name": "multiple-redis", | ||
"version": "0.0.3", | ||
"version": "0.0.4", | ||
"description": "Run redis commands against multiple redis instances.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -127,2 +127,3 @@ # multiple-redis | ||
| ----------- | ------- | ----------- | | ||
| 2015-09-03 | v0.0.4 | Maintenance | | ||
| 2015-09-03 | v0.0.3 | Added support for connected and server_info attributes. | | ||
@@ -129,0 +130,0 @@ | 2015-09-03 | v0.0.2 | Initial release. | |
@@ -201,3 +201,3 @@ 'use strict'; | ||
assert.isFalse(client.connected); | ||
assert.isUndefined(client.server_info); | ||
assert.isNull(client.server_info); | ||
}); | ||
@@ -215,3 +215,3 @@ | ||
assert.isFalse(client.connected); | ||
assert.isUndefined(client.server_info); | ||
assert.isNull(client.server_info); | ||
@@ -248,2 +248,28 @@ EventEmitterEnhancer.modifyInstance(client); | ||
}); | ||
it('connect for multiple proxy clients', function () { | ||
var client1 = new EventEmitter(); | ||
client1.connected = false; | ||
client1.server_info = 'server1'; | ||
var multipleClient1 = MultipleRedis.createClient(client1); | ||
var client2 = new EventEmitter(); | ||
client2.connected = true; | ||
client2.server_info = 'server2'; | ||
var multipleClient2 = MultipleRedis.createClient(client2); | ||
var client3 = new EventEmitter(); | ||
client3.connected = true; | ||
client3.server_info = 'server3'; | ||
var multipleClient3 = MultipleRedis.createClient(client3); | ||
assert.isFalse(multipleClient1.connected); | ||
assert.isNull(multipleClient1.server_info); | ||
assert.isTrue(multipleClient2.connected); | ||
assert.equal(multipleClient2.server_info, 'server2'); | ||
assert.isTrue(multipleClient3.connected); | ||
assert.equal(multipleClient3.server_info, 'server3'); | ||
}); | ||
}); | ||
@@ -250,0 +276,0 @@ |
67475
1090
134