tokenindexer

Documentation

Index

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

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.Txs) []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 ConsumerIndexer

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

func (ConsumerIndexer) Callback

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

type GetTokensAsset

type GetTokensAsset struct {
	AssetId   string `json:"asset_id"`
	CreatedAt int64  `json:"created_at"`
	UpdatedAt int64  `json:"updated_at"`
}

type GetTokensByAddressRequest

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

type GetTokensByAddressResponse

type GetTokensByAddressResponse []GetTokensAsset

type Instance

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

func Init

func Init(database *db.Instance) Instance

func (Instance) GetNewTokensRequest

func (i Instance) GetNewTokensRequest(r Request) (blockatlas.ResultsResponse, error)

func (Instance) GetTokensByAddress

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

type Request

type Request struct {
	From int64
}