dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Make AddFieldsWithTime usable

This commit is contained in:
Eugene Dementiev 2015-10-10 13:11:19 +03:00
parent 0bc76f094a
commit b76027e244
1 changed files with 11 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
accumulator.go
View File

@ -103,60 +103,22 @@ func (bp *BatchPoints) Add(
}) })
} }
// AddFieldsWithTime adds a measurement with a provided timestamp
func (bp *BatchPoints) AddFieldsWithTime(
measurement string,
fields map[string]interface{},
tags map[string]string,
timestamp time.Time,
) {
// TODO this function should add the fields with the timestamp, but that will
// need to wait for the InfluxDB point precision/unit to be fixed
bp.AddFields(measurement, fields, tags)
// bp.mu.Lock()
// defer bp.mu.Unlock()
// measurement = bp.Prefix + measurement
// if bp.Config != nil {
// if !bp.Config.ShouldPass(measurement, tags) {
// return
// }
// }
// if bp.Debug {
// var tg []string
// for k, v := range tags {
// tg = append(tg, fmt.Sprintf("%s=\"%s\"", k, v))
// }
// var vals []string
// for k, v := range fields {
// vals = append(vals, fmt.Sprintf("%s=%v", k, v))
// }
// sort.Strings(tg)
// sort.Strings(vals)
// fmt.Printf("> [%s] %s %s\n", strings.Join(tg, " "), measurement, strings.Join(vals, " "))
// }
// bp.Points = append(bp.Points, client.Point{
// Measurement: measurement,
// Tags: tags,
// Fields: fields,
// Time: timestamp,
// })
}
// AddFields will eventually replace the Add function, once we move to having a // AddFields will eventually replace the Add function, once we move to having a
// single plugin as a single measurement with multiple fields // single plugin as a single measurement with multiple fields
func (bp *BatchPoints) AddFields( func (bp *BatchPoints) AddFields(
measurement string, measurement string,
fields map[string]interface{}, fields map[string]interface{},
tags map[string]string, tags map[string]string,
) {
bp.AddFieldsWithTime(measurement, fields, tags, time.Time{})
}
// AddFieldsWithTime adds a measurement with a provided timestamp
func (bp *BatchPoints) AddFieldsWithTime(
measurement string,
fields map[string]interface{},
tags map[string]string,
timestamp time.Time,
) { ) {
bp.mu.Lock() bp.mu.Lock()
defer bp.mu.Unlock() defer bp.mu.Unlock()
@ -192,5 +154,6 @@ func (bp *BatchPoints) AddFields(
Measurement: measurement, Measurement: measurement,
Tags: tags, Tags: tags,
Fields: fields, Fields: fields,
Time: timestamp,
}) })
} }