Skip to content

Instantly share code, notes, and snippets.

@davidfooks
Created April 26, 2012 13:41
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save davidfooks/2499700 to your computer and use it in GitHub Desktop.
Save davidfooks/2499700 to your computer and use it in GitHub Desktop.
Testing replicaset
var mongodb = require('mongodb');
var ReplSetServers = mongodb.ReplSetServers;
var Server = mongodb.Server;
var Db = mongodb.Db;
var replSet = new ReplSetServers([
new Server('127.0.0.1', 27019, { auto_reconnect: true }),
new Server('127.0.0.1', 27020, { auto_reconnect: true }) ,
new Server('127.0.0.1', 27021, { auto_reconnect: true })
],
{
rs_name: 'myset'
}
);
var db = new Db('integration_test_', replSet, {'reaper': true});
function dbOpen(err, p_db)
{
console.log('connection open');
db.createCollection("test", function (err, collection)
{
console.log('created collection');
function addStuff()
{
function didItWork(err)
{
console.log(err);
}
console.log('addStuff');
collection.insert({"test": Date.now()}, {safe: true}, didItWork);
}
collection.remove({});
setInterval(addStuff, 1000);
});
}
db.open(dbOpen);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment