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

Allow other fields not only field "value"

Browse Source
This commit is contained in:
Holger Obermaier 2023-09-18 16:35:56 +02:00
parent 3f4b11db47
commit 64ffa3d23e
1 changed files with 16 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
sinks/httpSink.go
View File

@ -43,23 +43,24 @@ func (s *HttpSink) Write(m lp.CCMetric) error {
p := m.ToPoint(s.meta_as_tags) p := m.ToPoint(s.meta_as_tags)
s.lock.Lock() s.lock.Lock()
firstWriteOfBatch = len(s.encoder.Bytes()) == 0 firstWriteOfBatch = len(s.encoder.Bytes()) == 0
v, ok := m.GetField("value")
if ok {
s.encoder.StartLine(p.Name()) s.encoder.StartLine(p.Name())
for _, v := range p.TagList() { for _, v := range p.TagList() {
s.encoder.AddTag(v.Key, v.Value) s.encoder.AddTag(v.Key, v.Value)
}
s.encoder.AddField("value", influx.MustNewValue(v))
s.encoder.EndLine(p.Time())
err = s.encoder.Err()
if err != nil {
cclog.ComponentError(s.name, "encoding failed:", err.Error())
s.lock.Unlock()
return err
}
} }
for _, v := range p.FieldList() {
s.encoder.AddField(v.Key, influx.MustNewValue(v.Value))
}
s.encoder.EndLine(p.Time())
err = s.encoder.Err()
if err != nil {
cclog.ComponentError(s.name, "encoding failed:", err.Error())
s.lock.Unlock()
return err
}
s.lock.Unlock() s.lock.Unlock()
if s.flushDelay == 0 { if s.flushDelay == 0 {