multicast

Documentation

Index

• Constants
• Variables
• type MulticastMsg
  • func NewMulticastMsg(area *libp2parea.Area, country *country.AreaCountry) (gm *MulticastMsg)
  • func (gm *MulticastMsg) SendMulticastMsg(msgId uint64, nodeIds []*NodeMachineInfo, content string, ...) error
• type NodeMachineInfo

Constants

const (
	MSGID_P2P_SEND_MULTICAST_MSG      = 20010 // 发送组播消息
	MSGID_P2P_SEND_MULTICAST_MSG_RECV = 20011 // 发送组播消息的返回
)

消息号

Variables

var (
	Err_MULTICAST_MSG_NOT_INIT       = errors.New("multicast is not init")
	Err_MULTICAST_NODES_EMPTY        = errors.New("nodeIds is empty")
	Err_MULTICAST_MSGID_INVALID      = errors.New("msgid is invalid")
	Err_MULTICAST_COUNTRY_NODE_EMPTY = errors.New("country node is empty")
)

错误信息

Types

type MulticastMsg

type MulticastMsg struct {
	Area    *libp2parea.Area     // 节点信息
	Country *country.AreaCountry // 大区信息
	// contains filtered or unexported fields
}

组播消息

func NewMulticastMsg

func NewMulticastMsg(area *libp2parea.Area, country *country.AreaCountry) (gm *MulticastMsg)

* 创建组播消息 * * @param area *Area 所属区域 * @param country *AreaCountry 大区信息 * @return mm *MulticastMsg 群消息

func (*MulticastMsg) SendMulticastMsg

func (gm *MulticastMsg) SendMulticastMsg(msgId uint64, nodeIds []*NodeMachineInfo, content string, timeout time.Duration) error

* 发送组播消息 * * @param msgId uint64 消息号 * @param nodeIds []*AddressNet 接收端的地址列表 * @param content string 消息内容

type NodeMachineInfo

type NodeMachineInfo struct {
	NodeId    nodeStore.AddressNet // 节点地址
	MachineID string               // 机器id
}

节点机器id结构信息