bunyan-influxdb
Advanced tools
Comparing version 0.5.0 to 0.5.1
@@ -55,2 +55,3 @@ 'use strict'; | ||
InfluxDBStream.prototype.processCargo = function (tasks, callback) { | ||
var self = this; | ||
var dbs = {}; | ||
@@ -70,4 +71,4 @@ tasks.map(function (t) { | ||
{ | ||
times: this.options.tries || 1, | ||
interval: this.options.tryInterval || 5000 | ||
times: self.options.tries || 1, | ||
interval: self.options.tryInterval || 5000 | ||
}, | ||
@@ -80,3 +81,3 @@ | ||
} | ||
this.client.writePoints(dbs[db], options) | ||
self.client.writePoints(dbs[db], options) | ||
.then(clbk) | ||
@@ -86,4 +87,4 @@ .catch(function (err) { | ||
clbk(err); | ||
}.bind(this)) | ||
}.bind(this), | ||
}) | ||
}, | ||
@@ -90,0 +91,0 @@ callback |
{ | ||
"name": "bunyan-influxdb", | ||
"version": "0.5.0", | ||
"version": "0.5.1", | ||
"description": "Bunyan InfluxDB Stream", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
80
3805