dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added: server to tags

This commit is contained in:
Sherif Zain 2015-06-22 10:40:30 +02:00
parent 2ccd828e81
commit e2dac56a40
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/postgresql/postgresql.go
View File

@ -89,7 +89,7 @@ func (p *Postgresql) gatherServer(serv *Server, acc plugins.Accumulator) error {
defer rows.Close() defer rows.Close()
for rows.Next() { for rows.Next() {
err := p.accRow(rows, acc) err := p.accRow(rows, acc, serv.Address)
if err != nil { if err != nil {
return err return err
} }
@ -100,7 +100,7 @@ func (p *Postgresql) gatherServer(serv *Server, acc plugins.Accumulator) error {
for _, name := range serv.Databases { for _, name := range serv.Databases {
row := db.QueryRow(`SELECT * FROM pg_stat_database WHERE datname=$1`, name) 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 { if err != nil {
return err return err
} }
@ -114,7 +114,7 @@ type scanner interface {
Scan(dest ...interface{}) error 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 ignore interface{}
var name string var name string
var commit, rollback, read, hit int64 var commit, rollback, read, hit int64
@ -135,7 +135,7 @@ func (p *Postgresql) accRow(row scanner, acc plugins.Accumulator) error {
return err 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_commit", commit, tags)
acc.Add("xact_rollback", rollback, tags) acc.Add("xact_rollback", rollback, tags)