chawago

Documentation

Index

• Constants
• func GetPendingTransactions(qPendingTx chan *types.Transaction, qTxsWithLogs chan *models.TxWithLogs, ...)
• func GetTransactionsForLogs(gb *gloomberg.Gloomberg, qRawLogs chan types.Log) chan *models.TxWithLogs
• func GetTransactionsForLogsWithChannel(gb *gloomberg.Gloomberg, qRawLogs chan types.Log, ...) chan *models.TxWithLogs

Constants

const (
	Topic0 models.Topic = iota
	Topic1
	Topic2
	Topic3
)

Functions

func GetPendingTransactions

func GetPendingTransactions(qPendingTx chan *types.Transaction, qTxsWithLogs chan *models.TxWithLogs, providerPool *provider.Pool)

GetPendingTransactions utilizes the providerPool to fetch the transaction & receipt for logs from qRawLogs. The transaction with the receipt is then sent to qTxsWithLogs.

func GetTransactionsForLogs

func GetTransactionsForLogs(gb *gloomberg.Gloomberg, qRawLogs chan types.Log) chan *models.TxWithLogs

GetTransactionsForLogs utilizes the providerPool to fetch the transaction & receipt for logs from qRawLogs. The transaction with the receipt is then sent to qTxsWithLogs.

func GetTransactionsForLogsWithChannel

func GetTransactionsForLogsWithChannel(gb *gloomberg.Gloomberg, qRawLogs chan types.Log, qTxsWithLogs chan *models.TxWithLogs) chan *models.TxWithLogs