An object storing functions by key. These can be then executed grouped by key.
Useful to coordinate execution across different processes.
Uses Redis pub/sub.
var FunctionBus = require('function-bus-redis');
var functionBus = new FunctionBus();
// queue functions by key
functionBus.queue('a', func1);
functionBus.queue('a', func2);
functionBus.queue('b', func3);
// number of functions queued by key
functionBus.len('a'); // 2
functionBus.len('b'); // 1
functionBus.len('c'); // 0
// execute the 2 functions with key "a"
// passing 3 arguments: 1, 2, 3
functionBus.execute('a', [1, 2, 3]);It works also across different processes connected to the same redis.
Options:
- serialize [optional]: function used to serialize the values when they are sent to redis
- deserialize [optional]: function used to deserialize the values when they are received from redis
- channelPrefix [optional]: the prefix used for redis pub/sub
- redisConfig [optional]: node-redis configuration
- pub/sub [optional]: redisClients (2 different!). If they are not passed they are created using redisConfig.