txmanager

package

v0.0.1 Latest Latest Go to latest Published: Mar 13, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewPgxPool(
	conn *pgxpool.Conn,
) *pgxManager

func NewSqlx(
	db *sqlx.DB,
) *sqlxManager

type Fn func(ctx context.Context) error

type MockTx struct {
	mock.Mock
}

func (m *MockTx) Begin(ctx context.Context) (pgx.Tx, error)

func (m *MockTx) Conn() *pgx.Conn

func (m *MockTx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)

func (m *MockTx) Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error)

func (m *MockTx) LargeObjects() pgx.LargeObjects

func (m *MockTx) Prepare(ctx context.Context, name, sql string) (*pgconn.StatementDescription, error)

func (m *MockTx) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func (m *MockTx) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row

func (m *MockTx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

type TxManager interface {
	Do(ctx context.Context, fn Fn) (err error)
	GetTxOrDb(ctx context.Context) trmsqlx.Tr
}