elasticsearch-loop
Advanced tools
Comparing version 0.3.1 to 0.3.2
@@ -6,2 +6,7 @@ var elasticsearch = require('elasticsearch') | ||
this._connection = null | ||
this._debug = false | ||
this.reset() | ||
} | ||
reset () { | ||
this._total = 0 | ||
@@ -12,3 +17,2 @@ this._dataAmount = 0 | ||
this._firstLoop = true | ||
this._debug = false | ||
this.loopCallback = null | ||
@@ -39,2 +43,3 @@ this.successCallback = null | ||
query (queryDsl, loopCallback) { | ||
this.reset() | ||
const returnData = [] | ||
@@ -41,0 +46,0 @@ return new Promise((resolve, reject) => { |
{ | ||
"name": "elasticsearch-loop", | ||
"version": "0.3.1", | ||
"version": "0.3.2", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -49,2 +49,4 @@ # Elasticsearch loop | ||
q: 'time:[2016-01-01 TO 2016-12-31]', | ||
}, (msg) => { | ||
// Incase you want to retrieve every message | ||
}) | ||
@@ -51,0 +53,0 @@ console.log(res) |
7775
6
196
59