Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pgsql

package module

Go to main page

Versions in this module

v1

v1.6.0-beta

Mar 29, 2026

v1.5.5

Mar 8, 2026

v1.5.4

Mar 2, 2026

Changes in this version

+ func WaitForDB(ctx context.Context) (*sql.DB, error)

+ func WaitForDBConnected(ctx context.Context) (*sql.DB, error)

+ func WaitForDriver(ctx context.Context) (*entsql.Driver, error)

v1.5.3

Feb 10, 2026

Changes in this version

+ func CheckHealth() error

+ func GetConfig() *interfaces.Config

+ func GetDB() (*sql.DB, error)

+ func GetDialect() string

+ func GetDriver() (*entsql.Driver, error)

+ func GetMetricsGatherer() prometheus.Gatherer

+ func GetStats() *base.ConnectionPoolStats

+ func IsConnected() bool

+ type DBPgsqlClient struct

+ func NewPgsqlClient() *DBPgsqlClient

+ func (p *DBPgsqlClient) CleanupTasks() error

+ func (p *DBPgsqlClient) GetConfig() *interfaces.Config

+ func (p *DBPgsqlClient) GetMetricsGatherer() prometheus.Gatherer

+ func (p *DBPgsqlClient) InitializeResources(rt plugins.Runtime) error

+ func (p *DBPgsqlClient) StartupTasks() error

+ type PrometheusConfig struct

+ Labels map[string]string

+ Namespace string

+ Subsystem string

+ type PrometheusMetrics struct

+ ConfigMaxConn *prometheus.GaugeVec

+ ConfigMinConn *prometheus.GaugeVec

+ ConnectAttempts *prometheus.CounterVec

+ ConnectFailures *prometheus.CounterVec

+ ConnectRetries *prometheus.CounterVec

+ ConnectSuccess *prometheus.CounterVec

+ ErrorCounter *prometheus.CounterVec

+ HealthCheckFailure *prometheus.CounterVec

+ HealthCheckSuccess *prometheus.CounterVec

+ HealthCheckTotal *prometheus.CounterVec

+ IdleConnections *prometheus.GaugeVec

+ InUseConnections *prometheus.GaugeVec

+ MaxIdleClosed *prometheus.CounterVec

+ MaxIdleConnections *prometheus.GaugeVec

+ MaxLifetimeClosed *prometheus.CounterVec

+ MaxOpenConnections *prometheus.GaugeVec

+ OpenConnections *prometheus.GaugeVec

+ QueryDuration *prometheus.HistogramVec

+ SlowQueryCnt *prometheus.CounterVec

+ TxDuration *prometheus.HistogramVec

+ WaitCount *prometheus.CounterVec

+ WaitDuration *prometheus.CounterVec

+ func NewPrometheusMetrics(config *PrometheusConfig) *PrometheusMetrics

+ func (m *PrometheusMetrics) UpdateMetrics(stats *base.ConnectionPoolStats, config *conf.Pgsql)

+ func (pm *PrometheusMetrics) GetGatherer() prometheus.Gatherer

+ func (pm *PrometheusMetrics) IncConnectAttempt(config *conf.Pgsql)

+ func (pm *PrometheusMetrics) IncConnectFailure(config *conf.Pgsql)

+ func (pm *PrometheusMetrics) IncConnectRetry(config *conf.Pgsql)

+ func (pm *PrometheusMetrics) IncConnectSuccess(config *conf.Pgsql)

+ func (pm *PrometheusMetrics) RecordHealthCheck(success bool, config *conf.Pgsql)

+ func (pm *PrometheusMetrics) RecordQuery(op string, dur time.Duration, err error, threshold time.Duration, ...)

+ func (pm *PrometheusMetrics) RecordTx(dur time.Duration, committed bool, config *conf.Pgsql)

v1.5.2

Jan 15, 2026

v1.5.0

Dec 7, 2025