pgxv4

Sep 4, 2024

Changes in this version

+ var DefaultCtxGetter = NewCtxGetter(trmcontext.DefaultManager)

+ func NewDefaultFactory(db Transactional) trm.TrFactory

+ func NewFactory(db Transactional) trm.TrFactory

+ type CtxGetter struct

+ func NewCtxGetter(c trm.СtxManager) *CtxGetter

+ func (c *CtxGetter) DefaultTrOrDB(ctx context.Context, db Tr) Tr

+ func (c *CtxGetter) TrOrDB(ctx context.Context, key trm.CtxKey, db Tr) Tr

+ type Opt func(*Settings) error

+ func WithTxOptions(opts pgx.TxOptions) Opt

+ type Settings struct

+ func MustSettings(trms trm.Settings, oo ...Opt) Settings

+ func NewSettings(trms trm.Settings, oo ...Opt) (Settings, error)

+ func (s Settings) EnrichBy(in trm.Settings) trm.Settings

+ func (s Settings) TxOpts() pgx.TxOptions

+ type Tr interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

+ BeginFunc func(ctx context.Context, f func(pgx.Tx) error) (err error)

+ CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)

+ Exec func(ctx context.Context, sql string, arguments ...interface{}) (commandTag pgconn.CommandTag, err error)

+ Query func(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

+ QueryFunc func(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error)

+ QueryRow func(ctx context.Context, sql string, args ...interface{}) pgx.Row

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

+ type Transaction struct

+ func NewTransaction(ctx context.Context, opts pgx.TxOptions, db Transactional) (context.Context, *Transaction, error)

+ func (t *Transaction) Begin(ctx context.Context, _ trm.Settings) (context.Context, trm.Transaction, error)

+ func (t *Transaction) Closed() <-chan struct{}

+ func (t *Transaction) Commit(ctx context.Context) error

+ func (t *Transaction) IsActive() bool

+ func (t *Transaction) Rollback(ctx context.Context) error

+ func (t *Transaction) Transaction() interface{}

+ type Transactional interface

+ BeginTx func(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)