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

Fix: Reset counter

Browse Source
This commit is contained in:
Holger Obermaier 2022-02-09 23:22:54 +01:00
parent a0e97d216a
commit acf5db543e
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
sinks/httpSink.go
View File

@ -47,6 +47,9 @@ func (s *HttpSink) Init(config json.RawMessage) error {
s.config.Timeout = "5s" s.config.Timeout = "5s"
s.config.BatchSize = 20 s.config.BatchSize = 20
// Reset counter
s.batchCounter = 0
// Read config // Read config
if len(config) > 0 { if len(config) > 0 {
err := json.Unmarshal(config, &s.config) err := json.Unmarshal(config, &s.config)
@ -103,6 +106,14 @@ func (s *HttpSink) Write(m lp.CCMetric) error {
} }
func (s *HttpSink) Flush() error { func (s *HttpSink) Flush() error {
// Do not flush empty buffer
if s.batchCounter == 0 {
return nil
}
// Reset counter
s.batchCounter = 0
// Create new request to send buffer // Create new request to send buffer
req, err := http.NewRequest(http.MethodPost, s.url, s.buffer) req, err := http.NewRequest(http.MethodPost, s.url, s.buffer)
if err != nil { if err != nil {