From e2dac56a40f5d0e1c07f1c001b6d074dffe66083 Mon Sep 17 00:00:00 2001 From: Sherif Zain Date: Mon, 22 Jun 2015 10:40:30 +0200 Subject: [PATCH] Added: server to tags --- plugins/postgresql/postgresql.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/plugins/postgresql/postgresql.go b/plugins/postgresql/postgresql.go index 812d39750..85479577d 100644 --- a/plugins/postgresql/postgresql.go +++ b/plugins/postgresql/postgresql.go @@ -89,7 +89,7 @@ func (p *Postgresql) gatherServer(serv *Server, acc plugins.Accumulator) error { defer rows.Close() for rows.Next() { - err := p.accRow(rows, acc) + err := p.accRow(rows, acc, serv.Address) if err != nil { return err } @@ -100,7 +100,7 @@ func (p *Postgresql) gatherServer(serv *Server, acc plugins.Accumulator) error { for _, name := range serv.Databases { row := db.QueryRow(`SELECT * FROM pg_stat_database WHERE datname=$1`, name) - err := p.accRow(row, acc) + err := p.accRow(row, acc, serv.Address) if err != nil { return err } @@ -114,7 +114,7 @@ type scanner interface { Scan(dest ...interface{}) error } -func (p *Postgresql) accRow(row scanner, acc plugins.Accumulator) error { +func (p *Postgresql) accRow(row scanner, acc plugins.Accumulator, server string) error { var ignore interface{} var name string var commit, rollback, read, hit int64 @@ -135,7 +135,7 @@ func (p *Postgresql) accRow(row scanner, acc plugins.Accumulator) error { return err } - tags := map[string]string{"db": name} + tags := map[string]string{"server": server, "db": name} acc.Add("xact_commit", commit, tags) acc.Add("xact_rollback", rollback, tags)