repository

Documentation

Index

• type DBTX
  • func NewDBTX(db Querier) *DBTX
  • func (d *DBTX) DB() Querier
  • func (d *DBTX) InTransaction(ctx context.Context, fn TransactionFunc) error
• type PaginationParams
• type Querier
• type QuerierTX
• type TransactionFunc

Types

type DBTX

type DBTX struct {
	// contains filtered or unexported fields
}

func NewDBTX

func NewDBTX(db Querier) *DBTX

func (*DBTX) DB

func (d *DBTX) DB() Querier

func (*DBTX) InTransaction

func (d *DBTX) InTransaction(ctx context.Context, fn TransactionFunc) error

type PaginationParams

type PaginationParams struct {
	Limit  uint64
	Offset uint64
}

type Querier

type Querier interface {
	Begin(ctx context.Context) (pgx.Tx, error)
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
}

type QuerierTX

type QuerierTX interface {
	Querier
	Commit(ctx context.Context) error
	Rollback(ctx context.Context) error
}

type TransactionFunc

type TransactionFunc func(ctx context.Context, qe Querier) error