tx

Documentation

Index

• func CreateTables(ctx context.Context, chDB *ch.DB, pgDB *bun.DB) error
• type Repository
  • func NewRepository(ck *ch.DB, pg *bun.DB) *Repository
  • func (r *Repository) AddTransactions(ctx context.Context, tx bun.Tx, transactions []*core.Transaction) error
  • func (r *Repository) AggregateTransactionsHistory(ctx context.Context, req *history.TransactionsReq) (*history.TransactionsRes, error)
  • func (r *Repository) FilterTransactions(ctx context.Context, req *filter.TransactionsReq) (*filter.TransactionsRes, error)

Functions

func CreateTables

func CreateTables(ctx context.Context, chDB *ch.DB, pgDB *bun.DB) error

Types

type Repository

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

func NewRepository

func NewRepository(ck *ch.DB, pg *bun.DB) *Repository

func (*Repository) AddTransactions

func (r *Repository) AddTransactions(ctx context.Context, tx bun.Tx, transactions []*core.Transaction) error

func (*Repository) AggregateTransactionsHistory

func (r *Repository) AggregateTransactionsHistory(ctx context.Context, req *history.TransactionsReq) (*history.TransactionsRes, error)

func (*Repository) FilterTransactions

func (r *Repository) FilterTransactions(ctx context.Context, req *filter.TransactionsReq) (*filter.TransactionsRes, error)