Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #13664 from influxdata/add_bkt_org_scraper 

fix(gather): add bkt and org id to scraper writer
pull/13582/head
kelwang 2019-04-26 13:02:51 -04:00 committed by GitHub
parent 9a8426c3f0 d7cb7d5ffa
commit 444b571956
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gather/recorder.go
View File

@ -6,6 +6,7 @@ import (
"github.com/influxdata/influxdb/nats"
"github.com/influxdata/influxdb/storage"
"github.com/influxdata/influxdb/tsdb"
"go.uber.org/zap"
)
@ -20,6 +21,11 @@ func (s PointWriter) Record(collected MetricsCollection) error {
if err != nil {
return err
}
ps, err = tsdb.ExplodePoints(collected.OrgID, collected.BucketID, ps)
if err != nil {
return err
}
return s.Writer.WritePoints(context.TODO(), ps)
}