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

Add hostname to error messages

Browse Source
This commit is contained in:
Jan Eitzinger 2024-11-20 06:57:24 +01:00
parent 60d4584d06
commit 7ee0a01eff
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/api/lineprotocol.go
View File

@ -298,7 +298,7 @@ func decodeLine(dec *lineprotocol.Decoder,
} }
if string(key) != "value" { if string(key) != "value" {
return fmt.Errorf("unkown field: '%s' (value: %#v)", string(key), val) return fmt.Errorf("host %s: unknown field: '%s' (value: %#v)", host, string(key), val)
} }
if val.Kind() == lineprotocol.Float { if val.Kind() == lineprotocol.Float {
@ -308,12 +308,12 @@ func decodeLine(dec *lineprotocol.Decoder,
} else if val.Kind() == lineprotocol.Uint { } else if val.Kind() == lineprotocol.Uint {
metric.Value = util.Float(val.UintV()) metric.Value = util.Float(val.UintV())
} else { } else {
return fmt.Errorf("unsupported value type in message: %s", val.Kind().String()) return fmt.Errorf("host %s: unsupported value type in message: %s", host, val.Kind().String())
} }
} }
if t, err = dec.Time(lineprotocol.Second, t); err != nil { if t, err = dec.Time(lineprotocol.Second, t); err != nil {
return fmt.Errorf("timestamp : %#v with error : %#v", lineprotocol.Second, err.Error()) return fmt.Errorf("host %s: timestamp : %#v with error : %#v", host, lineprotocol.Second, err.Error())
} }
if err := ms.WriteToLevel(lvl, selector, t.Unix(), []memorystore.Metric{metric}); err != nil { if err := ms.WriteToLevel(lvl, selector, t.Unix(), []memorystore.Metric{metric}); err != nil {