ledger

Documentation

Index

• type Repository
  • func NewRepository(db *pgxpool.Pool, pb *instrumentators.LedgerInstrumentator) *Repository
  • func (r Repository) CreateTransaction(ctx context.Context, transaction entities.Transaction) error
  • func (r Repository) GetAnalyticAccountBalance(ctx context.Context, account vos.Account) (vos.AccountBalance, error)
  • func (r Repository) GetBoundedAccountBalance(ctx context.Context, acc vos.Account, start, end time.Time) (vos.AccountBalance, error)
  • func (r Repository) GetSyntheticAccountBalance(ctx context.Context, account vos.Account) (vos.AccountBalance, error)
  • func (r *Repository) GetSyntheticReport(ctx context.Context, query vos.Account, level int, startTime time.Time, ...) (*vos.SyntheticReport, error)
  • func (r Repository) ListAccountEntries(ctx context.Context, req vos.AccountEntryRequest) ([]vos.AccountEntry, pag.Cursor, error)

Types

type Repository

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

func NewRepository

func NewRepository(db *pgxpool.Pool, pb *instrumentators.LedgerInstrumentator) *Repository

func (Repository) CreateTransaction

func (r Repository) CreateTransaction(ctx context.Context, transaction entities.Transaction) error

func (Repository) GetAnalyticAccountBalance

func (r Repository) GetAnalyticAccountBalance(ctx context.Context, account vos.Account) (vos.AccountBalance, error)

func (Repository) GetBoundedAccountBalance

func (r Repository) GetBoundedAccountBalance(ctx context.Context, acc vos.Account, start, end time.Time) (vos.AccountBalance, error)

func (Repository) GetSyntheticAccountBalance

func (r Repository) GetSyntheticAccountBalance(ctx context.Context, account vos.Account) (vos.AccountBalance, error)

func (*Repository) GetSyntheticReport

func (r *Repository) GetSyntheticReport(ctx context.Context, query vos.Account, level int, startTime time.Time, endTime time.Time) (*vos.SyntheticReport, error)

func (Repository) ListAccountEntries

func (r Repository) ListAccountEntries(ctx context.Context, req vos.AccountEntryRequest) ([]vos.AccountEntry, pag.Cursor, error)