go-transaction-manager

1
package pgxv4
2

3
import (
4
	"context"
5

6
	"github.com/avito-tech/go-transaction-manager/trm/v2"
7
)
8

9
// NewDefaultFactory creates default trm.Transaction(pgx.Tx).
10
func NewDefaultFactory(db Transactional) trm.TrFactory {
11
	return NewFactory(db)
12
}
13

14
// NewFactory creates trm.Transaction(pgx.Tx).
15
func NewFactory(db Transactional) trm.TrFactory {
16
	return func(ctx context.Context, trms trm.Settings) (context.Context, trm.Transaction, error) {
17
		s, _ := trms.(Settings)
18

19
		return NewTransaction(ctx, s.TxOpts(), db)
20
	}
21
}
22