ReMo

Save data from memory to disk for async/background/slow tasks.

Metrics

Standalone ReMo

How to use the package? See this implementation.

var remo = require('remo');
var message = { .... };
remo.pool(message, function(){ ... });

Message must contain the 'action'. See attempt actions.

ReMo

Configure your queues and defaults:

# conf.json
"input"  : "db:mongo:input"   # All input queries
"retry"  : "db:mongo:retry"   # Queries not processed
"output" : "db:mongo:output"  # Output for 'find'
"errors" : "db:mongo:errors"  # Logging errors
"results": "db:mongo:results" # Logging results

Learn ReMo

Follow the step by step guide for massive queries.

## Redis List Expected Message

var redis = require('redis');
var pub = redis.createClient();

var message = conf.defaults;
message.doc = {version: 1, module: 'readme'};
message.action = 'insert';
pub.rpush(['db:mongo:input', JSON.stringify(message)], function(){});

Code Quality

apt-get install lcov
npm install gulp mocha istanbul mocha-istanbul -g
npm install gulp-jshint
gulp
mocha
make cov