queryService

Documentation

Index

• Constants
• Variables
• func QueryWalletNft(cursor, gameNftAddress, walletAddr, network string, res []response.NftResult) ([]response.NftResult, error)
• type BalanceService
  • func (service *BalanceService) QueryWalletService(address string) ([]response.BalanceShow, error)
• type QueryManager
  • func NewQueryManager() *QueryManager
  • func (qm *QueryManager) QueryERC20TxRecord(ctx context.Context, walletAddr string, contractAddr string) (response.BscResult, error)
  • func (qm *QueryManager) QueryNativeRecord(ctx context.Context, walletAddr string) (response.BscResult, error)
  • func (qm *QueryManager) QueryNftList(ctx context.Context, gameContractAddr, walletAddr, assetType string) ([]model.CacheData, error)
  • func (qm *QueryManager) QueryNftType(ctx context.Context, gameContractAddr, walletAddr string) ([]response.NftType, error)
• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) Schedule(ctx context.Context, tp model.TaskType, action model.QueryAction) error

Constants

const BscScanRateLimit = "\"Max rate limit reached\""

Variables

var BalanceSrv = new(BalanceService)

var MoralisRateLimit = "{\"message\":\"Rate limit exceeded.\"}"

var ResourceTable = map[model.TaskType]int{
	model.NftQuery:            1,
	model.Erc20TxRecordQuery:  1,
	model.NativeTxRecordQuery: 2,
}

Functions

func QueryWalletNft

func QueryWalletNft(cursor, gameNftAddress, walletAddr, network string, res []response.NftResult) ([]response.NftResult, error)

Types

type BalanceService

type BalanceService struct {
}

func (*BalanceService) QueryWalletService

func (service *BalanceService) QueryWalletService(address string) ([]response.BalanceShow, error)

type QueryManager

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

func NewQueryManager

func NewQueryManager() *QueryManager

func (*QueryManager) QueryERC20TxRecord

func (qm *QueryManager) QueryERC20TxRecord(ctx context.Context, walletAddr string, contractAddr string) (response.BscResult, error)

func (*QueryManager) QueryNativeRecord

func (qm *QueryManager) QueryNativeRecord(ctx context.Context, walletAddr string) (response.BscResult, error)

func (*QueryManager) QueryNftList

func (qm *QueryManager) QueryNftList(ctx context.Context, gameContractAddr, walletAddr, assetType string) ([]model.CacheData, error)

func (*QueryManager) QueryNftType

func (qm *QueryManager) QueryNftType(ctx context.Context, gameContractAddr, walletAddr string) ([]response.NftType, error)

type Scheduler

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

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(ctx context.Context, tp model.TaskType, action model.QueryAction) error