Compare commits
1 commit
Author | SHA1 | Date | |
---|---|---|---|
abca7e21e7 |
2 changed files with 11 additions and 2 deletions
11
influxdb.go
11
influxdb.go
|
@ -57,8 +57,17 @@ func writeStats(start time.Time) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if opts.Debug {
|
||||||
|
fmt.Printf("InfluxDB pt: %+v\n", pt)
|
||||||
|
}
|
||||||
|
|
||||||
bp.AddPoint(pt)
|
bp.AddPoint(pt)
|
||||||
|
|
||||||
// Write the batch
|
// 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
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
2
main.go
2
main.go
|
@ -14,7 +14,7 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
_Version = "v5.0.0b4"
|
_Version = "v5.0.0b6"
|
||||||
_Producer = 0
|
_Producer = 0
|
||||||
_Consumer = 1
|
_Consumer = 1
|
||||||
_Remover = 2
|
_Remover = 2
|
||||||
|
|
Loading…
Add table
Reference in a new issue