CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(common.shim): check err of s.writeProcessedMetrics for the linter (#12103)

This commit is contained in:
Mya 2022-10-26 20:50:38 +02:00 committed by GitHub
parent 9039af6990
commit 2bcb4d9f52
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugins/common/shim/input.go
View File

@ -54,7 +54,10 @@ func (s *Shim) RunInput(pollInterval time.Duration) error {
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
wg.Add(1) wg.Add(1)
go func() { go func() {
s.writeProcessedMetrics() err := s.writeProcessedMetrics()
if err != nil {
s.log.Warnf("%s", err)
}
wg.Done() wg.Done()
}() }()

5
plugins/common/shim/processor.go
View File

@ -44,7 +44,10 @@ func (s *Shim) RunProcessor() error {
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
wg.Add(1) wg.Add(1)
go func() { go func() {
s.writeProcessedMetrics() err := s.writeProcessedMetrics()
if err != nil {
s.log.Warnf("%s", err)
}
wg.Done() wg.Done()
}() }()