dal

Documentation

Index

• Variables
• func NewDB(conn *sql.DB, c config.AppConfig, scope tally.Scope, ...) (*gorm.DB, error)
• func Tx(tx Transaction, fc func(tx *query.Query) error) error
• type MysqlTransaction
  • func (t MysqlTransaction) Transaction(fc func(tx *query.Query) error) error
• type NoopTransaction
  • func (t NoopTransaction) Transaction(fc func(tx *query.Query) error) error
• type Transaction
  • func NewMysqlTransaction(q *query.Query) Transaction

Variables

var Module = fx.Module("dal",
	fx.Provide(
		NewDB,
		query.Use,
		NewMysqlTransaction,
	),
)

Functions

func NewDB

func NewDB(conn *sql.DB, c config.AppConfig, scope tally.Scope, prom prometheus.Registerer) (*gorm.DB, error)

func Tx

func Tx(tx Transaction, fc func(tx *query.Query) error) error

Types

type MysqlTransaction

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

func (MysqlTransaction) Transaction

func (t MysqlTransaction) Transaction(fc func(tx *query.Query) error) error

type NoopTransaction

type NoopTransaction struct {
}

func (NoopTransaction) Transaction

func (t NoopTransaction) Transaction(fc func(tx *query.Query) error) error

type Transaction

type Transaction interface {
	Transaction(fc func(tx *query.Query) error) error
}

func NewMysqlTransaction

func NewMysqlTransaction(q *query.Query) Transaction