uow

type Config struct {
	DisableNestedTransaction bool
	// contains filtered or unexported fields
}

type DbFactory func(ctx context.Context, keys ...string) (TransactionalDb, error)

type IdGenerator func(ctx context.Context) string

type KeyFormatter func(keys ...string) string

type Manager interface {
	CreateNew(ctx context.Context, opt ...*sql.TxOptions) (*UnitOfWork, error)
	// WithNew create a new unit of work and execute [fn] with this unit of work
	WithNew(ctx context.Context, fn func(ctx context.Context) error, opt ...*sql.TxOptions) error
}

type Option func(*Config)

type TransactionalDb interface {
	// Begin a transaction
	Begin(opt ...*sql.TxOptions) (db Txn, err error)
}

type Txn interface {
	Commit() error
	Rollback() error
}

type UnitOfWork struct {
	// contains filtered or unexported fields
}