pkg

Documentation

Index

• Constants
• func IsActive(v interface{}) bool
• func RegisterCommit(ctx context.Context, key any, hook ...Hook)
• func RegisterRollback(ctx context.Context, key any, hook ...Hook)
• func RunTransaction[T any](ctx context.Context, begin Begin, ...) (res T, err error)
• func WithTransaction() interface{}
• type Begin
• type Hook
• type Hooks
  • func (h Hooks) Invoke(ctx context.Context)
• type TransactionContainer

Constants

const (
	ReadOnly    = "readOnly"
	Transaction = "transaction"
)

Functions

func IsActive

func IsActive(v interface{}) bool

func RegisterCommit

func RegisterCommit(ctx context.Context, key any, hook ...Hook)

func RegisterRollback

func RegisterRollback(ctx context.Context, key any, hook ...Hook)

func RunTransaction

func RunTransaction[T any](ctx context.Context, begin Begin, txFunc func(ctx context.Context, db *gorm.DB) (context.Context, T, error), key any, opts ...*sql.TxOptions) (res T, err error)

func WithTransaction

func WithTransaction() interface{}

Types

type Begin

type Begin func(ctx context.Context, opts ...*sql.TxOptions) *gorm.DB

type Hook

type Hook func(ctx context.Context)

type Hooks

type Hooks []Hook

func (Hooks) Invoke

func (h Hooks) Invoke(ctx context.Context)

type TransactionContainer

type TransactionContainer struct {
	DB              *gorm.DB
	TransactionType string
	// contains filtered or unexported fields
}