msgnet

package

v0.8.8 Latest Latest Go to latest Published: Aug 8, 2017 License: GPL-3.0 Imports: 3 Imported by: 0

Details

View Source

const (
	ChainTxMsg = iota + 100
	ChainConsensusMsg
	ChainMergeTxsMsg
	ChainAckMergeTxsMsg
	ChainAckedMergeTxsMsg
)

This section is empty.

func NewMsgnet(id string, routeAddress []string, fn MsgHandler, logOutPath string) *msgnet.Peer

NewMsgnet start client msg-net service and returns a msg-net peer

type Message struct {
	Cmd     uint8
	Payload []byte
}

Message represents the message transfer in msg-net

func (m *Message) Deserialize(data []byte)

Deserialize bytes to message

func (m *Message) Serialize() []byte

Serialize message to bytes

type MsgHandler func(src string, dst string, payload, sig []byte) error

MsgHandler handles the message of the msg-net

type Stack interface {
	Send(dst string, payload, signature []byte) bool
}

Stack defines send interface