Versions in this module Expand all Collapse all v0 v0.5.3 Jan 9, 2024 v0.5.2 Dec 6, 2023 Changes in this version type BlockInterface + BlockTime string v0.5.1 Oct 8, 2023 Changes in this version + const EthNftTransferSingleTopic type TronReceipt + InternalTransactions []struct{ ... } v0.5.0 Aug 10, 2023 Changes in this version + const EthTopic + const PolygonTopic + const TronTopic + type Block struct + BaseFee string + BlockHash string + BlockNumber string + BlockReward string + BlockSize string + BlockStatus string + BlockTime string + Coinbase string + ExtraData string + FeeRecipient string + GasLimit string + GasUsed string + Id int64 + Nonce string + ParentHash string + ReceiptRoot string + Root string + TotalDifficulty string + Transactions []string + TxRoot string + type BlockChainInterface interface + CheckAddress func(tx []byte, addrList map[string]int64) bool + GetBlockByHash func(blockHash string, log *logrus.Entry, flag bool) (*BlockInterface, []*TxInterface) + GetBlockByNumber func(blockNumber string, log *logrus.Entry, flag bool) (*BlockInterface, []*TxInterface) + GetMultiBlockByNumber func(blockNumber string, log *logrus.Entry, flag bool) ([]*BlockInterface, []*TxInterface) + GetReceipt func(txHash string, log *logrus.Entry) (*ReceiptInterface, error) + GetReceiptByBlock func(blockHash, number string, log *logrus.Entry) ([]*ReceiptInterface, error) + GetTx func(txHash string, log *logrus.Entry) *TxInterface + Monitor func() + type BlockInterface struct + Block interface{} + BlockHash string + BlockNumber string + type Common interface + Start func() + Stop func() + type Logs struct + Address string + BlockHash string + BlockNumber string + Data string + LogIndex string + Removed bool + Topics []string + TransactionHash string + TransactionIndex string + type NodeTask struct + BlockChain int + BlockHash string + BlockNumber string + CreateTime time.Time + Id int64 + LogTime time.Time + NodeId string + TaskStatus int + TaskType int + TxHash string + type Receipt struct + BlockHash string + BlockNumber string + ContractAddress string + CreateTime string + CumulativeGasUsed string + EffectiveGasPrice string + From string + GasUsed string + Id int64 + Logs []*Logs + LogsBloom string + Status string + To string + TransactionHash string + TransactionIndex string + Type string + type ReceiptInterface struct + BlockNumber int64 + BlockTimeStamp int64 + Receipt interface{} + TransactionHash string + type StoreTaskInterface interface + DelErrTxNodeTask func(blockchain int64, key string) (string, error) + DelNodeTask func(blockchain int64, key string) (int64, *NodeTask, error) + GetAllKeyForContract func(blockchain int64) ([]string, error) + GetAllKeyForErrTx func(blockchain int64) ([]string, error) + GetAllKeyForNodeTask func(blockchain int64) ([]string, error) + GetAllNodeId func(blockchain int64) ([]string, error) + GetClusterNode func(blockChain int64, prefix string) (map[string]int64, error) + GetContract func(blockchain int64, contract string) (string, error) + GetErrTxNodeTask func(blockchain int64, key string) (int64, string, error) + GetMonitorAddress func(blockChain int64) ([]string, error) + GetNodeTask func(blockchain int64, key string) (int64, *NodeTask, error) + ResetNodeTask func(blockchain int64, oldKey, key string) error + SendNodeTask func(list []*NodeTask, partitions []int64) []*kafka.Message + StoreClusterHealthStatus func(blockChain int64, data map[string]int64) error + StoreClusterNode func(blockChain int64, prefix string, data any) error + StoreContract func(blockchain int64, contract string, data string) error + StoreErrTxNodeTask func(blockchain int64, key string, data any) error + StoreLatestBlock func(blockchain int64, key string, data any, number string) error + StoreNodeId func(blockchain int64, key string, data any) error + StoreNodeTask func(key string, task *NodeTask) + UpdateNodeTaskStatus func(key string, status int) error + UpdateNodeTaskStatusWithBatch func(keys []string, status int) error + type TronReceipt struct + BlockNumber int64 + BlockTimeStamp int64 + ContractAddress string + ContractResult []string + Fee int64 + From string + Id string + Log []*Logs + Receipt struct{ ... } + To string + type Tx struct + BaseFee string + BlockHash string + BlockNumber string + Fee string + FromAddr string + GasLimit string + GasPrice string + GasUsed string + Id int64 + InputData string + MaxPrice string + PriorityFee string + Receipt string + ToAddr string + TransactionIndex string + TxHash string + TxStatus string + TxTime string + Type string + Value string + type TxInterface struct + Tx interface{} + TxHash string