chawago

Documentation

Index

• func GetPendingTransactions(qPendingTx chan *types.Transaction, qTxsWithLogs chan TxWithLogs, ...)
• func GetTransactionsForLogs(qRawLogs chan types.Log, qTxsWithLogs chan TxWithLogs, ...)
• type Topic
• type TxWithLogs
  • func (t *TxWithLogs) Sender() *common.Address

Functions

func GetPendingTransactions

func GetPendingTransactions(qPendingTx chan *types.Transaction, qTxsWithLogs chan 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(qRawLogs chan types.Log, qTxsWithLogs chan TxWithLogs, providerPool *provider.Pool)

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

Types

type Topic

type Topic int64

const (
	Topic0 Topic = iota
	Topic1
	Topic2
	Topic3
)

type TxWithLogs

type TxWithLogs struct {
	*types.Transaction
	*types.Receipt
	Pending bool
}

func (*TxWithLogs) Sender

func (t *TxWithLogs) Sender() *common.Address

getTxMessage is used to get the From field of a transaction.