subscriptions

package
v0.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 23, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL