sender

Documentation

Index

• func DirectSend(msg *msg1.ChainMessage) (*msg1.ChainMessage, error)
• func RelaySend(chainMessage *msg1.ChainMessage) (*msg1.ChainMessage, error)
• func Send(msg *msg1.ChainMessage) (*msg1.ChainMessage, error)
• func SendCM(msg *msg1.ChainMessage) (*msg1.ChainMessage, error)

Functions

func DirectSend

func DirectSend(msg *msg1.ChainMessage) (*msg1.ChainMessage, error)

* 定位器之间直接发送方法

func RelaySend

func RelaySend(chainMessage *msg1.ChainMessage) (*msg1.ChainMessage, error)

* 无错无返回表示不需要转发

func Send

func Send(msg *msg1.ChainMessage) (*msg1.ChainMessage, error)

* 发送ChainMessage消息的唯一方法 1.找出发送的目标地址和方式 2.根据情况处理校验，加密，压缩等 3.建立合适的通道并发送，比如libp2p的Pipe并Write消息流 4.等待即时的返回，校验，解密，解压缩等

func SendCM

func SendCM(msg *msg1.ChainMessage) (*msg1.ChainMessage, error)

* 直接发送到下一个节点，报文不做处理，有3种发送目标： 1.如果主题不为空，发送到主题 2.发送到peerClient：这时候TargetPeerId和TargetConnectSessionId不为空、TargetConnectPeerId可以为空或者就是自己（connectPeerId可以为空或者就是TargetPeerId） 3.不满足上面的条件，发送到peerEndpoint，这时候connectPeerId不为空并且不是自己