pgxpool

package
v0.0.0-...-904665a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DefaultConnection pgxer.Conn
)

Functions

func AfterConnectFromBaseAfterConnect 

func AfterConnectFromBaseAfterConnect(func(ctx context.Context, conn *basePgx.Conn) error) func(context.Context, pgxer.Conn) error

func AfterReleaseFromBaseAfterRelease 

func AfterReleaseFromBaseAfterRelease(func(conn *basePgx.Conn) bool) func(pgxer.Conn) bool

func BaseAfterConnectFromAfterConnect 

func BaseAfterConnectFromAfterConnect(func(context.Context, pgxer.Conn) error) func(context.Context, *basePgx.Conn) error

func BaseAfterReleaseFromAfterRelease 

func BaseAfterReleaseFromAfterRelease(func(conn pgxer.Conn) bool) func(conn *basePgx.Conn) bool

func BaseBeforeAcquireFromBeforeAcquire 

func BaseBeforeAcquireFromBeforeAcquire(func(ctx context.Context, conn pgxer.Conn) bool) func(ctx context.Context, conn *basePgx.Conn) bool

func BaseBeforeConnectFromBeforeConnect 

func BaseBeforeConnectFromBeforeConnect(func(ctx context.Context, connConfig pgxer.ConnConfig) error) func(context.Context, *basePgx.ConnConfig) error

func BaseConnConfigFromConnConfig 

func BaseConnConfigFromConnConfig(c pgxer.ConnConfig) *basePgx.ConnConfig

func BeforeAcquireFromBaseBeforeAcquire 

func BeforeAcquireFromBaseBeforeAcquire(func(ctx context.Context, conn *basePgx.Conn) bool) func(ctx context.Context, conn pgxer.Conn) bool

func BeforeConnectFromBaseBeforeConnect 

func BeforeConnectFromBaseBeforeConnect(func(ctx context.Context, config *basePgx.ConnConfig) error) func(ctx context.Context, config pgxer.ConnConfig) error

func ConnConfigFromBaseConnConfig 

func ConnConfigFromBaseConnConfig(config *basePgx.ConnConfig) pgxer.ConnConfig

Types

type ConcreteConfig 

type ConcreteConfig struct {
	basePgxPool.Config
}

func (*ConcreteConfig) AfterConnect 

func (c *ConcreteConfig) AfterConnect(context.Context, pgxer.Conn) error

func (*ConcreteConfig) AfterRelease 

func (c *ConcreteConfig) AfterRelease(pgxer.Conn) bool

func (*ConcreteConfig) BeforeAcquire 

func (c *ConcreteConfig) BeforeAcquire(context.Context, pgxer.Conn) bool

func (*ConcreteConfig) BeforeConnect 

func (c *ConcreteConfig) BeforeConnect(context.Context, pgxer.ConnConfig) error

func (*ConcreteConfig) ConnConfig 

func (c *ConcreteConfig) ConnConfig() pgxer.ConnConfig

func (*ConcreteConfig) HealthCheckPeriod 

func (c *ConcreteConfig) HealthCheckPeriod() time.Duration

func (*ConcreteConfig) LazyConnect 

func (c *ConcreteConfig) LazyConnect() bool

func (*ConcreteConfig) MaxConnIdleTime 

func (c *ConcreteConfig) MaxConnIdleTime() time.Duration

func (*ConcreteConfig) MaxConnLifetime 

func (c *ConcreteConfig) MaxConnLifetime() time.Duration

func (*ConcreteConfig) MaxConns 

func (c *ConcreteConfig) MaxConns() int32

func (*ConcreteConfig) MinConns 

func (c *ConcreteConfig) MinConns() int32

func (*ConcreteConfig) SetAfterConnect 

func (c *ConcreteConfig) SetAfterConnect(func(context.Context, pgxer.Conn) error) Config

func (*ConcreteConfig) SetAfterRelease 

func (c *ConcreteConfig) SetAfterRelease(func(pgxer.Conn) bool) Config

func (*ConcreteConfig) SetBeforeAcquire 

func (c *ConcreteConfig) SetBeforeAcquire(func(context.Context, pgxer.Conn) bool) Config

func (*ConcreteConfig) SetBeforeConnect 

func (c *ConcreteConfig) SetBeforeConnect(func(context.Context, pgxer.ConnConfig) error) Config

func (*ConcreteConfig) SetConnConfig 

func (c *ConcreteConfig) SetConnConfig(config pgxer.ConnConfig) Config

func (*ConcreteConfig) SetHealthCheckPeriod 

func (c *ConcreteConfig) SetHealthCheckPeriod(time.Duration) Config

func (*ConcreteConfig) SetLazyConnect 

func (c *ConcreteConfig) SetLazyConnect(bool) Config

func (*ConcreteConfig) SetMaxConnIdleTime 

