repository

package
v0.0.0-...-3ca87c7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 9, 2021 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountNoSQL 

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

func NewAccountNoSQL 

func NewAccountNoSQL(db NoSQL) AccountNoSQL

func (AccountNoSQL) Create 

func (a AccountNoSQL) Create(ctx context.Context, account domain.Account) (domain.Account, error)

func (AccountNoSQL) DeleteByID 

func (a AccountNoSQL) DeleteByID(ctx context.Context, ID domain.AccountID) (bool, error)

func (AccountNoSQL) FindAll 

func (a AccountNoSQL) FindAll(ctx context.Context) ([]domain.Account, error)

func (AccountNoSQL) FindBalance 

func (a AccountNoSQL) FindBalance(ctx context.Context, ID domain.AccountID) (domain.Account, error)

func (AccountNoSQL) FindByID 

func (a AccountNoSQL) FindByID(ctx context.Context, ID domain.AccountID) (domain.Account, error)

func (AccountNoSQL) UpdateBalance 

func (a AccountNoSQL) UpdateBalance(ctx context.Context, ID domain.AccountID, balance domain.Money) error

type AccountSQL 

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

func NewAccountSQL 

func NewAccountSQL(db SQL) AccountSQL

func (AccountSQL) Create 

func (a AccountSQL) Create(ctx context.Context, account domain.Account) (domain.Account, error)

func (AccountSQL) DeleteByID 

func (a AccountSQL) DeleteByID(ctx context.Context, ID domain.AccountID) (bool, error)

func (AccountSQL) FindAll 

func (a AccountSQL) FindAll(ctx context.Context) ([]domain.Account, error)

func (AccountSQL) FindBalance 

func (a AccountSQL) FindBalance(ctx context.Context, ID domain.AccountID) (domain.Account, error)

func (AccountSQL) FindByID 

func (a AccountSQL) FindByID(ctx context.Context, ID domain.AccountID) (domain.Account, error)

func (AccountSQL) UpdateBalance 

func (a AccountSQL) UpdateBalance(ctx context.Context, ID domain.AccountID, balance domain.Money) error

type CharityMrysSQL 

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

func NewCharityMrysSQL 

func NewCharityMrysSQL(db SQL) CharityMrysSQL

func (CharityMrysSQL) Create 

func (a CharityMrysSQL) Create(ctx context.Context, CharityMrys domain.CharityMrys) (domain.CharityMrys, error)

func (CharityMrysSQL) CreateBulk 

func (a CharityMrysSQL) CreateBulk(ctx context.Context, CharityMrys []domain.CharityMrys) ([]domain.CharityMrys, error)

func (CharityMrysSQL) DeleteByID 

func (a CharityMrysSQL) DeleteByID(ctx context.Context, ID string) (bool, error)

func (CharityMrysSQL) FindAll 

func (a CharityMrysSQL) FindAll(ctx context.Context, auth *domain.UserJwt) (domain.CharityMrysAll, error)

func (CharityMrysSQL) FindByID 

func (a CharityMrysSQL) FindByID(ctx context.Context, ID string) (domain.CharityMrys, error)

func (CharityMrysSQL) FindPagination 

func (a CharityMrysSQL) FindPagination(ctx context.Context, currentPage int, perPage int, sort string, search string) (domain.CharityMrysPagination, error)

func (CharityMrysSQL) Update 

func (a CharityMrysSQL) Update(ctx context.Context, CharityMrys domain.CharityMrys, ID string) (domain.CharityMrys, error)

type NoSQL 

type NoSQL interface {
	Store(context.Context, string, interface{}) error
	Update(context.Context, string, interface{}, interface{}) error
	FindAll(context.Context, string, interface{}, interface{}) error
	FindOne(context.Context, string, interface{}, interface{}, interface{}) error
	StartSession() (Session, error)
}

type ReceiptLunarSQL 

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

func NewReceiptLunarSQL 

func NewReceiptLunarSQL(db SQL) ReceiptLunarSQL

func (ReceiptLunarSQL) Create 

