causeway

Link individual or groups applications together via Redis to create modular full stack node systems.

API

    var causeway = require('../../index')()
    // register redis profiles
    .register({
        'default': {
            port: 6379,
            host: '0.0.0.0'
        },
        'special': {
            port: 5678,
            host:'0.0.0.0'
        }
    });

    /**
     * Host
     */

    // listen on a redis connection
    causeway.listen('default')

    // switch on job events
    .when('load_user', function (job, args, done) {
        console.log('Process job: ' + job + ', with args: ' + JSON.stringify(args, null, 4));

        // call callback on completion with response
        done({ status: 'success' });

        // if you have an error, pass it in `.err`
        // so the client can have their promises rejected
        done({ err: 'You did something totally wrong' });
    });

    /**
     * Client
     */

    // Connect to host via redis profile
    var client = causeway.using('default');

    // On handshake completion
    client.on('handshake', function (key) {
        console.log('Handshake with client with key: ' + key);

        // request job from host
        client.request('load_user', 'iyad').then(function (response) {

            // callback on job completion
            console.log('Response for load_user job: '+ JSON.stringify(response));
        }, function (response) {
            console.log('We had an error: ' + response.err);
        });
    });

###Tests

npm install && npm test

Benchmarks

npm run bench