#mongo-oplog-observable

Creates an observable from a mongodb-oplog.

Install

npm install --save mongo-oplog-observable

Usage

OplogObservable(config)

• config.uri [String] mongodb connection-string
• config.ns [String] database, database.*, *.database, (databaseA|databaseB), database.collection, (db|dbX|dbY)$, etc.

Examples

var OplogObservable = require('mongo-oplog-observable');

var oplog = OplogObservable({
	uri: 'mongodb://127.0.0.1:12345/local', 
	ns: 'myDatabase.myCollection'
});

var inserts = oplog.filter(function(e){ return e.op === 'i'; });
var updates = oplog.filter(function(e){ return e.op === 'u'; });
var deletes = oplog.filter(function(e){ return e.op === 'd'; });

oplog.subscribe(
	function onNext(event){
		console.log('Next');
		console.log(event);
	},
	function onError(err){
		console.log('Error');
		console.log(err);
	},
	function onCompleted() {
		console.log('Completed');
	}
);

#Author

Christian Blaschke [email protected]