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

Removed TagSet type to make it more explicit.

This commit is contained in:
Eric Fortin 2016-08-19 09:44:31 -04:00 committed by Eric
parent fbaa6f8490
commit c3b8149e11
1 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
plugins/outputs/opentsdb/opentsdb.go
View File

@ -46,17 +46,15 @@ var sampleConfig = `
debug = false
`
type TagSet map[string]string
func (t TagSet) ToLineFormat() string {
tags := make([]string, len(t))
func ToLineFormat(tags map[string]string) string {
tagsArray := make([]string, len(tags))
index := 0
for k, v := range t {
tags[index] = fmt.Sprintf("%s=%s", k, v)
for k, v := range tags {
tagsArray[index] = fmt.Sprintf("%s=%s", k, v)
index++
}
sort.Strings(tags)
return strings.Join(tags, " ")
sort.Strings(tagsArray)
return strings.Join(tagsArray, " ")
}
func (o *OpenTSDB) Connect() error {
@ -150,7 +148,7 @@ func (o *OpenTSDB) WriteTelnet(metrics []telegraf.Metric, u *url.URL) error {
for _, m := range metrics {
now := m.UnixNano() / 1000000000
tags := cleanTags(m.Tags()).ToLineFormat()
tags := ToLineFormat(cleanTags(m.Tags()))
for fieldName, value := range m.Fields() {
metricValue, buildError := buildValue(value)
@ -176,7 +174,7 @@ func (o *OpenTSDB) WriteTelnet(metrics []telegraf.Metric, u *url.URL) error {
return nil
}
func cleanTags(tags map[string]string) TagSet {
func cleanTags(tags map[string]string) map[string]string {
tagSet := make(map[string]string, len(tags))
for k, v := range tags {
tagSet[sanitizedChars.Replace(k)] = sanitizedChars.Replace(v)