txmng

package module

Go to main page

Versions in this module

v1

v1.0.1

Dec 8, 2025

Changes in this version

+ type Result interface

+ Scan func(args ...any) error

+ func NewResult(args ...any) Result

v1.0.0

Oct 18, 2025

Changes in this version

type DBManager

+ MustGetDB func(ctx Context) T

type DBProvider

+ func NewPGXProvider(db *pgxpool.Pool) DBProvider[PGX]

+ func NewStdSQLProvider(db *sql.DB) DBProvider[StdSQL]

+ BeginTx func(opts TxOpts) (Tx[T], error)

+ GetDB func(opts NoTxOpts) T

+ type NoTxOpts struct

+ Ctx context.Context

+ Ext any

type Option

+ func WithDefaultRetrier() Option

+ func WithRetrier(r Retrier) Option

+ func WithRetrierParams(delays []time.Duration, jitter float64) Option

+ type PGX interface

+ type Retrier interface

+ Do func(func() error) error

+ type StdSQL interface

+ Commit func() error

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ Rollback func() error

+ type Tx interface

+ Commit func(ctx context.Context) error

+ GetDB func() T

+ Rollback func(ctx context.Context) error

type TxManager

+ RunNoTx func(opts NoTxOpts, fn func(ctx Context) (Scanner, error)) (Scanner, error)

+ RunTx func(opts TxOpts, fn func(ctx Context) (Scanner, error)) (Scanner, error)

+ type TxOpts struct

+ Ctx context.Context

+ Ext any

+ Isolation IsolationLevel

+ ReadOnly bool

+ type TxOptsExt struct

+ BeginQuery string

+ CommitQuery string

+ DeferrableMode bool

v0

v0.2.0

May 24, 2025

Changes in this version

+ func New(p DBProvider, opts ...Option) (txm TxManager, dbm DBManager)

+ type Config struct

+ type Context interface

+ func NewContext(ctx context.Context) Context

+ type DB interface

+ type DBManager interface

+ GetDB func(ctx Context) (DB, error)

+ type DBProvider interface

+ Raw func() DB

+ Tx func(opts Opts) (DB, error)

+ func NewDefaultSQLDBProvider(db *sql.DB) DBProvider

+ type IsolationLevel int

+ const LevelDefault

+ const LevelLinearizable

+ const LevelReadCommitted

+ const LevelReadUncommitted

+ const LevelRepeatableRead

+ const LevelSerializable

+ const LevelSnapshot

+ const LevelWriteCommitted

+ type MockDB struct

+ func NewMockDB(ctrl *gomock.Controller) *MockDB

+ func (m *MockDB) Commit() error

+ func (m *MockDB) EXPECT() *MockDBMockRecorder

+ func (m *MockDB) ExecContext(arg0 context.Context, arg1 string, arg2 ...interface{}) (sql.Result, error)

+ func (m *MockDB) PrepareContext(arg0 context.Context, arg1 string) (*sql.Stmt, error)

+ func (m *MockDB) QueryContext(arg0 context.Context, arg1 string, arg2 ...interface{}) (*sql.Rows, error)

+ func (m *MockDB) QueryRowContext(arg0 context.Context, arg1 string, arg2 ...interface{}) *sql.Row

+ func (m *MockDB) Rollback() error

+ type MockDBManager struct

+ func NewMockDBManager(ctrl *gomock.Controller) *MockDBManager

+ func (m *MockDBManager) EXPECT() *MockDBManagerMockRecorder

+ func (m *MockDBManager) GetDB(ctx context.Context) (DB, error)

+ type MockDBManagerMockRecorder struct

+ func (mr *MockDBManagerMockRecorder) GetDB(ctx interface{}) *gomock.Call

+ type MockDBMockRecorder struct

+ func (mr *MockDBMockRecorder) Commit() *gomock.Call

+ func (mr *MockDBMockRecorder) ExecContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockDBMockRecorder) PrepareContext(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockDBMockRecorder) QueryContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockDBMockRecorder) QueryRowContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockDBMockRecorder) Rollback() *gomock.Call

+ type MockDBProvider struct

+ func NewMockDBProvider(ctrl *gomock.Controller) *MockDBProvider

+ func (m *MockDBProvider) EXPECT() *MockDBProviderMockRecorder

+ func (m *MockDBProvider) Raw() DB

+ func (m *MockDBProvider) Tx(opts Opts) (DB, error)

+ type MockDBProviderMockRecorder struct

+ func (mr *MockDBProviderMockRecorder) Raw() *gomock.Call

+ func (mr *MockDBProviderMockRecorder) Tx(opts interface{}) *gomock.Call

+ type MockTxManager struct

+ func NewMockTxManager(ctrl *gomock.Controller) *MockTxManager

+ func (m *MockTxManager) EXPECT() *MockTxManagerMockRecorder

+ func (m *MockTxManager) Tx(opts Opts, f func(context.Context) (Scanner, error)) (Scanner, error)

+ type MockTxManagerMockRecorder struct

+ func (mr *MockTxManagerMockRecorder) Tx(opts, f interface{}) *gomock.Call

+ type Option func(cfg *Config)

+ func WithDefaultRetries(retryCount int, retryInterval time.Duration) Option

+ func WithForbidRawDB(v bool) Option

+ func WithRetries(retryCount int, retryInterval time.Duration, retryNeed func(error) bool) Option

+ type Opts struct

+ Ctx context.Context

+ Isolation IsolationLevel

+ ReadOnly bool

+ type Scanner interface

+ Scan func(args ...any) error

+ func Values(args ...any) Scanner

+ type TxManager interface

+ Tx func(opts Opts, f func(ctx Context) (Scanner, error)) (Scanner, error)

v0.1.0

Jun 3, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL