redis-cluster-client

Automatic Redis Failover

npm install redis-cluster-client
4 downloads in the last week
8 downloads in the last month

redis-failover-in-nodejs

Automatic Redis Failover

build status

Installation

This module is installed via npm:

$ npm install redis-failover-node

Example Usage

var expect = require('expect.js'),
    ClusterClient = require('redis-cluster-client');

describe('testcase for cluster client', function() {
    it('client for', function(done) {
        this.timeout(100000000);
        var options = {zkservers:'localhost:6388,localhost:2181'};
        var client = new ClusterClient(options);
        client.init();
        client.on('error', function(err) {
            console.error('err:%s', err);
            done();
        });

        client.on('connect', function(client) {
            var count = 0;
            function batch() {
                setTimeout(function() {
                    client.clientFor(count, function(err, c) {
                        // console.log('%s:%d set %d %d', c.host, c.port, count, count);
                        c.set(count, count, function() {
                            count += 1;
                            if (count > 1000) {
                                console.log('exit.');
                                done();
                            }
                            console.log('count:%d', count);
                            c.release();
                            process.nextTick(batch);
                        });
                    });
                }, 1000);
            }
            batch();
        });
    });



    it.only('cluster command', function(done) {
        this.timeout(100000000);
        var options = {zkservers:'localhost:6388,localhost:2181'};
        var client = new ClusterClient(options);
        client.init();
        client.on('error', function(err) {
            console.error('err:%s', err);
            done();
        });
        client.on('connect', function(client) {
            var count = 0;
            function batch() {
                setTimeout(function() {
                    client.set(count, count, function() {
                            count += 1;
                            if (count > 1000) {
                                console.log('exit.');
                                done();
                            }
                            console.log('count:%d', count);
                            process.nextTick(batch);
                    });
                }, 1000);
            }
            batch();
        });
    });

    process.on("uncaughtException", function (error) {
        console.log('uncaught Exception:%j', error.stack);
    });

});
npm loves you