collector

Sep 25, 2025

Changes in this version

+ func Int32(m sql.NullInt32) float64

+ type BuffercacheSummaryCollector struct

+ func (c BuffercacheSummaryCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

type Collector

+ func NewBuffercacheSummaryCollector(config collectorConfig) (Collector, error)

+ func NewPGStatProgressVacuumCollector(config collectorConfig) (Collector, error)

+ type PGStatProgressVacuumCollector struct

+ func (c *PGStatProgressVacuumCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

type PostgresCollector

+ func (p *PostgresCollector) Close() error

Feb 21, 2025

Changes in this version

type Collector

+ func NewPGStatCheckpointerCollector(config collectorConfig) (Collector, error)

+ type PGStatCheckpointerCollector struct

+ func (c PGStatCheckpointerCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

Nov 10, 2024

Changes in this version

type Collector

+ func NewPGRolesCollector(config collectorConfig) (Collector, error)

+ type PGRolesCollector struct

+ func (c PGRolesCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

Sep 20, 2023

Changes in this version

type Collector

+ func NewPGDatabaseWraparoundCollector(config collectorConfig) (Collector, error)

+ func NewPGLocksCollector(config collectorConfig) (Collector, error)

+ func NewPGLongRunningTransactionsCollector(config collectorConfig) (Collector, error)

+ func NewPGStatActivityAutovacuumCollector(config collectorConfig) (Collector, error)

+ func NewPGStatWalReceiverCollector(config collectorConfig) (Collector, error)

+ func NewPGStatioUserIndexesCollector(config collectorConfig) (Collector, error)

+ func NewPGWALCollector(config collectorConfig) (Collector, error)

+ func NewPGXlogLocationCollector(config collectorConfig) (Collector, error)

+ type PGDatabaseWraparoundCollector struct

+ func (c *PGDatabaseWraparoundCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGLocksCollector struct

+ func (c PGLocksCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGLongRunningTransactionsCollector struct

+ func (PGLongRunningTransactionsCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGStatActivityAutovacuumCollector struct

+ func (PGStatActivityAutovacuumCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGStatWalReceiverCollector struct

+ func (c *PGStatWalReceiverCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGStatioUserIndexesCollector struct

+ func (c *PGStatioUserIndexesCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGWALCollector struct

+ func (c PGWALCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGXlogLocationCollector struct

+ func (c PGXlogLocationCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

Jun 22, 2023

Changes in this version

type Collector

+ func NewPGPostmasterCollector(collectorConfig) (Collector, error)

+ func NewPGProcessIdleCollector(config collectorConfig) (Collector, error)

+ func NewPGReplicationCollector(collectorConfig) (Collector, error)

+ func NewPGStatDatabaseCollector(config collectorConfig) (Collector, error)

+ func NewPGStatIOUserTablesCollector(config collectorConfig) (Collector, error)

+ func NewPGStatStatementsCollector(config collectorConfig) (Collector, error)

+ func NewPGStatUserTablesCollector(config collectorConfig) (Collector, error)

+ type PGPostmasterCollector struct

+ func (c *PGPostmasterCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGProcessIdleCollector struct

+ func (PGProcessIdleCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGReplicationCollector struct

+ func (c *PGReplicationCollector) Update(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

+ type PGStatDatabaseCollector struct

+ func (PGStatDatabaseCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGStatIOUserTablesCollector struct

+ func (PGStatIOUserTablesCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGStatStatementsCollector struct

+ func (PGStatStatementsCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

+ type PGStatUserTablesCollector struct

+ func (c *PGStatUserTablesCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error

Mar 21, 2023

Changes in this version

type Collector

+ func NewPGReplicationSlotCollector(config collectorConfig) (Collector, error)

+ type PGReplicationSlotCollector struct

+ func (PGReplicationSlotCollector) Update(ctx context.Context, db *sql.DB, ch chan<- prometheus.Metric) error

+ type ProbeCollector struct

+ func NewProbeCollector(logger log.Logger, excludeDatabases []string, registry *prometheus.Registry, ...) (*ProbeCollector, error)

+ func (pc *ProbeCollector) Close() error

+ func (pc *ProbeCollector) Collect(ch chan<- prometheus.Metric)

+ func (pc *ProbeCollector) Describe(ch chan<- *prometheus.Desc)

Jul 28, 2022

Changes in this version

+ var ErrNoData = errors.New("collector returned no data")

+ func IsNoDataError(err error) bool

+ type Collector interface

+ Update func(ctx context.Context, server *server, ch chan<- prometheus.Metric) error

+ func NewPGDatabaseCollector(logger log.Logger) (Collector, error)

+ func NewPGStatBGWriterCollector(logger log.Logger) (Collector, error)

+ type Option func(*PostgresCollector) error

+ type PGDatabaseCollector struct

+ func (PGDatabaseCollector) Update(ctx context.Context, server *server, ch chan<- prometheus.Metric) error

+ type PGStatBGWriterCollector struct

+ func (PGStatBGWriterCollector) Update(ctx context.Context, server *server, ch chan<- prometheus.Metric) error

+ type PostgresCollector struct

+ Collectors map[string]Collector

+ func NewPostgresCollector(logger log.Logger, dsns []string, filters []string, options ...Option) (*PostgresCollector, error)

+ func (p PostgresCollector) Collect(ch chan<- prometheus.Metric)

+ func (p PostgresCollector) Describe(ch chan<- *prometheus.Desc)