Gather IPMI metrics concurrently from list of servers

Resolves #4175
influxdata · Jun 28, 2018 · 0453516 · 0453516
1 parent 23523ff
commit 0453516
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/.circleci/config.yml b/.circleci/config.yml
@@ -16,11 +16,11 @@ jobs:
     steps:
       - checkout
       - restore_cache:
-          key: vendor-{{ .Branch }}-{{ checksum "Gopkg.lock" }}
+          key: vendor-{{ checksum "Gopkg.lock" }}
       - run: 'make deps'
       - save_cache:
           name: 'vendored deps'
-          key: vendor-{{ .Branch }}-{{ checksum "Gopkg.lock" }}
+          key: vendor-{{ checksum "Gopkg.lock" }}
           paths:
             - './vendor'
       - persist_to_workspace:

diff --git a/plugins/inputs/ipmi_sensor/ipmi.go b/plugins/inputs/ipmi_sensor/ipmi.go
@@ -62,11 +62,12 @@ func (m *Ipmi) Gather(acc telegraf.Accumulator) error {
 
 	if len(m.Servers) > 0 {
 		for _, server := range m.Servers {
-			err := m.parse(acc, server)
-			if err != nil {
-				acc.AddError(err)
-				continue
-			}
+			go func(a telegraf.Accumulator, s string) {
+				err := m.parse(a, s)
+				if err != nil {
+					a.AddError(err)
+				}
+			}(acc, server)
 		}
 	} else {
 		err := m.parse(acc, "")