filecoin

Documentation

Index

• func CheckAddress(txValue []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(value []byte, transferTopic string, blockchain int64) (*store.SubTx, error)

Functions

func CheckAddress

func CheckAddress(txValue []byte, addrList map[string]*store.MonitorAddress, transferTopic string) bool

func GetBlockFromKafka

func GetBlockFromKafka(value []byte) (*store.Block, error)

func GetCoreAddr

func GetCoreAddr(addr string) string

func GetReceiptFromKafka

func GetReceiptFromKafka(value []byte) (*store.Receipt, error)

func GetTxFromKafka

func GetTxFromKafka(value []byte) (*store.Tx, error)

func GetTxType

func GetTxType(body []byte) (uint64, error)

func ParseTx

func ParseTx(value []byte, transferTopic string, blockchain int64) (*store.SubTx, error)