var RedisBroadcast = require('redis-broadcast');
 
// Define the redis servers, and whether or not
// they should be written to via child processes
var myRedisServers = new RedisBroadcast({
    primary: [6379, 'localhost'],
    secondary: [6379, 'some.other.server'],
    tertiary: [6379, 'and.another.server'],
    quaternary: [6379, 'and.another']
}, {
    useChildProcesses: false,
    customMethods: {
        setnxOnce: [
            function setnxOnce(key, val, callback) {
                this.setnx(key, val, function(err, result) {
                    if(err || !result) {
                        callback(err || new Error('key already defined'));
                    } else {
                        callback(null, result);
                    }
                });
            },
            'set'
        ]
    }
});
 
// Write to only one server
var writePrimary = myRedisServers.writeTo('primary');
writePrimary.set('foo', 'bar', callback);
// Callback gets an object with the key being 'primary' and the value being an array of [err, result]
// { primary: 'OK' }
 
// Write to all servers
var writeAll = myRedisServers.writeTo('all');
writeAll.set('true', false, callback);
// Callback gets object of [err, result] arrays, keys matching server names
// {
//     primary: 'OK',
//     secondary: 'OK',
//     tertiary: 'OK',
//     quaternary: 'OK'
// }
 
// Write to a pair of servers in parallel
var writePrimarySecondary = myRedisServers.writeTo(['primary', 'secondary']);
writePrimarySecondary.set('fubar', true, callback);
// Gets object of [err, result] arrays, keys matching server names
// {
//     primary: 'OK',
//     secondary: 'OK'
// }
 
// Write to three servers in series, stopping if any returns an error
var write123 = myRedisServers.writeTo('primary').thenTo('secondary').thenTo('tertiary');
write123.set('hello', 'world', callback);
// Gets array of objects of [err, result] arrays, keys matching server names, order of objects matching write order
// [
//     { primary: 'OK' },
//     { secondary: 'OK' },
//     { tertiary: 'OK' }
// ]
 
// Write to primary, then all remaining servers in parallel if no error
var writePrimaryThenRemaining = myRedisServers.writeTo('primary').thenTo('remaining');
writePrimaryThenRemaining.set('distributedOnlyIfSuccessful', true, callback);
// Gets an array; first value is an object with the primary key and an [err, result] array value,
// second is an object of [err, result] arrays, keys matching server names
// [
//     { primary: 'OK' },
//     {
//         secondary: 'OK',
//         tertiary: 'OK',
//         quaternary: 'OK'
//     }
// ]
 
// Write to primary, then all remaining servers in parallel if key doesn't already exist.
// NOTE: Custom functions must be 'pure' (not closures) to work on the child process.
var writePrimaryThenRemainingIfNew = myRedisServers.writeTo('primary').thenTo('remaining');
writePrimaryThenRemainingIfNew.setnxOnce('newkey', true, callback);
// Gets an array, the first array element gets the results of setnx, the second gets the results of set, if called
// [
//     { primary: 1 },
//     {
//         secondary: 'OK',
//         tertiary: 'OK',
//         quaternary: 'OK
//     }
// ]