package testing

import "github.com/vgarvardt/gue/v5/adapter/testing"

Index ¶

• Variables
• func OpenTestPoolLibPQ(t testing.TB) adapter.ConnPool
• func OpenTestPoolLibPQCustomSchemas(t testing.TB, gueSchema, secondSchema string) adapter.ConnPool
• func OpenTestPoolMaxConnsLibPQ(t testing.TB, maxConnections int, gueSchema, secondSchema string) adapter.ConnPool
• func OpenTestPoolMaxConnsPGXv4(t testing.TB, maxConnections int32) adapter.ConnPool
• func OpenTestPoolMaxConnsPGXv5(t testing.TB, maxConnections int32) adapter.ConnPool
• func OpenTestPoolPGXv4(t testing.TB) adapter.ConnPool
• func OpenTestPoolPGXv5(t testing.TB) adapter.ConnPool
• type CommandTag
• func (m *CommandTag) RowsAffected() int64
• type Conn
• func (m *Conn) Begin(ctx context.Context) (adapter.Tx, error)
• func (m *Conn) Ping(ctx context.Context) error
• func (m *Conn) Release() error
• type ConnPool
• func (m *ConnPool) Acquire(ctx context.Context) (adapter.Conn, error)
• func (m *ConnPool) Begin(ctx context.Context) (adapter.Tx, error)
• func (m *ConnPool) Close() error
• func (m *ConnPool) Ping(ctx context.Context) error
• type OpenOpenTestPoolMaxConns
• type OpenTestPool
• type Queryable
• func (m *Queryable) Exec(ctx context.Context, query string, args ...any) (adapter.CommandTag, error)
• func (m *Queryable) Query(ctx context.Context, query string, args ...any) (adapter.Rows, error)
• func (m *Queryable) QueryRow(ctx context.Context, query string, args ...any) adapter.Row
• type Row
• func (m *Row) Scan(dest ...any) error
• type Rows
• func (m *Rows) Err() error
• func (m *Rows) Next() bool
• func (m *Rows) Scan(dest ...any) error
• type Tx
• func (m *Tx) Commit(ctx context.Context) error
• func (m *Tx) Rollback(ctx context.Context) error

Variables ¶

var AllAdaptersOpenTestPool = map[string]OpenTestPool{
	"pgx/v4": OpenTestPoolPGXv4,
	"pgx/v5": OpenTestPoolPGXv5,
	"lib/pq": OpenTestPoolLibPQ,
}

AllAdaptersOpenTestPool lists all available adapters with callbacks

Functions ¶

func OpenTestPoolLibPQ ¶

func OpenTestPoolLibPQ(t testing.TB) adapter.ConnPool

OpenTestPoolLibPQ opens connections pool used in testing

func OpenTestPoolLibPQCustomSchemas ¶

func OpenTestPoolLibPQCustomSchemas(t testing.TB, gueSchema, secondSchema string) adapter.ConnPool

OpenTestPoolLibPQCustomSchemas opens connections pool used in testing with gue table installed to own schema and search_path set to two different schemas

func OpenTestPoolMaxConnsLibPQ ¶

func OpenTestPoolMaxConnsLibPQ(t testing.TB, maxConnections int, gueSchema, secondSchema string) adapter.ConnPool

OpenTestPoolMaxConnsLibPQ opens connections pool used in testing

func OpenTestPoolMaxConnsPGXv4 ¶

func OpenTestPoolMaxConnsPGXv4(t testing.TB, maxConnections int32) adapter.ConnPool

OpenTestPoolMaxConnsPGXv4 opens connections pool used in testing

func OpenTestPoolMaxConnsPGXv5 ¶

func OpenTestPoolMaxConnsPGXv5(t testing.TB, maxConnections int32) adapter.ConnPool

OpenTestPoolMaxConnsPGXv5 opens connections pool used in testing

func OpenTestPoolPGXv4 ¶

func OpenTestPoolPGXv4(t testing.TB) adapter.ConnPool

OpenTestPoolPGXv4 opens connections pool used in testing

func OpenTestPoolPGXv5 ¶

func OpenTestPoolPGXv5(t testing.TB) adapter.ConnPool

