ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-04-08 22:45:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

Move publication of metrics into Flush() for NatsSink

Browse Source
This commit is contained in:
Thomas Roehl 2022-01-24 16:11:37 +01:00
parent a111389c75
commit 89283fa419
1 changed files with 6 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
sinks/natsSink.go
View File

@ -57,31 +57,22 @@ func (s *NatsSink) Init(config sinkConfig) error {
func (s *NatsSink) Write(point lp.CCMetric) error { func (s *NatsSink) Write(point lp.CCMetric) error {
if s.client != nil { if s.client != nil {
// var tags map[string]string
// var fields map[string]interface{}
// for _, t := range point.TagList() {
// tags[t.Key] = t.Value
// }
// for _, f := range point.FieldList() {
// fields[f.Key] = f.Value
// }
// m, err := protocol.New(point.Name(), tags, fields, point.Time())
// if err != nil {
// log.Print(err)
// return err
// }
_, err := s.encoder.Encode(point) _, err := s.encoder.Encode(point)
if err != nil { if err != nil {
log.Print(err) log.Print(err)
return err return err
} }
s.client.Publish(s.database, s.buffer.Bytes())
s.buffer.Reset()
} }
return nil return nil
} }
func (s *NatsSink) Flush() error { func (s *NatsSink) Flush() error {
if s.client != nil {
if err := s.client.Publish(s.database, s.buffer.Bytes()); err != nil {
return err
}
s.buffer.Reset()
}
return nil return nil
} }