gorm

Documentation

Index

• Variables
• func Get(ctx context.Context) (*gorm.DB, error)
• func Initialize(db *gorm.DB)
• func InitializeDialector(dialector *gorm.Dialector)
• func Invalidate()
• func InvalidateDialector()
• func Manager() manager
• func NewStatement(fn func(ctx context.Context, tx *gorm.DB, out db.StatementResult) error, ...) db.Statement
• func TraceableScan(tx *newrelic.Transaction, db *gorm.DB, dest interface{}) *gorm.DB
• func WithTransaction(tx *gorm.DB) db.ExecuteOption
• type Statement
  • func (s *Statement) Execute(ctx context.Context, opts ...db.ExecuteOption) error
  • func (s *Statement) Result() db.StatementResult
• type Transaction
  • func (t *Transaction) Commit(ctx context.Context) error
  • func (t *Transaction) ExecuteStatement(ctx context.Context, statement db.Statement) error
  • func (t *Transaction) Rollback(ctx context.Context) error
  • func (t *Transaction) SubscribeError() <-chan error

Variables

var ErrAlreadyExecuted = errors.New("statement is already executed.")

var ErrDialectorNotInitialized = errors.New("gorm dialector is not initialized")

Functions

func Get

func Get(ctx context.Context) (*gorm.DB, error)

func Initialize

func Initialize(db *gorm.DB)

Initialize initializes gorm database connection.

func InitializeDialector

func InitializeDialector(dialector *gorm.Dialector)

InitializeDialector initializes gorm database dialector.

func Invalidate

func Invalidate()

Invalidate invalidates gorm connection.

func InvalidateDialector

func InvalidateDialector()

InvalidateDialector invalidates gorm database dialector.

func Manager

func Manager() manager

func NewStatement

func NewStatement(fn func(ctx context.Context, tx *gorm.DB, out db.StatementResult) error, out db.StatementResult) db.Statement

func TraceableScan

func TraceableScan(tx *newrelic.Transaction, db *gorm.DB, dest interface{}) *gorm.DB

TraceableScan is a wrapper around gorm.DB.Scan that instruments with New Relic.

func WithTransaction

func WithTransaction(tx *gorm.DB) db.ExecuteOption

WithTransaction is an option to set transaction to Statement.

Types

type Statement

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

Statement is a implementation of db.Statement for gorm.

func (*Statement) Execute

func (s *Statement) Execute(ctx context.Context, opts ...db.ExecuteOption) error

func (*Statement) Result

func (s *Statement) Result() db.StatementResult

type Transaction

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

func (*Transaction) Commit

func (t *Transaction) Commit(ctx context.Context) error

func (*Transaction) ExecuteStatement

func (t *Transaction) ExecuteStatement(ctx context.Context, statement db.Statement) error

func (*Transaction) Rollback

func (t *Transaction) Rollback(ctx context.Context) error

func (*Transaction) SubscribeError

func (t *Transaction) SubscribeError() <-chan error