msgpack

func NewAddrReq ¶

func NewAddrReq() mt.Message

Peer address request package

func NewAddrs ¶

func NewAddrs(nodeAddrs []*mt.PeerAddr) mt.Message

Peer address package

func NewCheckpointBatchMsg ¶ added in v1.0.2

func NewCheckpointBatchMsg(startNum, endNum uint64) mt.Message

checkpoint package

func NewClearOutOfRangeState ¶ added in v1.0.2

func NewClearOutOfRangeState() mt.Message

func NewConsMsg ¶ added in v1.0.2

func NewConsMsg(msg message.ConsensusMessage, needForwardBroadcast bool) mt.Message

consensus package

func NewDetectFormerIds ¶ added in v1.0.2

func NewDetectFormerIds(endID []byte) mt.Message

func NewPingMsg ¶

func NewPingMsg(height uint64) mt.Message

ping msg package

func NewPongMsg ¶

func NewPongMsg(height uint64) mt.Message

pong msg package

func NewRequestBlockBatch ¶ added in v1.0.2

func NewRequestBlockBatch(startID, endID []byte) mt.Message

func NewRequestOutOfRangeIds ¶ added in v1.0.2

func NewRequestOutOfRangeIds(startID, targetID []byte) mt.Message

func NewSigBlk ¶

func NewSigBlk(bk *prototype.SignedBlock, needTriggerFetch bool) mt.Message

func NewSigBlkIdMsg ¶

func NewSigBlkIdMsg(bk *prototype.SignedBlock) mt.Message

block package

func NewTxn ¶

func NewTxn(txn *prototype.SignedTransaction) mt.Message

Transaction package

func NewVerAck ¶

func NewVerAck(isConsensus bool) mt.Message

version ack package

func NewVersion ¶

func NewVersion(n p2p.P2P, isCons bool, height uint64, runningVersion string) mt.Message

Version package