txn_pgx

Sep 13, 2023

Changes in this version

+ type RawTx = pgx.Tx

+ type RawTxn interface

+ Raw func() RawTx

Sep 11, 2023

Changes in this version

type Doer

+ ReadOnlySetters func(title string) []txn.DoerFieldSetter

+ ReadWriteSetters func(title string) []txn.DoerFieldSetter

Sep 8, 2023

Changes in this version

+ func Execute(ctx context.Context, mod Module[Stmt], doer D, ...) (D, error)

+ func ExecuteOnce(ctx context.Context, beginner Beginner, do D, ...) (D, error)

+ func ExecuteRo(ctx context.Context, mod Module[Stmt], do D, ...) (D, error)

+ func ExecuteRw(ctx context.Context, mod Module[Stmt], do D, ...) (D, error)

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

+ type Beginner = *pgxpool.Pool

+ type Doer interface

+ SetStmt func(Stmt)

+ Stmt func() Stmt

+ type DoerBase struct

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

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

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

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

+ type Module interface

+ Beginner func() Beginner

+ type ModuleBase struct

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

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

+ type Options = *pgx.TxOptions

+ type StmtHolder = any

type Txn

+ Raw pgx.Tx

+ func BeginTxn(ctx context.Context, beginner Beginner, opt Options) (*Txn, error)

+ func (w *Txn) Commit(ctx context.Context) error

+ func (w *Txn) Rollback(ctx context.Context) error

Sep 7, 2023

Changes in this version

+ func PgxRoExecute(ctx context.Context, log logr.Logger, mod PgxModule[Stmt], doer Doer, ...) (Doer, error)

+ func PgxRwExecute(ctx context.Context, log logr.Logger, mod PgxModule[Stmt], doer Doer, ...) (Doer, error)

+ type PgxModule interface

+ Beginner func() PgxBeginner

+ type PgxModuleBase struct

+ func (b *PgxModuleBase[_]) Beginner() PgxBeginner

+ func (b *PgxModuleBase[_]) Init(beginner PgxBeginner)

+ type PgxStmt = any

Sep 6, 2023

Changes in this version

+ func PgxPing(ctx context.Context, beginner PgxBeginner, doer PgxDoer[T], ...) (int, error)

Sep 5, 2023

Changes in this version

type PgxDoerBase

+ func (do *PgxDoerBase[_]) SetReadOnly(title string)

+ func (do *PgxDoerBase[_]) SetReadWrite(title string)

Sep 5, 2023

Changes in this version

+ type PgxDoer interface

+ Options func() PgxOptions

+ ReadOnly func(title string)

+ ReadWrite func(title string)

+ SetOptions func(options PgxOptions)

+ SetStmt func(Stmt)

+ Stmt func() Stmt

type PgxDoerBase

+ func (do *PgxDoerBase[Stmt]) BeginTxn(context.Context, PgxBeginner) (Txn, error)

+ func (do *PgxDoerBase[Stmt]) ReadOnly(title string)

+ func (do *PgxDoerBase[Stmt]) ReadWrite(title string)

+ type TxnDoer = txn.Doer[Txn, PgxBeginner]

Aug 31, 2023

Changes in this version

type PgxDoerBase

+ func (do *PgxDoerBase[any]) SetStmt(s any)

+ func (do *PgxDoerBase[any]) Stmt() any

Aug 30, 2023

Changes in this version

+ func PgxExecute(ctx context.Context, db PgxBeginner, do D, fn txn.DoFunc[Txn, PgxBeginner, D]) (D, error)

+ type PgxBeginner = *pgxpool.Pool

+ type PgxDoerBase struct

+ func (d *PgxDoerBase) IsReadOnly() bool

+ type PgxOptions = *pgx.TxOptions

+ type PgxTx = pgx.Tx

+ type PgxTxn struct

+ Raw PgxTx

+ func PgxBeginTxn(ctx context.Context, db PgxBeginner, opt PgxOptions) (*PgxTxn, error)

+ func (w *PgxTxn) Commit(ctx context.Context) error

+ func (w *PgxTxn) IsNil() bool

+ func (w *PgxTxn) Rollback(ctx context.Context) error

+ type Txn = txn.Txn