Versions in this module Expand all Collapse all v0 v0.2.2 May 2, 2020 v0.2.1 Nov 19, 2019 Changes in this version + const TxConfirmMsg + const TxMsg + func WriteMsg(fd net.Conn, msg *Msg) error + type Msg struct + Code uint64 + Payload io.Reader + Size uint64 + func ReadMsg(fd net.Conn) (msg Msg, err error) + type TxCollector struct + func NewTxCollector(listenAddr string) *TxCollector + func (s *TxCollector) Start(txChan chan types.Transactions) error + func (s *TxCollector) Stop() + type TxSender struct + func NewTxSender(srvAddr string) *TxSender + func (s *TxSender) Connect() error + func (s *TxSender) SendTx(tx *types.Transaction) error