influxdb write verbose

2018-12-12 14:57:08 +01:00
2 changed files with 11 additions and 2 deletions
--- a/influxdb.go
+++ b/influxdb.go
@ -57,8 +57,17 @@ func writeStats(start time.Time) {
 		return
 	}

+	if opts.Debug {
+		fmt.Printf("InfluxDB pt: %+v\n", pt)
+	}
+
 	bp.AddPoint(pt)

 	// Write the batch
-	c.Write(bp)
+	err = c.Write(bp)
+	if err != nil {
+		fmt.Printf("InfluxDB write Error: %+v\n", err)
+		log.Printf("InfluxDB write Error: %+v\n", err)
+		return
+	}
 }
--- a/main.go
+++ b/main.go
@ -14,7 +14,7 @@ import (
 )

 const (
-	_Version  = "v5.0.0b4"
+	_Version  = "v5.0.0b6"
 	_Producer = 0
 	_Consumer = 1
 	_Remover  = 2