assets

Documentation

Index

• type Repo
• type Repository
  • func New(db *gorm.DB) *Repository
  • func (r *Repository) CreateAssetOperations(operation models.AssetOperation) error
  • func (r *Repository) FindOperations(operationIDs []int64, limit uint64) (operations []models.AssetOperation, err error)
  • func (r *Repository) GetAccountAssetsBalances(hexAddress string) (holders []models.AccountAssetBalance, err error)
  • func (r *Repository) GetAssetOperations(tokenIDs, operationTypes, accountIDs []string, blockLevels []int64, ...) (count int64, info []models.AssetOperationReport, err error)
  • func (r *Repository) GetAssetReport(tokenID uint64, params models.ReportFilter) (report []models.AssetReport, err error)
  • func (r *Repository) GetRegisteredToken(tokenID uint64) (token models.RegisteredToken, err error)
  • func (r *Repository) GetTokenHolders(tokenID string) (holders []models.AssetHolder, err error)
  • func (r *Repository) GetTokenInfo(tokenID string) (info models.AssetInfo, err error)
  • func (r *Repository) GetTokensList() (count int64, tokens []models.AssetInfo, err error)
  • func (r *Repository) GetUnprocessedAssetTxs(tokenID string) (ops []models.Operation, err error)

Types

type Repo

type Repo interface {
	GetTokensList() (int64, []models.AssetInfo, error)
	GetTokenInfo(tokenID string) (models.AssetInfo, error)
	GetTokenHolders(tokenID string) ([]models.AssetHolder, error)
	GetAssetOperations(tokenIDs, operationTypes, accountIDs []string, blockLevels []int64, limit, offset uint) (count int64, info []models.AssetOperationReport, err error)
	GetAssetReport(tokenID uint64, params models.ReportFilter) ([]models.AssetReport, error)
	GetAccountAssetsBalances(hexAddress string) (holders []models.AccountAssetBalance, err error)
	GetUnprocessedAssetTxs(tokenID string) ([]models.Operation, error)
	CreateAssetOperations(models.AssetOperation) error
	FindOperations(operationIDs []int64, limit uint64) (operations []models.AssetOperation, err error)
	GetRegisteredToken(tokenID uint64) (token models.RegisteredToken, 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) CreateAssetOperations

func (r *Repository) CreateAssetOperations(operation models.AssetOperation) error

func (*Repository) FindOperations

func (r *Repository) FindOperations(operationIDs []int64, limit uint64) (operations []models.AssetOperation, err error)

func (*Repository) GetAccountAssetsBalances

func (r *Repository) GetAccountAssetsBalances(hexAddress string) (holders []models.AccountAssetBalance, err error)

func (*Repository) GetAssetOperations

func (r *Repository) GetAssetOperations(tokenIDs, operationTypes, accountIDs []string, blockLevels []int64, limit, offset uint) (count int64, info []models.AssetOperationReport, err error)

func (*Repository) GetAssetReport

func (r *Repository) GetAssetReport(tokenID uint64, params models.ReportFilter) (report []models.AssetReport, err error)

func (*Repository) GetRegisteredToken

func (r *Repository) GetRegisteredToken(tokenID uint64) (token models.RegisteredToken, err error)

func (*Repository) GetTokenHolders

func (r *Repository) GetTokenHolders(tokenID string) (holders []models.AssetHolder, err error)

func (*Repository) GetTokenInfo

func (r *Repository) GetTokenInfo(tokenID string) (info models.AssetInfo, err error)

func (*Repository) GetTokensList

func (r *Repository) GetTokensList() (count int64, tokens []models.AssetInfo, err error)

func (*Repository) GetUnprocessedAssetTxs

func (r *Repository) GetUnprocessedAssetTxs(tokenID string) (ops []models.Operation, err error)