superinfo

Documentation

Index

• Constants
• type SuperInfo
  • func NewSuperInfo(area *libp2parea.Area, ...) (si *SuperInfo)
  • func (si *SuperInfo) Register_superNodeOfflineCallback(handler libp2parea.NodeEventCallbackHandler)
  • func (si *SuperInfo) Register_superNodeOnlineCallback(handler libp2parea.NodeEventCallbackHandler)

Constants

const (
	TIME_LOOP_SEND_ONLINE_INFO = time.Second * 3 // 循环发送节点在线消息间隔时间, 单位秒
	TIME_LOOP_CHECK_CACHE      = time.Second * 5 // 循环检查节点在线消息间隔时间, 单位秒
	TIME_CACHE_INVALID         = 10              // 缓存失效时间, 单位秒
)

常量定义

const (
	MSGID_SUPER_INFO_MULTICAST_MSG = 20020 // 发送节点在线广播消息
)

消息号

Types

type SuperInfo

type SuperInfo struct {
	Area       *libp2parea.Area // 节点信息
	SuperNodes *sync.Map        // 存放超级节点信息
	// contains filtered or unexported fields
}

超级节点信息

func NewSuperInfo

func NewSuperInfo(area *libp2parea.Area, superOnlineCallback, superOfflineCallback libp2parea.NodeEventCallbackHandler) (si *SuperInfo)

* 创建超级节点信息 * * @param area *Area 所属区域 * @param superOnlineCallback NodeEventCallbackHandler 大区信息 * @param superOfflineCallback NodeEventCallbackHandler 大区信息 * @return si *SuperInfo 超级节点信息

func (*SuperInfo) Register_superNodeOfflineCallback

func (si *SuperInfo) Register_superNodeOfflineCallback(handler libp2parea.NodeEventCallbackHandler)

* 注册超级节点下线回调函数

func (*SuperInfo) Register_superNodeOnlineCallback

func (si *SuperInfo) Register_superNodeOnlineCallback(handler libp2parea.NodeEventCallbackHandler)

* 注册超级节点下线回调函数