account

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) AddAccountStates(ctx context.Context, tx bun.Tx, accounts []*core.AccountState) error
  • func (r *Repository) AddAddressLabel(ctx context.Context, label *core.AddressLabel) error
  • func (r *Repository) AggregateAccounts(ctx context.Context, req *aggregate.AccountsReq) (*aggregate.AccountsRes, error)
  • func (r *Repository) AggregateAccountsHistory(ctx context.Context, req *history.AccountsReq) (*history.AccountsRes, error)
  • func (r *Repository) FilterAccounts(ctx context.Context, f *filter.AccountsReq) (*filter.AccountsRes, error)
  • func (r *Repository) FilterLabels(ctx context.Context, f *filter.LabelsReq) (*filter.LabelsRes, error)
  • func (r *Repository) GetAddressLabel(ctx context.Context, a addr.Address) (*core.AddressLabel, error)
  • func (r *Repository) GetAllAccountInterfaces(ctx context.Context, a addr.Address) (map[uint64][]abi.ContractName, error)
  • func (r *Repository) GetAllAccountStates(ctx context.Context, a addr.Address, beforeTxLT uint64, limit int) ([]*core.AccountState, error)
  • func (r *Repository) MatchStatesByInterfaceDesc(ctx context.Context, contractName abi.ContractName, addresses []*addr.Address, ...) ([]*core.AccountStateID, error)
  • func (r *Repository) UpdateAccountStates(ctx context.Context, accounts []*core.AccountState) 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) AddAccountStates

func (r *Repository) AddAccountStates(ctx context.Context, tx bun.Tx, accounts []*core.AccountState) error

func (*Repository) AddAddressLabel

func (r *Repository) AddAddressLabel(ctx context.Context, label *core.AddressLabel) error

func (*Repository) AggregateAccounts

func (r *Repository) AggregateAccounts(ctx context.Context, req *aggregate.AccountsReq) (*aggregate.AccountsRes, error)

func (*Repository) AggregateAccountsHistory

func (r *Repository) AggregateAccountsHistory(ctx context.Context, req *history.AccountsReq) (*history.AccountsRes, error)

func (*Repository) FilterAccounts

func (r *Repository) FilterAccounts(ctx context.Context, f *filter.AccountsReq) (*filter.AccountsRes, error)

func (*Repository) FilterLabels

func (r *Repository) FilterLabels(ctx context.Context, f *filter.LabelsReq) (*filter.LabelsRes, error)

func (*Repository) GetAddressLabel

func (r *Repository) GetAddressLabel(ctx context.Context, a addr.Address) (*core.AddressLabel, error)

func (*Repository) GetAllAccountInterfaces

func (r *Repository) GetAllAccountInterfaces(ctx context.Context, a addr.Address) (map[uint64][]abi.ContractName, error)

func (*Repository) GetAllAccountStates

func (r *Repository) GetAllAccountStates(ctx context.Context, a addr.Address, beforeTxLT uint64, limit int) ([]*core.AccountState, error)

func (*Repository) MatchStatesByInterfaceDesc

func (r *Repository) MatchStatesByInterfaceDesc(ctx context.Context,
	contractName abi.ContractName,
	addresses []*addr.Address,
	codeHash []byte,
	getMethodHashes []int32,
	afterAddress *addr.Address,
	afterTxLt uint64,
	limit int,
) ([]*core.AccountStateID, error)

func (*Repository) UpdateAccountStates

func (r *Repository) UpdateAccountStates(ctx context.Context, accounts []*core.AccountState) error