func (c *ConcreteConfig) SetMaxConnIdleTime(time.Duration) Config

func (*ConcreteConfig) SetMaxConnLifetime 

func (c *ConcreteConfig) SetMaxConnLifetime(time.Duration) Config

func (*ConcreteConfig) SetMaxConns 

func (c *ConcreteConfig) SetMaxConns(int32) Config

func (*ConcreteConfig) SetMinConns 

func (c *ConcreteConfig) SetMinConns(int32) Config

type ConcreteConn 

type ConcreteConn basePgxPool.Conn

func (*ConcreteConn) Begin 

func (cc *ConcreteConn) Begin(ctx context.Context) (pgxer.Tx, error)

func (*ConcreteConn) BeginFunc 

func (cc *ConcreteConn) BeginFunc(ctx context.Context, f func(pgxer.Tx) error) error

func (*ConcreteConn) BeginTx 

func (cc *ConcreteConn) BeginTx(ctx context.Context, txOptions pgxer.TxOptions) (pgxer.Tx, error)

func (*ConcreteConn) BeginTxFunc 

func (cc *ConcreteConn) BeginTxFunc(ctx context.Context, txOptions pgxer.TxOptions, f func(pgxer.Tx) error) error

func (*ConcreteConn) Conn 

func (cc *ConcreteConn) Conn() pgxer.Conn

func (*ConcreteConn) CopyFrom 

func (cc *ConcreteConn) CopyFrom(ctx context.Context, tableName pgxer.Identifier, columnNames []string, rowSrc pgxer.CopyFromSource) (int64, error)

func (*ConcreteConn) Exec 

func (cc *ConcreteConn) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)

func (*ConcreteConn) Ping 

func (cc *ConcreteConn) Ping(ctx context.Context) error

func (*ConcreteConn) Query 

func (cc *ConcreteConn) Query(ctx context.Context, sql string, args ...interface{}) (pgxer.Rows, error)

func (*ConcreteConn) QueryFunc 

func (cc *ConcreteConn) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(row pgxer.QueryFuncRow) error) (pgconn.CommandTag, error)

func (*ConcreteConn) QueryRow 

func (cc *ConcreteConn) QueryRow(ctx context.Context, sql string, args ...interface{}) pgxer.Row

func (*ConcreteConn) Release 

func (cc *ConcreteConn) Release()

func (*ConcreteConn) SendBatch 

func (cc *ConcreteConn) SendBatch(ctx context.Context, b pgxer.Batch) pgxer.BatchResults

type ConcretePool 

type ConcretePool basePgxPool.Pool

func (*ConcretePool) Acquire 

func (p *ConcretePool) Acquire(ctx context.Context) (Conn, error)

func (*ConcretePool) AcquireAllIdle 

func (p *ConcretePool) AcquireAllIdle(ctx context.Context) []Conn

func (*ConcretePool) AcquireFunc 

func (p *ConcretePool) AcquireFunc(ctx context.Context, f func(conn Conn) error) error

func (*ConcretePool) Begin 

func (p *ConcretePool) Begin(ctx context.Context) (pgxer.Tx, error)

func (*ConcretePool) BeginFunc 

func (p *ConcretePool) BeginFunc(ctx context.Context, f func(pgxer.Tx) error) error

func (*ConcretePool) BeginTx 

func (p *ConcretePool) BeginTx(ctx context.Context, txOptions pgxer.TxOptions) (pgxer.Tx, error)

func (*ConcretePool) BeginTxFunc 

func (p *ConcretePool) BeginTxFunc(ctx context.Context, txOptions pgxer.TxOptions, f func(pgxer.Tx) error) error

func (*ConcretePool) ConnConfig 

func (p *ConcretePool) ConnConfig() pgxer.ConnConfig

func (*ConcretePool) CopyFrom 

func (p *ConcretePool) CopyFrom(ctx context.Context, tableName pgxer.Identifier, columnNames []string, rowSrc pgxer.CopyFromSource) (int64, error)

func (*ConcretePool) Exec 

func (p *ConcretePool) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)

func (*ConcretePool) Ping 

func (p *ConcretePool) Ping(ctx context.Context) error

func (*ConcretePool) Query 

func (p *ConcretePool) Query(ctx context.Context, sql string, args ...interface{}) (pgxer.Rows, error)

func (*ConcretePool) QueryFunc 

func (p *ConcretePool) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgxer.QueryFuncRow) error) (pgconn.CommandTag, error)

func (*ConcretePool) QueryRow 

func (p *ConcretePool) QueryRow(ctx context.Context, sql string, args ...interface{}) pgxer.Row

func (*ConcretePool) SendBatch 

func (p *ConcretePool) SendBatch(ctx context.Context, b pgxer.Batch) pgxer.BatchResults

func (*ConcretePool) Stat 

