txn_pgx

Documentation

Index

• func Execute[Stmt StmtHolder, D Doer[Stmt]](ctx context.Context, mod Module[Stmt], doer D, ...) (D, error)
• func ExecuteOnce[D txn.Doer[Options, Beginner]](ctx context.Context, beginner Beginner, do D, ...) error
• func ExecuteRo[Stmt StmtHolder, D Doer[Stmt]](ctx context.Context, mod Module[Stmt], do D, ...) (D, error)
• func ExecuteRw[Stmt StmtHolder, D Doer[Stmt]](ctx context.Context, mod Module[Stmt], do D, ...) (D, error)
• func Ping(beginner Beginner, limit int, count txn.PingCount) (int, error)
• type Beginner
• type Doer
• type DoerBase
  • func (do *DoerBase[_]) ReadOnlySetters(title string) []txn.DoerFieldSetter
  • func (do *DoerBase[_]) ReadWriteSetters(title string) []txn.DoerFieldSetter
  • func (do *DoerBase[S]) SetStmt(s S)
  • func (do *DoerBase[S]) Stmt() S
• type Module
• type ModuleBase
  • func (b *ModuleBase[_]) Beginner() Beginner
  • func (b *ModuleBase[_]) Init(beginner Beginner)
• type Options
• type RawTx
• type RawTxn
  • func BeginTxn(ctx context.Context, beginner Beginner, opt Options) (RawTxn, error)
• type StmtHolder

Functions

func Execute

func Execute[Stmt StmtHolder, D Doer[Stmt]](
	ctx context.Context, mod Module[Stmt], doer D,
	fn txn.DoFunc[Options, Beginner, D], setters ...txn.DoerFieldSetter,
) (D, error)

func ExecuteOnce

func ExecuteOnce[
	D txn.Doer[Options, Beginner],
](ctx context.Context, beginner Beginner, do D, fn txn.DoFunc[Options, Beginner, D]) error

ExecuteOnce executes a pgx transaction.

func ExecuteRo

func ExecuteRo[Stmt StmtHolder, D Doer[Stmt]](
	ctx context.Context, mod Module[Stmt], do D,
	fn txn.DoFunc[Options, Beginner, D], setters ...txn.DoerFieldSetter,
) (D, error)

func ExecuteRw

func ExecuteRw[Stmt StmtHolder, D Doer[Stmt]](
	ctx context.Context, mod Module[Stmt], do D,
	fn txn.DoFunc[Options, Beginner, D], setters ...txn.DoerFieldSetter,
) (D, error)

func Ping

func Ping(beginner Beginner, limit int, count txn.PingCount) (int, error)

Ping performs a ping operation.

Types

type Beginner

type Beginner = *pgxpool.Pool

type Doer

type Doer[Stmt any] interface {
	txn.Doer[Options, Beginner]
	ReadOnlySetters(title string) []txn.DoerFieldSetter
	ReadWriteSetters(title string) []txn.DoerFieldSetter
	Stmt() Stmt
	SetStmt(Stmt)
}

Doer defines the interface for PGX transaction operations.

type DoerBase

type DoerBase[Stmt any] struct {
	txn.DoerBase[Options, Beginner]
	// contains filtered or unexported fields
}

DoerBase provides a base implementation for the Doer interface.

func (*DoerBase[_]) ReadOnlySetters

func (do *DoerBase[_]) ReadOnlySetters(title string) []txn.DoerFieldSetter

func (*DoerBase[_]) ReadWriteSetters

func (do *DoerBase[_]) ReadWriteSetters(title string) []txn.DoerFieldSetter

func (*DoerBase[S]) SetStmt

func (do *DoerBase[S]) SetStmt(s S)

SetStmt sets the statement.

func (*DoerBase[S]) Stmt

func (do *DoerBase[S]) Stmt() S

Stmt returns the statement.

type Module

type Module[Stmt StmtHolder] interface {
	Beginner() Beginner
}

type ModuleBase

type ModuleBase[Stmt StmtHolder] struct {
	// contains filtered or unexported fields
}

func (*ModuleBase[_]) Beginner

func (b *ModuleBase[_]) Beginner() Beginner

func (*ModuleBase[_]) Init

func (b *ModuleBase[_]) Init(beginner Beginner)

type Options

type Options = *pgx.TxOptions

type RawTx

type RawTx = pgx.Tx

type RawTxn

type RawTxn interface {
	txn.Txn
	Raw() RawTx
}

func BeginTxn

func BeginTxn(ctx context.Context, beginner Beginner, opt Options) (RawTxn, error)

BeginTxn begins a pgx transaction.

type StmtHolder

type StmtHolder = any