diff --git a/influxdb.go b/influxdb.go index c193057..fdb4fc8 100644 --- a/influxdb.go +++ b/influxdb.go @@ -3,11 +3,12 @@ package main import ( "fmt" + "time" influxdb "github.com/influxdata/influxdb/client/v2" ) -func writeStats() { +func writeStats(start time.Time) { if opts.Debug { fmt.Printf("writing to influxdb server: %s", opts.Influxdb) } @@ -39,7 +40,7 @@ func writeStats() { "dup": count.GetDup(), "stop": count.GetTime(), } - pt, err := influxdb.NewPoint("ll2mongo", tags, fields) + pt, err := influxdb.NewPoint("ll2mongo", tags, fields, start) if err != nil { fmt.Printf("Error: %+v\n", err) return diff --git a/main.go b/main.go index b803261..0d17b7f 100644 --- a/main.go +++ b/main.go @@ -11,7 +11,7 @@ import ( ) const ( - _VERSION = "v2.5.0" + _VERSION = "v2.5.1" ) var ( @@ -107,7 +107,7 @@ func main() { log.Printf("Stop %v - user: %d - login: %d - errors: %d - rem: %d - duplicate: %d\n\r", count.GetTime(), count.GetUser(), count.GetLog(), count.GetErr(), count.GetRem(), count.GetDup()) if opts.Influxdb != "" { - writeStats() + writeStats(start) } if opts.Xymon != "" {