collector

Documentation

Index

• type Exporter
  • func NewExporter(ctx context.Context, logger kitlog.Logger, connConfig *pgx.ConnConfig) *Exporter
  • func (e Exporter) Collect(ch chan<- prometheus.Metric)
  • func (e Exporter) Describe(ch chan<- *prometheus.Desc)
• type Scraper
  • func NewDiskUsageScraper() Scraper
  • func NewInfoScraper() Scraper
  • func NewLocksScraper() Scraper
  • func NewStatActivityScraper() Scraper
  • func NewStatArchiverScraper() Scraper
  • func NewStatBgwriterScraper() Scraper
  • func NewStatDatabaseScraper() Scraper
  • func NewStatReplicationScraper() Scraper
  • func NewStatUserIndexesScraper() Scraper
  • func NewStatUserTablesScraper() Scraper
  • func NewStatVacuumProgressScraper() Scraper
• type Version
  • func NewVersion(v string) Version
  • func (v Version) Gte(n float64) bool
  • func (v Version) String() string

Types

type Exporter

type Exporter struct {
	// contains filtered or unexported fields
}

func NewExporter

func NewExporter(ctx context.Context, logger kitlog.Logger, connConfig *pgx.ConnConfig) *Exporter

NewExporter is called every time we receive a scrape request and knows how to collect metrics using each of the scrapers. It will live only for the duration of the scrape request.

func (Exporter) Collect

func (e Exporter) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (Exporter) Describe

func (e Exporter) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.

type Scraper

type Scraper interface {
	Name() string
	// Scrape new metrics and expose them via prometheus registry.
	Scrape(ctx context.Context, db *pgx.Conn, version Version, ch chan<- prometheus.Metric) error
}

Scraper is the interface each scraper has to implement.

func NewDiskUsageScraper

func NewDiskUsageScraper() Scraper

NewDiskUsageScraper returns a new Scraper exposing postgres disk usage view

func NewInfoScraper

func NewInfoScraper() Scraper

NewInfoScraper returns a new Scraper exposing postgres info

func NewLocksScraper

func NewLocksScraper() Scraper

NewLocksScraper returns a new Scraper exposing data from pg_locks

func NewStatActivityScraper

func NewStatActivityScraper() Scraper

NewStatActivityScraper returns a new Scraper exposing postgres pg_stat_activity

func NewStatArchiverScraper

func NewStatArchiverScraper() Scraper

NewStatarchiverScraper returns a new Scraper exposing PostgreSQL `pg_stat_archiver` view

func NewStatBgwriterScraper

func NewStatBgwriterScraper() Scraper

NewStatBgwriterScraper returns a new Scraper exposing PostgreSQL `pg_stat_bgwriter` view

func NewStatDatabaseScraper

func NewStatDatabaseScraper() Scraper

NewStatDatabaseScraper returns a new Scraper exposing postgres pg_stat_database view The Statistics Scraper PostgreSQL's statistics collector is a subsystem that supports collection and reporting of information about server activity. Presently, the collector can count accesses to tables and indexes in both disk-block and individual-row terms. It also tracks the total number of rows in each table, and information about vacuum and analyze actions for each table. It can also count calls to user-defined functions and the total time spent in each one. https://www.postgresql.org/docs/9.4/static/monitoring-stats.html#PG-STAT-DATABASE-VIEW

func NewStatReplicationScraper

func NewStatReplicationScraper() Scraper

NewStatReplicationScraper returns a new Scraper exposing postgres pg_stat_replication

func NewStatUserIndexesScraper

func NewStatUserIndexesScraper() Scraper

NewStatUserIndexesScraper returns a new Scraper exposing postgres pg_stat_user_indexes view

func NewStatUserTablesScraper

func NewStatUserTablesScraper() Scraper

NewStatUserTablesScraper returns a new Scraper exposing postgres pg_stat_database view

func NewStatVacuumProgressScraper

func NewStatVacuumProgressScraper() Scraper

NewStatVacuumProgressScraper returns a new Scraper exposing postgres pg_stat_vacuum_progress_*

type Version

type Version struct {
	// contains filtered or unexported fields
}

Postgres Version

func NewVersion

func NewVersion(v string) Version

func (Version) Gte

func (v Version) Gte(n float64) bool

func (Version) String

func (v Version) String() string