func (p *ConcretePool) Stat() Stat

type Config 

type Config interface {
	ConnConfig() pgxer.ConnConfig
	SetConnConfig(config pgxer.ConnConfig) Config

	AfterConnect(context.Context, pgxer.Conn) error
	AfterRelease(pgxer.Conn) bool
	BeforeAcquire(context.Context, pgxer.Conn) bool
	BeforeConnect(context.Context, pgxer.ConnConfig) error

	SetAfterConnect(func(context.Context, pgxer.Conn) error) Config
	SetAfterRelease(func(pgxer.Conn) bool) Config
	SetBeforeAcquire(func(context.Context, pgxer.Conn) bool) Config
	SetBeforeConnect(func(context.Context, pgxer.ConnConfig) error) Config

	HealthCheckPeriod() time.Duration
	LazyConnect() bool
	MaxConnIdleTime() time.Duration
	MaxConnLifetime() time.Duration
	MaxConns() int32
	MinConns() int32

	SetHealthCheckPeriod(time.Duration) Config
	SetLazyConnect(bool) Config
	SetMaxConnIdleTime(time.Duration) Config
	SetMaxConnLifetime(time.Duration) Config
	SetMaxConns(int32) Config
	SetMinConns(int32) Config
}

func ParseConfig 

func ParseConfig(connString string) (Config, error)

type Conn 

type Conn interface {
	Begin(ctx context.Context) (pgxer.Tx, error)
	BeginFunc(ctx context.Context, f func(pgxer.Tx) error) error
	BeginTx(ctx context.Context, txOptions pgxer.TxOptions) (pgxer.Tx, error)
	BeginTxFunc(ctx context.Context, txOptions pgxer.TxOptions, f func(pgxer.Tx) error) error
	Conn() pgxer.Conn
	CopyFrom(ctx context.Context, tableName pgxer.Identifier, columnNames []string, rowSrc pgxer.CopyFromSource) (int64, error)
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	Ping(ctx context.Context) error
	Query(ctx context.Context, sql string, args ...interface{}) (pgxer.Rows, error)
	QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(row pgxer.QueryFuncRow) error) (pgconn.CommandTag, error)
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgxer.Row
	Release()
	SendBatch(ctx context.Context, b pgxer.Batch) pgxer.BatchResults
}

Conn is an acquired pgxer.Conn from a pgxpool.Pool.

type Pool 

type Pool interface {
	Acquire(ctx context.Context) (Conn, error)
	AcquireFunc(ctx context.Context, f func(Conn) error) error
	AcquireAllIdle(ctx context.Context) []Conn
	ConnConfig() pgxer.ConnConfig
	Stat() Stat
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...interface{}) (pgxer.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgxer.Row
	QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgxer.QueryFuncRow) error) (pgconn.CommandTag, error)
	SendBatch(ctx context.Context, b pgxer.Batch) pgxer.BatchResults
	Begin(ctx context.Context) (pgxer.Tx, error)
	BeginTx(ctx context.Context, txOptions pgxer.TxOptions) (pgxer.Tx, error)
	BeginFunc(ctx context.Context, f func(pgxer.Tx) error) error
	BeginTxFunc(ctx context.Context, txOptions pgxer.TxOptions, f func(pgxer.Tx) error) error
	CopyFrom(ctx context.Context, tableName pgxer.Identifier, columnNames []string, rowSrc pgxer.CopyFromSource) (int64, error)
	Ping(ctx context.Context) error
}

func Connect 

func Connect(ctx context.Context, connString string) (p Pool, err error)

func ConnectConfig 

func ConnectConfig(ctx context.Context, config Config) (Pool, error)

type Stat 

type Stat interface {
	AcquireCount() int64
	AcquiredConns() int32
	AcquireDuration() time.Duration
	CanceledAcquireCount() int64
	ConstructingConns() int32
	EmptyAcquireCount() int64
	IdleConns() int32
	MaxConns() int32
	TotalConns() int32
}

type Tx 

type Tx interface {
	Begin(ctx context.Context) (pgxer.Tx, error)
	BeginFunc(ctx context.Context, f func(pgxer.Tx) error) error
	Commit(ctx context.Context) error
	Conn() pgxer.Conn
	CopyFrom(ctx context.Context, tableName pgxer.Identifier, columnNames []string, rowSrc pgxer.CopyFromSource) (int64, error)
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	LargeObjects() pgxer.LargeObjects
	Prepare(ctx context.Context, name, sql string) (pgconn.StatementDescription, error)
	Query(ctx context.Context, sql string, args ...interface{}) (pgxer.Rows, error)
	QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgxer.QueryFuncRow) error) (pgconn.CommandTag, error)
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgxer.Row
	Rollback(ctx context.Context) error
	SendBatch(ctx context.Context, b pgxer.Batch) pgxer.BatchResults
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.