Versions in this module Expand all Collapse all v5 v5.0.1 Mar 8, 2024 Changes in this version + type MockPgxTx struct + func NewMockPgxTx(ctrl *gomock.Controller) *MockPgxTx + func (m *MockPgxTx) Begin(arg0 context.Context) (pgx.Tx, error) + func (m *MockPgxTx) Commit(arg0 context.Context) error + func (m *MockPgxTx) Conn() *pgx.Conn + func (m *MockPgxTx) CopyFrom(arg0 context.Context, arg1 pgx.Identifier, arg2 []string, ...) (int64, error) + func (m *MockPgxTx) EXPECT() *MockPgxTxMockRecorder + func (m *MockPgxTx) Exec(arg0 context.Context, arg1 string, arg2 ...interface{}) (pgconn.CommandTag, error) + func (m *MockPgxTx) LargeObjects() pgx.LargeObjects + func (m *MockPgxTx) Prepare(arg0 context.Context, arg1 string, arg2 string) (*pgconn.StatementDescription, error) + func (m *MockPgxTx) Query(arg0 context.Context, arg1 string, arg2 ...interface{}) (pgx.Rows, error) + func (m *MockPgxTx) QueryRow(arg0 context.Context, arg1 string, arg2 ...interface{}) pgx.Row + func (m *MockPgxTx) Rollback(arg0 context.Context) error + func (m *MockPgxTx) SendBatch(arg0 context.Context, arg1 *pgx.Batch) pgx.BatchResults + type MockPgxTxMockRecorder struct + func (mr *MockPgxTxMockRecorder) Begin(ctx interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) Commit(ctx interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) Conn() *gomock.Call + func (mr *MockPgxTxMockRecorder) CopyFrom(ctx, tableName, columnNames, rowSrc interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) Exec(ctx, sql, arguments interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) LargeObjects() *gomock.Call + func (mr *MockPgxTxMockRecorder) Prepare(ctx, name, sql interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) Query(ctx, sql, args interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) QueryRow(ctx, sql, args interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) Rollback(ctx interface{}) *gomock.Call + func (mr *MockPgxTxMockRecorder) SendBatch(ctx, b interface{}) *gomock.Call v5.0.0 Mar 8, 2024 Changes in this version + var CSVColumnParser = func(s string) interface{} + type MockPgxPool struct + func NewMockPgxPool(ctrl *gomock.Controller) *MockPgxPool + func (m *MockPgxPool) Acquire(arg0 context.Context) (*pgxpool.Conn, error) + func (m *MockPgxPool) AcquireAllIdle(arg0 context.Context) []*pgxpool.Conn + func (m *MockPgxPool) AcquireFunc(arg0 context.Context, arg1 func(*pgxpool.Conn) error) error + func (m *MockPgxPool) Begin(arg0 context.Context) (pgx.Tx, error) + func (m *MockPgxPool) BeginFunc(arg0 context.Context, arg1 func(pgx.Tx) error) error + func (m *MockPgxPool) BeginTx(arg0 context.Context, arg1 pgx.TxOptions) (pgx.Tx, error) + func (m *MockPgxPool) BeginTxFunc(arg0 context.Context, arg1 pgx.TxOptions, arg2 func(pgx.Tx) error) error + func (m *MockPgxPool) Close() + func (m *MockPgxPool) Config() *pgxpool.Config + func (m *MockPgxPool) CopyFrom(arg0 context.Context, arg1 pgx.Identifier, arg2 []string, ...) (int64, error) + func (m *MockPgxPool) EXPECT() *MockPgxPoolMockRecorder + func (m *MockPgxPool) Exec(arg0 context.Context, arg1 string, arg2 ...interface{}) (pgconn.CommandTag, error) + func (m *MockPgxPool) Ping(arg0 context.Context) error + func (m *MockPgxPool) Query(arg0 context.Context, arg1 string, arg2 ...interface{}) (pgx.Rows, error) + func (m *MockPgxPool) QueryRow(arg0 context.Context, arg1 string, arg2 ...interface{}) pgx.Row + func (m *MockPgxPool) Reset() + func (m *MockPgxPool) SendBatch(arg0 context.Context, arg1 *pgx.Batch) pgx.BatchResults + func (m *MockPgxPool) Stat() *pgxpool.Stat + type MockPgxPoolMockRecorder struct + func (mr *MockPgxPoolMockRecorder) Acquire(arg0 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) AcquireAllIdle(arg0 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) AcquireFunc(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Begin(arg0 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) BeginFunc(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) BeginTx(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) BeginTxFunc(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Close() *gomock.Call + func (mr *MockPgxPoolMockRecorder) Config() *gomock.Call + func (mr *MockPgxPoolMockRecorder) CopyFrom(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Exec(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Ping(arg0 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Query(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) QueryRow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Reset() *gomock.Call + func (mr *MockPgxPoolMockRecorder) SendBatch(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPgxPoolMockRecorder) Stat() *gomock.Call + type PgxPool interface + Acquire func(ctx context.Context) (*pgxpool.Conn, error) + AcquireAllIdle func(ctx context.Context) []*pgxpool.Conn + AcquireFunc func(ctx context.Context, f func(*pgxpool.Conn) error) error + Begin func(ctx context.Context) (pgx.Tx, error) + BeginTx func(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error) + Close func() + Config func() *pgxpool.Config + CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error) + Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) + Ping func(ctx context.Context) error + Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error) + QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row + Reset func() + SendBatch func(ctx context.Context, b *pgx.Batch) pgx.BatchResults + Stat func() *pgxpool.Stat + type Row struct + func NewRow(columns []string, values ...interface{}) *Row + func (r *Row) RowError(row int, err error) *Row + func (r *Row) Scan(dest ...interface{}) error + type Rows struct + func NewRows(columns []string) *Rows + func NewRowsWithColumnDefinition(columns ...pgconn.FieldDescription) *Rows + func (r *Rows) AddRow(values ...interface{}) *Rows + func (r *Rows) CloseError(err error) *Rows + func (r *Rows) FromCSVString(s string) *Rows + func (r *Rows) RowError(row int, err error) *Rows + func (r *Rows) ToPgxRows() pgx.Rows