txn_mongo

Sep 13, 2023

Changes in this version

type ModuleBase

+ func (b *ModuleBase) Mutate(setters ...ModuleSetter)

+ type ModuleSetter func(*ModuleBase)

+ func WithBeginner(value Beginner) ModuleSetter

+ type RawTx = mongo.Session

+ type RawTxn interface

+ Raw func() RawTx

Sep 11, 2023

Changes in this version

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

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

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

+ type Beginner = *mongo.Client

+ type Doer interface

+ Client func() T

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

+ SetClient func(T)

+ type DoerBase struct

+ func (do *DoerBase[T]) Client() T

+ func (do *DoerBase[T]) SetClient(value T)

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

+ type MgoOptions struct

+ type Module interface

+ Beginner func() Beginner

+ type ModuleBase struct

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

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

+ type Options = *MgoOptions

+ type StmtHolder = any

+ type Txn struct

+ Raw mongo.Session

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

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

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