pg

May 28, 2026

Changes in this version

+ func RestartRequiredParams(pgPool *pgxpool.Pool, ctx context.Context, parameterNames []string) ([]string, error)

+ func ValidateRestartPolicy(pgPool *pgxpool.Pool, ctx context.Context, parameterNames []string, ...) (bool, error)

May 6, 2026

Changes in this version

+ const MetricCpuUtilization

+ const MetricDatabaseAutovacuumCount

+ const MetricDatabaseConnections

+ const MetricDatabaseTransactionsPerSecond

+ const MetricDatabaseWaitEvents

+ const MetricHardware

+ const MetricMemoryUsed

+ const MetricPgBgwriter

+ const MetricPgCheckpointer

+ const MetricPgDatabase

+ const MetricPgUserTables

+ const MetricPgWal

+ const MetricServerUptime

+ const MetricSystemDbSize

+ func BuildCatalogCollectors(pool *pgxpool.Pool, pgMajorVersion int, cfg CollectorsConfig, ...) ([]queries.CatalogCollector, error)

+ func CatalogCollectorsForVersion(pool *pgxpool.Pool, pgVersion string, cfg CollectorsConfig) ([]queries.CatalogCollector, error)

+ func PGMajorVersion(version string) (int, error)

+ func StandardCatalogCollectors(pool *pgxpool.Pool, pgVersion string) ([]queries.CatalogCollector, error)

+ type CollectorsConfig struct

+ PgClass collectorconfig.TypedEntry[queries.PgClassConfig]

+ PgStatStatements collectorconfig.TypedEntry[queries.PgStatStatementsConfig]

+ PgStatUserIndexes collectorconfig.TypedEntry[queries.PgStatUserIndexesConfig]

+ PgStatUserTables collectorconfig.TypedEntry[queries.PgStatUserTablesConfig]

+ PgStatioUserIndexes collectorconfig.TypedEntry[queries.PgStatioUserIndexesConfig]

+ PgStats collectorconfig.TypedEntry[queries.PgStatsConfig]

+ Simple map[string]collectorconfig.BaseConfig

+ func CollectorsConfigFromViper() (CollectorsConfig, error)

Mar 25, 2026

Changes in this version

+ func InferNumericType(setting interface{}) interface

+ func IsConnectionError(err error) bool

type Config

+ AllowRestart bool

Jan 15, 2026

Changes in this version

+ const AlterSystemResetQuery

+ func AlterSystemReset(pgPool *pgxpool.Pool, name string) error

Jan 5, 2026

Changes in this version

+ const ConnectionStatsQuery

+ func Connections(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

Nov 10, 2025

Changes in this version

+ var PgStatStatementsQueryBase = fmt.Sprintf(..., utils.DBTuneQueryPrefix)

+ var PgStatStatementsQueryWithTextFmt = fmt.Sprintf(..., utils.DBTuneQueryPrefix)

type Config

+ MaximumQueryTextLength int

Oct 7, 2025

Changes in this version

+ const CheckPGStatStatementsQuery

+ const PGStatBGWriterQuery

+ const PGStatCheckpointerQuery

+ const PGStatDatabaseQuery

+ const PGStatUserTablesQuery

+ const PGStatWalQuery

+ func CheckPGStatStatements(pgPool *pgxpool.Pool) error

+ func EmitCumulativeMetricsMap[T Number](state *agent.MetricsState, mappings []MetricMapping[T]) error

+ func EmitMetric(state *agent.MetricsState, metric metrics.MetricDef, value any) error

+ func PGStatBGwriter(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func PGStatCheckpointer(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func PGStatDatabase(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func PGStatUserTables(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func PGStatWAL(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

type Config

+ IncludeQueries bool

+ type MetricMapping struct

+ Current *T

+ Metric metrics.MetricDef

+ Previous *T

+ type Number interface

Jun 13, 2025

Changes in this version

+ const UptimeMinutesQuery

+ func UptimeMinutes(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

Jun 9, 2025

Changes in this version

+ const ActiveConnectionsQuery

+ const AlterDatabaseQuery

+ const AlterSystemQuery

+ const AutovacuumQuery

+ const BufferCacheHitRatioQuery

+ const DEFAULT_CONFIG_KEY

+ const DataDirectoryQuery

+ const DatabaseSizeQuery

+ const MaxConnectionsQuery

+ const PGVersionQuery

+ const PgStatStatementsQuery

+ const ReloadConfigQuery

+ const SELECT_NON_NUMERIC_SETTINGS

+ const SELECT_NUMERIC_SETTINGS

+ const Select1Query

+ const SleepQuery

+ const TransactionsPerSecondQuery

+ const UptimeQuery

+ const WaitEventsQuery

+ func ActiveConnections(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func AlterDatabase(pgPool *pgxpool.Pool, dbname string, name string, value string) error

+ func AlterSystem(pgPool *pgxpool.Pool, name string, value string) error

+ func ArtificiallyFailingQueries(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func Autovacuum(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func BufferCacheHitRatio(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func DataDirectory(pgPool *pgxpool.Pool) (string, error)

+ func DatabaseSize(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func DetectConfigFromConfigFile() bool

+ func DetectConfigFromEnv() bool

+ func GetActiveConfig(pool *pgxpool.Pool, ctx context.Context, logger *logrus.Logger) (agent.ConfigArraySchema, error)

+ func MaxConnections(pgPool *pgxpool.Pool) (uint32, error)

+ func PGStatStatements(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func PGVersion(pgPool *pgxpool.Pool) (string, error)

+ func ReloadConfig(pgPool *pgxpool.Pool) error

+ func Select1(pgPool *pgxpool.Pool) error

+ func TransactionsPerSecond(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func Uptime(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func WaitEvents(pgPool *pgxpool.Pool) func(ctx context.Context, state *agent.MetricsState) error

+ func WaitPostgresReady(pgPool *pgxpool.Pool) error

+ type Config struct

+ ConnectionURL string

+ ServiceName string

+ func ConfigFromViper(key *string) (Config, error)