1 files changed, 59 insertions, 0 deletions
diff --git a/src/go/collectors/go.d.plugin/modules/postgres/do_query_indexes.go b/src/go/collectors/go.d.plugin/modules/postgres/do_query_indexes.go
new file mode 100644
index 000000000..f5eb15bb3
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/modules/postgres/do_query_indexes.go
@@ -0,0 +1,59 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+package postgres
+
+import (
+	"database/sql"
+)
+
+func (p *Postgres) doQueryIndexesMetrics() error {
+	if err := p.doQueryStatUserIndexes(); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (p *Postgres) doQueryStatUserIndexes() error {
+	if err := p.doDBQueryStatUserIndexes(p.db); err != nil {
+		p.Warning(err)
+	}
+	for _, conn := range p.dbConns {
+		if conn.db == nil {
+			continue
+		}
+		if err := p.doDBQueryStatUserIndexes(conn.db); err != nil {
+			p.Warning(err)
+		}
+	}
+	return nil
+}
+
+func (p *Postgres) doDBQueryStatUserIndexes(db *sql.DB) error {
+	q := queryStatUserIndexes()
+
+	var dbname, schema, table, name string
+	return p.doDBQuery(db, q, func(column, value string, _ bool) {
+		switch column {
+		case "datname":
+			dbname = value
+		case "schemaname":
+			schema = value
+		case "relname":
+			table = value
+		case "indexrelname":
+			name = value
+			p.getIndexMetrics(name, table, dbname, schema).updated = true
+		case "parent_relname":
+			p.getIndexMetrics(name, table, dbname, schema).parentTable = value
+		case "idx_scan":
+			p.getIndexMetrics(name, table, dbname, schema).idxScan = parseInt(value)
+		case "idx_tup_read":
+			p.getIndexMetrics(name, table, dbname, schema).idxTupRead = parseInt(value)
+		case "idx_tup_fetch":
+			p.getIndexMetrics(name, table, dbname, schema).idxTupFetch = parseInt(value)
+		case "size":
+			p.getIndexMetrics(name, table, dbname, schema).size = parseInt(value)
+		}
+	})
+}