| 1 |
|
| 2 |
|
| 3 | module.exports = function(cb){
|
| 4 |
|
| 5 |
|
| 6 | var env = this;
|
| 7 | var config = env.config;
|
| 8 | if(!config.elastic) return cb();
|
| 9 |
|
| 10 | var elasticsearch = require('elasticsearch');
|
| 11 | var elastic = new elasticsearch.Client(config.elastic);
|
| 12 |
|
| 13 | elastic.ping({
|
| 14 | requestTimeout: config.elastic.connect_timeout || 5000,
|
| 15 | },function(err){
|
| 16 | if(err) return cb(err);
|
| 17 | env.engines.elastic = elastic;
|
| 18 | env.i.do("log.sys", "elasticsearch", "Connected to ElasticSearch on "+(config.elastic.host || "localhost:9200"));
|
| 19 | cb();
|
| 20 | });
|
| 21 |
|
| 22 | } |
| \ | No newline at end of file |