All files / Nodejs/connectors index.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
"use strict";
let extend = require("extend");
 
module.exports = function (configure) {
	configure = configure || {};
 
	process.__config = process.__config || configure;
	process.__config.registry = process.__config.registry || {};
	configure.registry = extend(true, process.__config.registry, configure.registry || {});
	return {
		elasticsearch: {
			write: require("./elasticsearch/toES.js")(configure).stream
		}
	}
};