subscribe

Documentation

Index

• func StreamListingsHandler(workerID int, gOwnCollections *collections.Collections, ...)
• func WorkerLogsQueue(workerID int, cNode *node.Node, rawNodes []*node.Node, ...)
• type TransactionCollector
  • func NewTransactionCollector(log *types.Log) *TransactionCollector
  • func (transco *TransactionCollector) AddLog(log *types.Log)
  • func (transco *TransactionCollector) UniqueTokenIDs() int

Functions

func StreamListingsHandler

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

func WorkerLogsQueue

func WorkerLogsQueue(workerID int, cNode *node.Node, rawNodes []*node.Node, ownCollections *collections.Collections, queueLogs *chan types.Log, queueEvents *chan *collections.Event, queueOutWS *chan *collections.Event)

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