func (a ReceiptLunarSQL) Create(ctx context.Context, ReceiptLunar domain.ReceiptLunar) (domain.ReceiptLunar, error)

func (ReceiptLunarSQL) DeleteByID 

func (a ReceiptLunarSQL) DeleteByID(ctx context.Context, Id string) (bool, error)

func (ReceiptLunarSQL) DeleteByReceiptLunarId 

func (a ReceiptLunarSQL) DeleteByReceiptLunarId(ctx context.Context, Id string) (bool, error)

func (ReceiptLunarSQL) FindAllByReceiptLunarId 

func (a ReceiptLunarSQL) FindAllByReceiptLunarId(ctx context.Context, Id string) ([]domain.ReceiptLunarDetail, error)

func (ReceiptLunarSQL) FindByID 

func (a ReceiptLunarSQL) FindByID(ctx context.Context, Id string) (domain.ReceiptLunar, error)

func (ReceiptLunarSQL) FindPagination 

func (a ReceiptLunarSQL) FindPagination(ctx context.Context, currentPage int, perPage int, sort string, search string) (domain.ReceiptLunarPagination, error)

func (ReceiptLunarSQL) Update 

func (a ReceiptLunarSQL) Update(ctx context.Context, ReceiptLunar domain.ReceiptLunar, Id string) (domain.ReceiptLunar, error)

type Row 

type Row interface {
	Scan(dest ...interface{}) error
}

type Rows 

type Rows interface {
	Scan(dest ...interface{}) error
	Next() bool
	Err() error
	Close() error
}

type SQL 

type SQL interface {
	ExecuteContext(context.Context, string, ...interface{}) error
	InsertPG(context.Context, string, ...interface{}) error
	UpdatePG(context.Context, interface{}, string) error
	ExecuteContextPG(context.Context, interface{}, string, ...interface{}) error
	GetDBPG(context.Context) *pg.DB
	GetDBGorm(context.Context) *gorm.DB
	QueryContext(context.Context, string, ...interface{}) (Rows, error)
	QueryContextPG(context.Context, interface{}, string, ...interface{}) (pg.Result, error)
	QueryRowContext(context.Context, string, ...interface{}) Row
	QueryRowContextPG(context.Context, interface{}, string, ...interface{}) (pg.Result, error)
	BeginTx(ctx context.Context) (Tx, error)
}

type Session 

type Session interface {
	WithTransaction(context.Context, func(context.Context) error) error
	EndSession(context.Context)
}

type TransferNoSQL 

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

func NewTransferNoSQL 

func NewTransferNoSQL(db NoSQL) TransferNoSQL

func (TransferNoSQL) Create 

func (t TransferNoSQL) Create(ctx context.Context, transfer domain.Transfer) (domain.Transfer, error)

func (TransferNoSQL) FindAll 

func (t TransferNoSQL) FindAll(ctx context.Context) ([]domain.Transfer, error)

func (TransferNoSQL) WithTransaction 

func (t TransferNoSQL) WithTransaction(ctx context.Context, fn func(ctxTx context.Context) error) error

type TransferSQL 

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

func NewTransferSQL 

func NewTransferSQL(db SQL) TransferSQL

func (TransferSQL) Create 

func (t TransferSQL) Create(ctx context.Context, transfer domain.Transfer) (domain.Transfer, error)

func (TransferSQL) FindAll 

func (t TransferSQL) FindAll(ctx context.Context) ([]domain.Transfer, error)

func (TransferSQL) WithTransaction 

func (t TransferSQL) WithTransaction(ctx context.Context, fn func(ctxTx context.Context) error) error

type Tx 

type Tx interface {
	ExecuteContext(context.Context, string, ...interface{}) error
	ExecuteContextPG(context.Context, interface{}, string, ...interface{}) error
	QueryContext(context.Context, string, ...interface{}) (Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) Row
	QueryRowContextPG(context.Context, interface{}, string, ...interface{}) (pg.Result, error)
	Commit() error
	Rollback() error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.