tx_collector

Documentation

Overview

Package tx_collector contains the implementation of tx collector for packer.

Package tx_collector contains the implementation of tx collector for packer.

Package tx_collector contains the implementation of tx collector for packer.

Index

• Constants
• func WriteMsg(fd net.Conn, msg *Msg) error
• type Msg
  • func ReadMsg(fd net.Conn) (msg Msg, err error)
• type TxCollector
  • func NewTxCollector(listenAddr string) *TxCollector
  • func (s *TxCollector) Start(txChan chan types.Transactions) error
  • func (s *TxCollector) Stop()
• type TxSender
  • func NewTxSender(srvAddr string) *TxSender
  • func (s *TxSender) Connect() error
  • func (s *TxSender) SendTx(tx *types.Transaction) error

Constants

const (
	TxMsg        = 0x00
	TxConfirmMsg = 0x01
)

tx collect message codes

Functions

func WriteMsg

func WriteMsg(fd net.Conn, msg *Msg) error

Types

type Msg

type Msg struct {
	Code    uint64
	Size    uint64
	Payload io.Reader
}

func ReadMsg

func ReadMsg(fd net.Conn) (msg Msg, err error)

type TxCollector

type TxCollector struct {
	// contains filtered or unexported fields
}

func NewTxCollector

func NewTxCollector(listenAddr string) *TxCollector

func (*TxCollector) Start

func (s *TxCollector) Start(txChan chan types.Transactions) error

func (*TxCollector) Stop

func (s *TxCollector) Stop()

type TxSender

type TxSender struct {
	// contains filtered or unexported fields
}

func NewTxSender

func NewTxSender(srvAddr string) *TxSender

func (*TxSender) Connect

func (s *TxSender) Connect() error

func (*TxSender) SendTx

func (s *TxSender) SendTx(tx *types.Transaction) error