subscriptions

Documentation

Index

• func GetTokenIDFromTopics(topics []common.Hash) uint64
• func StreamListingsHandler(workerID int, gOwnCollections *collections.Collections, ...)
• func SubscriptionLogsHandler(nodes *gbnode.NodeCollection, gOwnCollections *collections.Collections, ...)
• func WeiToEther(wei *big.Int) *big.Float
• type TransactionCollector
  • func NewTransactionCollector(log *types.Log) *TransactionCollector
  • func (transco *TransactionCollector) AddLog(log *types.Log)
  • func (transco *TransactionCollector) UniqueTokenIDs() int

Functions

func GetTokenIDFromTopics

func GetTokenIDFromTopics(topics []common.Hash) uint64

func StreamListingsHandler

func StreamListingsHandler(workerID int, gOwnCollections *collections.Collections, queueListings *chan *models.ItemListedEvent, queueEvents *chan *collections.Event)

func SubscriptionLogsHandler

func SubscriptionLogsHandler(nodes *gbnode.NodeCollection, gOwnCollections *collections.Collections, queueLogs chan types.Log, queueEvents chan *collections.Event)

func WeiToEther

func WeiToEther(wei *big.Int) *big.Float

Types

type TransactionCollector

type TransactionCollector struct {
	TxID       common.Hash
	LogIndices []int
	Logs       map[int]*types.Log
	TokenIDs   []uint64
	RWMu       *sync.RWMutex
	TX         *types.Transaction
}

func NewTransactionCollector

func NewTransactionCollector(log *types.Log) *TransactionCollector

func (*TransactionCollector) AddLog

func (transco *TransactionCollector) AddLog(log *types.Log)

func (*TransactionCollector) UniqueTokenIDs

func (transco *TransactionCollector) UniqueTokenIDs() int