ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2024-12-26 15:29:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Enable strings as field values in stdout sink

Browse Source
This commit is contained in:
Thomas Roehl 2021-05-12 17:46:16 +02:00
parent e8b2bbdae1
commit b84dc08cd6
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sinks/stdoutSink.go
View File

@ -27,9 +27,14 @@ func (s *StdoutSink) Write(measurement string, tags map[string]string, fields ma
tagsstr = append(tagsstr, fmt.Sprintf("%s=%s", k, v)) tagsstr = append(tagsstr, fmt.Sprintf("%s=%s", k, v))
} }
for k, v := range fields { for k, v := range fields {
switch v.(type) {
case float64:
if !math.IsNaN(v.(float64)) { if !math.IsNaN(v.(float64)) {
fieldstr = append(fieldstr, fmt.Sprintf("%s=%v", k, v.(float64))) fieldstr = append(fieldstr, fmt.Sprintf("%s=%v", k, v.(float64)))
} }
case string:
fieldstr = append(fieldstr, fmt.Sprintf("%s=%q", k, v.(string)))
}
} }
if len(tagsstr) > 0 { if len(tagsstr) > 0 {
fmt.Printf("%s,%s %s %d\n", measurement, strings.Join(tagsstr, ","), strings.Join(fieldstr, ","), t.Unix()) fmt.Printf("%s,%s %s %d\n", measurement, strings.Join(tagsstr, ","), strings.Join(fieldstr, ","), t.Unix())