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 + func CheckAddress(tx []byte, addrList map[string]*store.MonitorAddress, ...) bool + func GetBlockFromKafka(value []byte) (*store.Block, error) + func GetCoreAddr(addr string) string + func GetReceiptFromKafka(value []byte) (*store.Receipt, error) + func GetTxFromKafka(value []byte) (*store.Tx, error) + func GetTxType(body []byte) (uint64, error) + func ParseTx(body []byte, transferTopic, nftTransferSingleTopic string, blockchain int64) (*store.SubTx, error)