account

Documentation

Index

• type Repo
• type Repository
  • func New(db *gorm.DB) *Repository
  • func (r *Repository) Balances(accountId string, from time.Time, to time.Time) (bal []models.AccountBalance, err error)
  • func (r *Repository) Count(filter models.Account) (count int64, err error)
  • func (r *Repository) CycleDelegators(accountID string, cycle int64, limit uint, offset uint) (delegators []models.AccountDelegator, err error)
  • func (r *Repository) CycleDelegatorsTotal(accountID string, cycleID int64) (reward models.AccountReward, err error)
  • func (r *Repository) Filter(filter models.Account, limit, offset uint) (accounts []models.AccountListView, err error)
  • func (r *Repository) Find(filter models.Account) (found bool, acc models.AccountListView, err error)
  • func (r *Repository) GetBakerChangesByLastCycle() (bakers []models.BakerChanges, err error)
  • func (r *Repository) GetBakingReport(accountID string, params models.ReportFilter) (report []models.ExtendReport, err error)
  • func (r *Repository) GetContractsCount(from time.Time, to time.Time) (count int64, err error)
  • func (r *Repository) GetContractsCountByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)
  • func (r *Repository) GetCount(from time.Time, to time.Time) (count int64, err error)
  • func (r *Repository) GetCountActive(from time.Time) (count int64, err error)
  • func (r *Repository) GetCountActiveByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)
  • func (r *Repository) GetCountByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)
  • func (r *Repository) GetCountWhereBalance(lessThen int64) (count int64, err error)
  • func (r *Repository) GetReport(accountID string, params models.ReportFilter) (report []models.ExtendReport, err error)
  • func (r *Repository) List(limit, offset uint, filter models.AccountFilter) (count int64, accounts []models.AccountListView, err error)
  • func (r *Repository) PrevBalance(accountId string, from time.Time) (found bool, balance models.AccountBalance, err error)
  • func (r *Repository) RewardsCountList(accountID string, limit uint) (rewards []models.AccountRewardsCount, err error)
  • func (r *Repository) RewardsList(accountID string, limit uint, offset uint) (count int64, rewards []models.AccountReward, err error)
  • func (r *Repository) RichAccounts(limit uint) (accounts []models.Account, err error)
  • func (r *Repository) TotalBalance() (b int64, err error)

Types

type Repo

type Repo interface {
	List(limit uint, offset uint, filter models.AccountFilter) (int64, []models.AccountListView, error)
	Filter(filter models.Account, limit, offset uint) (accounts []models.AccountListView, err error)
	Count(filter models.Account) (int64, error)
	Find(filter models.Account) (found bool, acc models.AccountListView, err error)
	TotalBalance() (int64, error)
	Balances(string, time.Time, time.Time) ([]models.AccountBalance, error)
	PrevBalance(string, time.Time) (bool, models.AccountBalance, error)
	RewardsList(accountID string, limit uint, offset uint) (count int64, rewards []models.AccountReward, err error)
	RewardsCountList(accountID string, limit uint) (rewards []models.AccountRewardsCount, err error)
	CycleDelegatorsTotal(accountID string, cycleID int64) (reward models.AccountReward, err error)
	CycleDelegators(accountID string, cycle int64, limit uint, offset uint) (delegators []models.AccountDelegator, err error)
	GetReport(accountID string, params models.ReportFilter) (report []models.ExtendReport, err error)
	GetBakingReport(accountID string, params models.ReportFilter) (report []models.ExtendReport, err error)
	GetBakerChangesByLastCycle() (bakers []models.BakerChanges, err error)
	GetCountByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)
	GetCount(from time.Time, to time.Time) (count int64, err error)
	GetCountWhereBalance(lessThen int64) (count int64, err error)
	GetCountActive(from time.Time) (count int64, err error)
	GetCountActiveByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)
	GetContractsCountByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)
	GetContractsCount(from time.Time, to time.Time) (count int64, err error)
	RichAccounts(limit uint) (accounts []models.Account, err error)
}

type Repository

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

Repository is the account repo implementation.

func New

func New(db *gorm.DB) *Repository

New creates an instance of repository using the provided db.

func (*Repository) Balances

func (r *Repository) Balances(accountId string, from time.Time, to time.Time) (bal []models.AccountBalance, err error)

func (*Repository) Count

func (r *Repository) Count(filter models.Account) (count int64, err error)

Count counts a number of accounts sutisfying the filter.

func (*Repository) CycleDelegators

func (r *Repository) CycleDelegators(accountID string, cycle int64, limit uint, offset uint) (delegators []models.AccountDelegator, err error)

func (*Repository) CycleDelegatorsTotal

func (r *Repository) CycleDelegatorsTotal(accountID string, cycleID int64) (reward models.AccountReward, err error)

func (*Repository) Filter

func (r *Repository) Filter(filter models.Account, limit, offset uint) (accounts []models.AccountListView, err error)

Filter returns a list of accounts that sutisfies the filter.

func (*Repository) Find

func (r *Repository) Find(filter models.Account) (found bool, acc models.AccountListView, err error)

Find looks up for an account with filter.

func (*Repository) GetBakerChangesByLastCycle

func (r *Repository) GetBakerChangesByLastCycle() (bakers []models.BakerChanges, err error)

func (*Repository) GetBakingReport

func (r *Repository) GetBakingReport(accountID string, params models.ReportFilter) (report []models.ExtendReport, err error)

func (*Repository) GetContractsCount

func (r *Repository) GetContractsCount(from time.Time, to time.Time) (count int64, err error)

func (*Repository) GetContractsCountByPeriod

func (r *Repository) GetContractsCountByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)

func (*Repository) GetCount

func (r *Repository) GetCount(from time.Time, to time.Time) (count int64, err error)

func (*Repository) GetCountActive

func (r *Repository) GetCountActive(from time.Time) (count int64, err error)

func (*Repository) GetCountActiveByPeriod

func (r *Repository) GetCountActiveByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)

func (*Repository) GetCountByPeriod

func (r *Repository) GetCountByPeriod(filter models.AggTimeFilter) (items []models.AggTimeInt, err error)

func (*Repository) GetCountWhereBalance

func (r *Repository) GetCountWhereBalance(lessThen int64) (count int64, err error)

func (*Repository) GetReport

func (r *Repository) GetReport(accountID string, params models.ReportFilter) (report []models.ExtendReport, err error)

func (*Repository) List

func (r *Repository) List(limit, offset uint, filter models.AccountFilter) (count int64, accounts []models.AccountListView, err error)

List returns a list of accounts from the newest to oldest. limit defines the limit for the maximum number of accounts returned. before is used to paginate results based on the level. As the result is ordered descendingly the accounts with level < before will be returned.

func (*Repository) PrevBalance

func (r *Repository) PrevBalance(accountId string, from time.Time) (found bool, balance models.AccountBalance, err error)

func (*Repository) RewardsCountList

func (r *Repository) RewardsCountList(accountID string, limit uint) (rewards []models.AccountRewardsCount, err error)

func (*Repository) RewardsList

func (r *Repository) RewardsList(accountID string, limit uint, offset uint) (count int64, rewards []models.AccountReward, err error)

func (*Repository) RichAccounts

func (r *Repository) RichAccounts(limit uint) (accounts []models.Account, err error)

func (*Repository) TotalBalance

func (r *Repository) TotalBalance() (b int64, err error)

TotalBalance gets the total available balance of all accounts.