0.3.0: postgresql and phpfpm

Author: sparrc

plugins/haproxy/haproxy.go

@@ -162,14 +162,13 @@ func importCsvResult(r io.Reader, acc plugins.Accumulator, host string) error {
 	now := time.Now()
 
 	for _, row := range result {
-
+		fields := make(map[string]interface{})
+		tags := map[string]string{
+			"server": host,
+			"proxy":  row[HF_PXNAME],
+			"sv":     row[HF_SVNAME],
+		}
 		for field, v := range row {
-			fields := make(map[string]interface{})
-			tags := map[string]string{
-				"server": host,
-				"proxy":  row[HF_PXNAME],
-				"sv":     row[HF_SVNAME],
-			}
 			switch field {
 			case HF_QCUR:
 				ival, err := strconv.ParseUint(v, 10, 64)

plugins/phpfpm/phpfpm.go

@@ -198,9 +198,11 @@ func importMetric(r io.Reader, acc plugins.Accumulator, host string) (poolStat,
 			"url":  host,
 			"pool": pool,
 		}
+		fields := make(map[string]interface{})
 		for k, v := range stats[pool] {
-			acc.Add(strings.Replace(k, " ", "_", -1), v, tags)
+			fields[strings.Replace(k, " ", "_", -1)] = v
 		}
+		acc.AddFields("phpfpm", fields, tags)
 	}
 
 	return stats, nil

plugins/postgresql/postgresql.go

@@ -42,7 +42,7 @@ var sampleConfig = `
   # to grab metrics for.
   #
 
-  address = "sslmode=disable"
+  address = "host=localhost user=postgres sslmode=disable"
 
   # A list of databases to pull metrics about. If not specified, metrics for all
   # databases are gathered.
@@ -161,12 +161,14 @@ func (p *Postgresql) accRow(row scanner, acc plugins.Accumulator, serv *Server)
 
 	tags := map[string]string{"server": serv.Address, "db": dbname.String()}
 
+	fields := make(map[string]interface{})
 	for col, val := range columnMap {
 		_, ignore := ignoredColumns[col]
 		if !ignore {
-			acc.Add(col, *val, tags)
+			fields[col] = *val
 		}
 	}
+	acc.AddFields("postgresql", fields, tags)
 
 	return nil
 }