First part of review fixes

plugins/inputs/pgbouncer/README.md

@@ -9,7 +9,10 @@ Specify address via a url matching:
 
   `postgres://[pqgotest[:password]]@localhost[/dbname]?sslmode=[disable|verify-ca|verify-full]`
 
-All connection parameters are optional. Without the dbname parameter, the driver will default to a database with the same name as the user. This dbname is just for instantiating a connection with the server and doesn't restrict the databases we are trying to grab metrics for.
+All connection parameters are optional.
+
+Without the dbname parameter, the driver will default to a database with the same name as the user.
+This dbname is just for instantiating a connection with the server and doesn't restrict the databases we are trying to grab metrics for.
 
 ### Configuration example
 ```

plugins/inputs/pgbouncer/pgbouncer.go

@@ -27,11 +27,6 @@ var sampleConfig = `
   ##
   ## All connection parameters are optional.
   ##
-  ## Without the dbname parameter, the driver will default to a database
-  ## with the same name as the user. This dbname is just for instantiating a
-  ## connection with the server and doesn't restrict the databases we are trying
-  ## to grab metrics for.
-  ##
   address = "host=localhost user=pgbouncer sslmode=disable"
 `
 
@@ -43,10 +38,6 @@ func (p *PgBouncer) Description() string {
 	return "Read metrics from one or many pgbouncer servers"
 }
 
-func (p *PgBouncer) IgnoredColumns() map[string]bool {
-	return ignoredColumns
-}
-
 func (p *PgBouncer) Gather(acc telegraf.Accumulator) error {
 	var (
 		err     error
@@ -69,7 +60,7 @@ func (p *PgBouncer) Gather(acc telegraf.Accumulator) error {
 	}
 
 	for rows.Next() {
-		err = p.accRow(rows, acc, columns)
+		err = p.accRow("pgbouncer", rows, acc, columns)
 		if err != nil {
 			return err
 		}
@@ -90,7 +81,7 @@ func (p *PgBouncer) Gather(acc telegraf.Accumulator) error {
 	}
 
 	for poolRows.Next() {
-		err = p.accRow(poolRows, acc, columns)
+		err = p.accRow("pgbouncer_pools", poolRows, acc, columns)
 		if err != nil {
 			return err
 		}
@@ -103,7 +94,7 @@ type scanner interface {
 	Scan(dest ...interface{}) error
 }
 
-func (p *PgBouncer) accRow(row scanner, acc telegraf.Accumulator, columns []string) error {
+func (p *PgBouncer) accRow(measurement string, row scanner, acc telegraf.Accumulator, columns []string) error {
 	var columnVars []interface{}
 	var dbname bytes.Buffer
 
@@ -147,7 +138,7 @@ func (p *PgBouncer) accRow(row scanner, acc telegraf.Accumulator, columns []stri
 			fields[col] = *val
 		}
 	}
-	acc.AddFields("pgbouncer", fields, tags)
+	acc.AddFields(measurement, fields, tags)
 
 	return nil
 }