psql

package
v0.0.0-...-514f96b Latest Latest
Warning

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

Go to latest
Published: May 29, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountRepository

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

func NewAccountRepository

func NewAccountRepository(db *postgres.Client, logger *zap.Logger) *AccountRepository

func (*AccountRepository) AddBalance

func (ar *AccountRepository) AddBalance(
	ctx context.Context,
	dto account.AddBalanceDTO,
) (int64, error)

func (*AccountRepository) GetAccountByID

func (ar *AccountRepository) GetAccountByID(ctx context.Context, accountID int64) (account.Account, error)

func (*AccountRepository) ReserveBalance

func (ar *AccountRepository) ReserveBalance(ctx context.Context, dto account.ReserveBalanceDTO) (int64, error)

func (*AccountRepository) ReturnBalance

func (ar *AccountRepository) ReturnBalance(ctx context.Context, dto account.ReturnBalanceDTO) (int64, error)

func (*AccountRepository) TransferBalance

func (ar *AccountRepository) TransferBalance(
	ctx context.Context,
	dto account.TransferBalanceDTO,
) (int64, int64, error)

type OrderRepository

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

func NewOrderRepository

func NewOrderRepository(db *postgres.Client, logger *zap.Logger) *OrderRepository

func (*OrderRepository) CancelOrder

func (or *OrderRepository) CancelOrder(ctx context.Context, dto order.CancelDTO) error

func (*OrderRepository) CreateOrder

func (or *OrderRepository) CreateOrder(ctx context.Context, dto order.CreateDTO) (order.Order, error)

func (*OrderRepository) PayForOrder

func (or *OrderRepository) PayForOrder(ctx context.Context, dto order.PayForDTO) error

type ReportRepository

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

func NewReportRepository

func NewReportRepository(db *postgres.Client, logger *zap.Logger) *ReportRepository

func (*ReportRepository) GetReportMap

func (rr *ReportRepository) GetReportMap(ctx context.Context, dto report.GetMapDTO) (map[int64]int64, error)

type Repositories

type Repositories struct {
	Account     *AccountRepository
	Transaction *TransactionRepository
	Order       *OrderRepository
	Report      *ReportRepository
}

func NewRepositories

func NewRepositories(db *postgres.Client, logger *zap.Logger) *Repositories

type TransactionRepository

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

func NewTransactionRepository

func NewTransactionRepository(db *postgres.Client, logger *zap.Logger) *TransactionRepository

func (*TransactionRepository) CreateTransaction

func (tr *TransactionRepository) CreateTransaction(ctx context.Context, dto transaction.CreateDTO) error

func (*TransactionRepository) GetTransactionsByAccountID

func (tr *TransactionRepository) GetTransactionsByAccountID(
	ctx context.Context,
	accountID int64,
	listParams transaction.ListParams,
) ([]transaction.Transaction, int, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL