From 5c45a79d12cfc0f5eed440f49033d669bace1658 Mon Sep 17 00:00:00 2001
From: Michele Fadda <mikif70@gmail.com>
Date: Wed, 12 Dec 2018 13:33:26 +0100
Subject: [PATCH 1/3] split host@addr:port

---
 docker-compose/test.sh | 1 +
 influxdb.go            | 3 ++-
 main.go                | 7 +++++--
 3 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/docker-compose/test.sh b/docker-compose/test.sh
index 87d6691..233ebbf 100755
--- a/docker-compose/test.sh
+++ b/docker-compose/test.sh
@@ -11,5 +11,6 @@ docker run \
                 -r 192.168.0.1:6379 \
                 -m 192.168.0.1:27017 \
                 -d lastlogin \
+		-i test@10.39.253.206:8086 \
                 -T 80s \
                 $@
diff --git a/influxdb.go b/influxdb.go
index e0cdae4..3b96f37 100644
--- a/influxdb.go
+++ b/influxdb.go
@@ -15,7 +15,8 @@ var (
 
 func writeStats(start time.Time) {
 	if opts.Debug {
-		fmt.Printf("writing to influxdb server: %s", opts.Influxdb)
+		fmt.Printf("writing to influxdb server: %s\n", opts.Influxdb)
+		fmt.Printf("host: %s -- addr: %s\n", infhost, infdb)
 	}
 
 	c, err := influxdb.NewHTTPClient(influxdb.HTTPConfig{
diff --git a/main.go b/main.go
index fa66fb1..1ff7150 100644
--- a/main.go
+++ b/main.go
@@ -14,7 +14,7 @@ import (
 )
 
 const (
-	_Version  = "v5.0.0b2"
+	_Version  = "v5.0.0b3"
 	_Producer = 0
 	_Consumer = 1
 	_Remover  = 2
@@ -55,8 +55,11 @@ func main() {
 		//		re, _ := regexp.Compile(`(\w+)@(\d+.\d+.\d+.\d+:\d+)`)
 		if re.MatchString(opts.Influxdb) {
 			match := re.FindStringSubmatch(opts.Influxdb)
+			if opts.Debug {
+				fmt.Printf("Influxdb match: %+v\n", match)
+			}
 			infhost = match[1]
-			infdb = match[2]
+			infdb = match[2] + ":" + match[3]
 		} else {
 			opts.Influxdb = ""
 		}

From ee28cf2d89ca7834488cdbc9c249b899fd64e518 Mon Sep 17 00:00:00 2001
From: Michele Fadda <mikif70@gmail.com>
Date: Wed, 12 Dec 2018 14:35:13 +0100
Subject: [PATCH 2/3] influxdb verbose errors

---
 influxdb.go | 10 +++++++---
 main.go     |  2 +-
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/influxdb.go b/influxdb.go
index 3b96f37..242fe7c 100644
--- a/influxdb.go
+++ b/influxdb.go
@@ -3,6 +3,7 @@ package main
 
 import (
 	"fmt"
+	"log"
 	"time"
 
 	influxdb "github.com/influxdata/influxdb/client/v2"
@@ -24,7 +25,8 @@ func writeStats(start time.Time) {
 		Timeout: 2 * time.Second,
 	})
 	if err != nil {
-		fmt.Printf("Error: %+v\n", err)
+		fmt.Printf("InfluxDB connect Error: %+v\n", err)
+		log.Printf("InfluxDB connect Error: %+v\n", err)
 		return
 	}
 	defer c.Close()
@@ -34,7 +36,8 @@ func writeStats(start time.Time) {
 		Precision: "s",
 	})
 	if err != nil {
-		fmt.Printf("Error: %+v\n", err)
+		fmt.Printf("InfluxDB batch Error: %+v\n", err)
+		log.Printf("InfluxDB batch Error: %+v\n", err)
 		return
 	}
 
@@ -49,7 +52,8 @@ func writeStats(start time.Time) {
 	}
 	pt, err := influxdb.NewPoint("ll2mongo", tags, fields, start)
 	if err != nil {
-		fmt.Printf("Error: %+v\n", err)
+		fmt.Printf("InfluxDB point Error: %+v\n", err)
+		log.Printf("InfluxDB point Error: %+v\n", err)
 		return
 	}
 
diff --git a/main.go b/main.go
index 1ff7150..150966d 100644
--- a/main.go
+++ b/main.go
@@ -14,7 +14,7 @@ import (
 )
 
 const (
-	_Version  = "v5.0.0b3"
+	_Version  = "v5.0.0b4"
 	_Producer = 0
 	_Consumer = 1
 	_Remover  = 2

From abca7e21e71c040af6cd2ee66b2b84ae4f221572 Mon Sep 17 00:00:00 2001
From: Michele Fadda <mikif70@gmail.com>
Date: Wed, 12 Dec 2018 14:57:08 +0100
Subject: [PATCH 3/3] influxdb write verbose

---
 influxdb.go | 11 ++++++++++-
 main.go     |  2 +-
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/influxdb.go b/influxdb.go
index 242fe7c..be821d2 100644
--- 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
+	}
 }
diff --git a/main.go b/main.go
index 150966d..304e716 100644
--- 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