tokenindexer

Documentation

Index

• Constants
• func CreateAssociations(database *db.Instance, addressAssetsMap map[string][]string) error
• func GetAssetsFromTransactions(txs []types.Tx) []models.Asset
• func RunTokenIndexer(database *db.Instance, delivery amqp.Delivery) error
• func RunTokenIndexerSubscribe(database *db.Instance, apis map[uint]blockatlas.TokensAPI, ...) error
• type Asset
• type ConsumerIndexer
  • func (c ConsumerIndexer) Callback(msg amqp.Delivery) error
• type GetTokensByAddressRequest
• type GetTokensByAddressResponse
• type Instance
  • func Init(database *db.Instance) Instance
  • func (i Instance) GetTokensByAddress(r GetTokensByAddressRequest) (GetTokensByAddressResponse, error)
  • func (i Instance) HandleNewTokensRequest(r Request) (Response, error)
• type Request
• type Response

Constants

const (
	TokenIndexer              = "TokenIndexer"
	SubscriptionsTokenIndexer = "SubscriptionsTokenIndexer"
)

Functions

func CreateAssociations

func CreateAssociations(database *db.Instance, addressAssetsMap map[string][]string) error

func GetAssetsFromTransactions

func GetAssetsFromTransactions(txs []types.Tx) []models.Asset

func RunTokenIndexer

func RunTokenIndexer(database *db.Instance, delivery amqp.Delivery) error

func RunTokenIndexerSubscribe

func RunTokenIndexerSubscribe(database *db.Instance, apis map[uint]blockatlas.TokensAPI, delivery amqp.Delivery) error

Types

type Asset

type Asset struct {
	Asset  string `json:"asset"`
	Name   string `json:"name"`
	Symbol string `json:"symbol"`
	Type   string `json:"type"`

	Decimals uint `json:"decimals"`
}

type ConsumerIndexer

type ConsumerIndexer struct {
	Database   *db.Instance
	TokensAPIs map[uint]blockatlas.TokensAPI
	Delivery   func(*db.Instance, map[uint]blockatlas.TokensAPI, amqp.Delivery) error
}

func (ConsumerIndexer) Callback

func (c ConsumerIndexer) Callback(msg amqp.Delivery) error

type GetTokensByAddressRequest

type GetTokensByAddressRequest struct {
	AddressesByCoin map[string][]string `json:"addresses"`
	From            uint                `json:"from"`
}

type GetTokensByAddressResponse

type GetTokensByAddressResponse []string

type Instance

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

func Init

func Init(database *db.Instance) Instance

func (Instance) GetTokensByAddress

func (i Instance) GetTokensByAddress(r GetTokensByAddressRequest) (GetTokensByAddressResponse, error)

func (Instance) HandleNewTokensRequest

func (i Instance) HandleNewTokensRequest(r Request) (Response, error)

type Request

type Request struct {
	From int64
}

type Response

type Response struct {
	Assets []Asset `json:"assets"`
}