Versions in this module Expand all Collapse all v0 v0.0.1 Sep 19, 2024 Changes in this version + func ListenToNotifications(ctx context.Context, pool PgxPool, channel string, ...) + type MockConn struct + func (m *MockConn) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) + func (m *MockConn) Release() + func (m *MockConn) WaitForNotification(ctx context.Context) (*pgconn.Notification, error) + type MockPool struct + func (m *MockPool) Acquire(ctx context.Context) (PgxConn, error) + func (m *MockPool) Close() + func (m *MockPool) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) + func (m *MockPool) Query(ctx context.Context, sql string, arguments ...interface{}) (pgx.Rows, error) + func (m *MockPool) QueryRow(ctx context.Context, sql string, arguments ...interface{}) pgx.Row + type MockRow struct + func (m *MockRow) Scan(dest ...interface{}) error + type MockRows struct + func (m *MockRows) Close() + func (m *MockRows) Err() error + func (m *MockRows) Next() bool + func (m *MockRows) Scan(dest ...interface{}) error + type PgxConn interface + Exec func(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) + Release func() + WaitForNotification func(ctx context.Context) (*pgconn.Notification, error) + type PgxPool interface + Acquire func(ctx context.Context) (PgxConn, error) + Close func() + Exec func(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) + Query func(ctx context.Context, sql string, arguments ...interface{}) (pgx.Rows, error) + QueryRow func(ctx context.Context, sql string, arguments ...interface{}) pgx.Row + func NewPGXPoolWrapper(pool *pgxpool.Pool) PgxPool
Go to main page