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
• type WalletWatcher
  • func NewWalletWatcher(gb *gloomberg.Gloomberg) *WalletWatcher
  • func (ww *WalletWatcher) FormattedWallets() []string
  • func (ww *WalletWatcher) Pr(message string)
  • func (ww *WalletWatcher) PrDf(format string, a ...interface{})
  • func (ww *WalletWatcher) Prf(format string, a ...interface{})
  • func (ww *WalletWatcher) Watch()

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

Types

type WalletWatcher

type WalletWatcher struct {
	Wallets map[common.Address]*wallet.Wallet
	// contains filtered or unexported fields
}

func NewWalletWatcher

func NewWalletWatcher(gb *gloomberg.Gloomberg) *WalletWatcher

NewWalletWatcher returns a new walletWatcher.

func (*WalletWatcher) FormattedWallets

func (ww *WalletWatcher) FormattedWallets() []string

func (*WalletWatcher) Pr

func (ww *WalletWatcher) Pr(message string)

Pr prints messages from seawatcher to the terminal.

func (*WalletWatcher) PrDf

func (ww *WalletWatcher) PrDf(format string, a ...interface{})

func (*WalletWatcher) Prf

func (ww *WalletWatcher) Prf(format string, a ...interface{})

Prf formats and prints messages from seawatcher to the terminal.

func (*WalletWatcher) Watch

func (ww *WalletWatcher) Watch()