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
- API
  
  Reference documentation for the pkg.go.dev API
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

dbconn

package

Go to main page

Versions in this module

v0

v0.3.3

Sep 16, 2026

Changes in this version

+ var ErrNoSessionAffinity = errors.New("the connection does not keep one PostgreSQL session")

+ var ErrSessionSettingsDiscarded = errors.New("the connection does not keep pg-sprite's session settings")

+ func ProveSessionAffinity(ctx context.Context, conn *pgxpool.Conn, pinner *pgxpool.Pool, ...) error

+ type AdvisoryLockHolder interface

+ QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row

v0.3.2

Sep 10, 2026

Changes in this version

+ func LocalSearchPath(schemas ...string) string

+ type TableLock struct

+ func (l TableLock) Key() int64

+ func (l TableLock) Schema() string

+ func (l TableLock) Table() string

v0.3.1

Sep 7, 2026

v0.3.0

Sep 7, 2026

Changes in this version

type IndexBuildProgress

+ CurrentLockerPID uint32

+ LockersDone uint64

+ LockersTotal uint64

v0.2.0

Aug 30, 2026

v0.1.0

Aug 19, 2026

Changes in this version

+ const DefaultConnectTimeout

+ const DefaultLockTimeout

+ const DefaultStatementTimeout

+ func IsRDSHost(host string) bool

+ func NewPool(ctx context.Context, cfg Config) (*pgxpool.Pool, error)

+ func Retry(ctx context.Context, attempts int, backoff time.Duration, ...) error

+ func Retryable(err error) bool

+ func ServerMajor(ctx context.Context, pool *pgxpool.Pool) (int, error)

+ func ServerVersion(ctx context.Context, pool *pgxpool.Pool) (string, error)

+ func TerminateBlockers(ctx context.Context, q Querier, pid int) ([]int, error)

+ type Config struct

+ BeforeConnect func(context.Context, *pgx.ConnConfig) error

+ CACertPath string

+ ConnectTimeout time.Duration

+ HealthCheckPeriod time.Duration

+ LockTimeout time.Duration

+ Logger *slog.Logger

+ MaxConnIdleTime time.Duration

+ MaxConnLifetime time.Duration

+ MaxConnLifetimeJitter time.Duration

+ MaxConns int32

+ MinConns int32

+ QueryExecMode pgx.QueryExecMode

+ StatementTimeout time.Duration

+ URL string

+ type IndexBuildProgress struct

+ BlocksDone uint64

+ BlocksTotal uint64

+ Phase string

+ TuplesDone uint64

+ TuplesTotal uint64

+ func ConcurrentIndexProgress(ctx context.Context, session RowQuerier, backendPID uint32) (IndexBuildProgress, bool, error)

+ type Querier interface

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ type RowQuerier interface

+ QueryRow func(context.Context, string, ...any) pgx.Row