gormrepo

Documentation

Index

• type TxnDataSQL
  • func NewTxnDataSQL(db *gorm.DB) *TxnDataSQL
  • func (tds *TxnDataSQL) GetTxn(ctx context.Context) interface{}
  • func (tds *TxnDataSQL) TxnBegin(ctx context.Context) context.Context
  • func (tds *TxnDataSQL) TxnCommit(ctx context.Context) (err error)
  • func (tds *TxnDataSQL) TxnRollback(ctx context.Context) (err error)
• type UserRepository
  • func NewUserRepository() *UserRepository
  • func (r *UserRepository) Create(ctx context.Context, ent entity.User) (created entity.User, err error)
  • func (r *UserRepository) DB(ctx context.Context) *gorm.DB
  • func (r *UserRepository) GetByID(ctx context.Context, id interface{}) (ent entity.User, err error)

Types

type TxnDataSQL

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

TxnDataSQL manages the transaction by implementing the Transaction Manager interface

func NewTxnDataSQL

func NewTxnDataSQL(db *gorm.DB) *TxnDataSQL

NewTxnDataSQL is the contructor function

func (*TxnDataSQL) GetTxn

func (tds *TxnDataSQL) GetTxn(ctx context.Context) interface{}

GetTxn to get the current transaction of this service

func (*TxnDataSQL) TxnBegin

func (tds *TxnDataSQL) TxnBegin(ctx context.Context) context.Context

TxnBegin begin a new transaction

func (*TxnDataSQL) TxnCommit

func (tds *TxnDataSQL) TxnCommit(ctx context.Context) (err error)

TxnCommit commit a transaction

func (*TxnDataSQL) TxnRollback

func (tds *TxnDataSQL) TxnRollback(ctx context.Context) (err error)

TxnRollback rollback a transaction

type UserRepository

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

UserRepository repository struct implement the User Repository interface

func NewUserRepository

func NewUserRepository() *UserRepository

NewUserRepository creates the new instance of User Repository

func (*UserRepository) Create

func (r *UserRepository) Create(ctx context.Context, ent entity.User) (created entity.User, err error)

Create method to call DB to create the new user

func (*UserRepository) DB

func (r *UserRepository) DB(ctx context.Context) *gorm.DB

DB to get the transaction to Database from context

func (*UserRepository) GetByID

func (r *UserRepository) GetByID(ctx context.Context, id interface{}) (ent entity.User, err error)

GetByID get the User by ID