type github.com/jackc/pgx/v5/pgxpool.Pool
36 uses
github.com/jackc/pgx/v5/pgxpool (current package)
conn.go#L15: p *Pool
pool.go#L35: func (cr *connResource) getConn(p *Pool, res *puddle.Resource[*connResource]) *Conn {
pool.go#L78: type Pool struct {
pool.go#L212: func New(ctx context.Context, connString string) (*Pool, error) {
pool.go#L222: func NewWithConfig(ctx context.Context, config *Config) (*Pool, error) {
pool.go#L236: p := &Pool{
pool.go#L458: func (p *Pool) Close() {
pool.go#L465: func (p *Pool) isExpired(res *puddle.Resource[*connResource]) bool {
pool.go#L469: func (p *Pool) triggerHealthCheck() {
pool.go#L491: func (p *Pool) backgroundHealthCheck() {
pool.go#L506: func (p *Pool) checkHealth() {
pool.go#L530: func (p *Pool) checkConnsHealth() bool {
pool.go#L555: func (p *Pool) checkMinConns() error {
pool.go#L569: func (p *Pool) createIdleResources(parentCtx context.Context, targetResources int) error {
pool.go#L599: func (p *Pool) Acquire(ctx context.Context) (c *Conn, err error) {
pool.go#L663: func (p *Pool) AcquireFunc(ctx context.Context, f func(*Conn) error) error {
pool.go#L675: func (p *Pool) AcquireAllIdle(ctx context.Context) []*Conn {
pool.go#L698: func (p *Pool) Reset() {
pool.go#L703: func (p *Pool) Config() *Config { return p.config.Copy() }
pool.go#L706: func (p *Pool) Stat() *Stat {
pool.go#L719: func (p *Pool) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
pool.go#L739: func (p *Pool) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error) {
pool.go#L766: func (p *Pool) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row {
pool.go#L776: func (p *Pool) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults {
pool.go#L790: func (p *Pool) Begin(ctx context.Context) (pgx.Tx, error) {
pool.go#L798: func (p *Pool) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error) {
pool.go#L813: func (p *Pool) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) {
pool.go#L825: func (p *Pool) Ping(ctx context.Context) error {
tracer.go#L13: TraceAcquireStart(ctx context.Context, pool *Pool, data TraceAcquireStartData) context.Context
tracer.go#L15: TraceAcquireEnd(ctx context.Context, pool *Pool, data TraceAcquireEndData)
tracer.go#L28: TraceRelease(pool *Pool, data TraceReleaseData)
github.com/jackc/pgx/v5/tracelog
tracelog.go#L357: func (tl *TraceLog) TraceAcquireStart(ctx context.Context, _ *pgxpool.Pool, _ pgxpool.TraceAcquireStartData) context.Context {
tracelog.go#L363: func (tl *TraceLog) TraceAcquireEnd(ctx context.Context, _ *pgxpool.Pool, data pgxpool.TraceAcquireEndData) {
tracelog.go#L384: func (tl *TraceLog) TraceRelease(_ *pgxpool.Pool, data pgxpool.TraceReleaseData) {
go.pact.im/x/pgxprocess
pool.go#L17: handle[pgxpool.Pool, *pgxpool.Pool]