OpenTestPoolPGXv5 opens connections pool used in testing

Types ¶

type CommandTag ¶

type CommandTag struct {
	mock.Mock
}

CommandTag mock implementation of adapter.CommandTag

func (*CommandTag) RowsAffected ¶

func (m *CommandTag) RowsAffected() int64

RowsAffected mock implementation of adapter.CommandTag.RowsAffected()

type Conn ¶

type Conn struct {
	Queryable
	mock.Mock
}

Conn mock implementation of adapter.Conn

func (*Conn) Begin ¶

func (m *Conn) Begin(ctx context.Context) (adapter.Tx, error)

Begin mock implementation of adapter.Conn.Begin()

func (*Conn) Ping ¶

func (m *Conn) Ping(ctx context.Context) error

Ping mock implementation of adapter.Conn.Ping()

func (*Conn) Release ¶

func (m *Conn) Release() error

Release mock implementation of adapter.Conn.Release()

type ConnPool ¶

type ConnPool struct {
	Queryable
	mock.Mock
}

ConnPool mock implementation of adapter.ConnPool

func (*ConnPool) Acquire ¶

func (m *ConnPool) Acquire(ctx context.Context) (adapter.Conn, error)

Acquire mock implementation of adapter.ConnPool.Acquire()

func (*ConnPool) Begin ¶

func (m *ConnPool) Begin(ctx context.Context) (adapter.Tx, error)

Begin mock implementation of adapter.ConnPool.Begin()

func (*ConnPool) Close ¶

func (m *ConnPool) Close() error

Close mock implementation of adapter.ConnPool.Close()

func (*ConnPool) Ping ¶

func (m *ConnPool) Ping(ctx context.Context) error

Ping mock implementation of adapter.ConnPool.Ping()

type OpenOpenTestPoolMaxConns ¶

type OpenOpenTestPoolMaxConns func(t testing.TB, maxConnections int32) adapter.ConnPool

OpenOpenTestPoolMaxConns callback type for opening connection pool with custom max connections used in tests

type OpenTestPool ¶

type OpenTestPool func(t testing.TB) adapter.ConnPool

OpenTestPool callback type for opening connection pool with default parameters used in tests

type Queryable ¶

type Queryable struct {
	mock.Mock
}

Queryable mock implementation of adapter.Queryable

func (*Queryable) Exec ¶

func (m *Queryable) Exec(ctx context.Context, query string, args ...any) (adapter.CommandTag, error)

Exec mock implementation of adapter.Queryable.Exec()

func (*Queryable) Query ¶

func (m *Queryable) Query(ctx context.Context, query string, args ...any) (adapter.Rows, error)

Query mock implementation of adapter.Queryable.Query()

func (*Queryable) QueryRow ¶

func (m *Queryable) QueryRow(ctx context.Context, query string, args ...any) adapter.Row

QueryRow mock implementation of adapter.Queryable.QueryRow()

type Row ¶

type Row struct {
	mock.Mock
}

Row mock implementation of adapter.Row

func (*Row) Scan ¶

func (m *Row) Scan(dest ...any) error

Scan mock implementation of adapter.Row.Scan()

type Rows ¶

type Rows struct {
	mock.Mock
}

Rows mock implementation of adapter.Rows

func (*Rows) Err ¶

func (m *Rows) Err() error

Err mock implementation of adapter.Rows.Err()

func (*Rows) Next ¶

func (m *Rows) Next() bool

Next mock implementation of adapter.Rows.Next()

func (*Rows) Scan ¶

func (m *Rows) Scan(dest ...any) error

Scan mock implementation of adapter.Rows.Scan()

type Tx ¶

type Tx struct {
	Queryable
	mock.Mock
}

Tx mock implementation of adapter.Tx

func (*Tx) Commit ¶

func (m *Tx) Commit(ctx context.Context) error

Commit mock implementation of adapter.Tx.Commit()

func (*Tx) Rollback ¶

func (m *Tx) Rollback(ctx context.Context) error

Rollback mock implementation of adapter.Tx.Rollback()

Source Files ¶

all.go libpq.go mock.go pgxv4.go pgxv5.go