bunyan-influxdb - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

lib/influx.js

 'use strict';
 
-var stream = require('stream');
-var util = require('util');
+var stream   = require('stream');
+var util     = require('util');
 var Writable = stream.Writable;
-var influx = require('influx');
+var influx   = require('influx');
+var async    = require('async');
 
@@ -34,13 +35,13 @@
 
-  if( point.length && point.split ) {
-    point = '"' + point + '"';
-  }
+  async.retry({times: 3, interval: 3000}, function( clbk, results ){
+    //console.log( "Write Point ", series, point, tags, time );
+    this.clientInflux.writePoint( series, point, tags, time, function(err) {
+      if(err) {
+        console.error( "Influxdb write error ", err );
+      }
+      clbk && clbk( err );
+    }.bind(this));
+  }.bind(this), function(err, result) {
+  }.bind(this));
 
-  //console.log( "Write Point ", series, point, tags, time );
-  this.clientInflux.writePoint( series, point, tags, time, function(err) {
-    if(err) {
-      console.error( "Error ", err );
-    }
-  });
-
 };
@@ -47,0 +48,0 @@

package.json

 {
   "name": "bunyan-influxdb",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Bunyan InfluxDB Stream",
@@ -12,4 +12,5 @@ "main": "index.js",
   "dependencies": {
+    "async": "^1.5.0",
     "influx": "^4.0.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

2942

increased by6.56%

Lines of code

42

increased by5%

Worsened metrics

Dependency count

2

increased by100%

Dependency changes

• + Addedasync@^1.5.0

• + Addedasync@1.5.2(transitive)