Documentation
¶
Index ¶
- func CheckAddress(blockChain int64, msg *kafka.Message, list map[string]*store.MonitorAddress) bool
- func GetBlockFromKafka(value []byte, blockChain int64) (*store.Block, error)
- func GetCoreAddress(blockChain int64, address string) string
- func GetReceiptFromKafka(value []byte, blockChain int64) (*store.Receipt, error)
- func GetTxFromKafka(value []byte, blockChain int64) (*store.Tx, error)
- func GetTxType(blockchain int64, msg *kafka.Message) (uint64, error)
- func ParseTx(blockchain int64, msg *kafka.Message) (*store.SubTx, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckAddress ¶
func CheckAddress(blockChain int64, msg *kafka.Message, list map[string]*store.MonitorAddress) bool
func GetBlockFromKafka ¶
func GetCoreAddress ¶
func GetReceiptFromKafka ¶
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.