Documentation
¶
Index ¶
- type VnodeCenter
- func (this *VnodeCenter) BroadcastCloseVnode(vnode *virtual_node.Vnodeinfo)
- func (vc *VnodeCenter) BroadcastSelfVnodeInfo()
- func (this *VnodeCenter) CheckVnodeIsOnline(vnodeInfo *virtual_node.Vnodeinfo) bool
- func (this *VnodeCenter) Close()
- func (this *VnodeCenter) CloseVnodeDeal()
- func (this *VnodeCenter) FindNearVnode()
- func (this *VnodeCenter) GetNearSuperAddr(c engine.Controller, msg engine.Packet, message *message_center.Message)
- func (this *VnodeCenter) GetNearSuperAddr_recv(c engine.Controller, msg engine.Packet, message *message_center.Message)
- func (this *VnodeCenter) GetRemoteVnodeinfo(vnodes *[]*virtual_node.FindVnodeVO)
- func (this *VnodeCenter) GetVnodeOpenState(c engine.Controller, msg engine.Packet, message *message_center.Message)
- func (this *VnodeCenter) GetVnodeOpenState_recv(c engine.Controller, msg engine.Packet, message *message_center.Message)
- func (this *VnodeCenter) LoopGetVnodeinfo()
- func (this *VnodeCenter) LoopSendVnodeInfo()
- func (this *VnodeCenter) NoticeAddNode(addr nodeStore.AddressNet)
- func (this *VnodeCenter) NoticeRemoveNode(addr nodeStore.AddressNet)
- func (this *VnodeCenter) Open()
- func (this *VnodeCenter) SearchVnodeId(nodeId *virtual_node.AddressNetExtend, ...) (*[]byte, error)
- func (this *VnodeCenter) TriggerLoopGetVnodeinfo()
- func (this *VnodeCenter) TriggerLoopSendVnodeinfo()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VnodeCenter ¶
type VnodeCenter struct {
// contains filtered or unexported fields
}
func NewVnodeCenter ¶
func NewVnodeCenter(messageCenterParam *message_center.MessageCenter, nodeManagerParam *nodeStore.NodeManager, sessionEngineParam *engine.Engine, vm *virtual_node.VnodeManager, c context.Context) *VnodeCenter
func (*VnodeCenter) BroadcastCloseVnode ¶
func (this *VnodeCenter) BroadcastCloseVnode(vnode *virtual_node.Vnodeinfo)
* 广播通知虚拟节点关闭信息
func (*VnodeCenter) BroadcastSelfVnodeInfo ¶
func (vc *VnodeCenter) BroadcastSelfVnodeInfo()
* @author qlw * 广播通知本节点的所有虚拟节点信息
func (*VnodeCenter) CheckVnodeIsOnline ¶
func (this *VnodeCenter) CheckVnodeIsOnline(vnodeInfo *virtual_node.Vnodeinfo) bool
* 检查虚拟节点是否在线 * @param vnodeInfo 需要检查的虚拟节点信息 * @return bool 是否在线
func (*VnodeCenter) GetNearSuperAddr ¶
func (this *VnodeCenter) GetNearSuperAddr(c engine.Controller, msg engine.Packet, message *message_center.Message)
获取相邻节点的Vnode地址
func (*VnodeCenter) GetNearSuperAddr_recv ¶
func (this *VnodeCenter) GetNearSuperAddr_recv(c engine.Controller, msg engine.Packet, message *message_center.Message)
获取相邻节点的Vnode地址 返回
func (*VnodeCenter) GetRemoteVnodeinfo ¶
func (this *VnodeCenter) GetRemoteVnodeinfo(vnodes *[]*virtual_node.FindVnodeVO)
向逻辑节点发送消息，获取自己的逻辑节点
func (*VnodeCenter) GetVnodeOpenState ¶
func (this *VnodeCenter) GetVnodeOpenState(c engine.Controller, msg engine.Packet, message *message_center.Message)
获取节点的虚拟节点开通状态
func (*VnodeCenter) GetVnodeOpenState_recv ¶
func (this *VnodeCenter) GetVnodeOpenState_recv(c engine.Controller, msg engine.Packet, message *message_center.Message)
获取节点的虚拟节点开通状态 返回
func (*VnodeCenter) LoopSendVnodeInfo ¶
func (this *VnodeCenter) LoopSendVnodeInfo()
* 广播本节点的所有虚拟节点信息消息
func (*VnodeCenter) NoticeAddNode ¶
func (this *VnodeCenter) NoticeAddNode(addr nodeStore.AddressNet)
通知有新节点加入网络
func (*VnodeCenter) NoticeRemoveNode ¶
func (this *VnodeCenter) NoticeRemoveNode(addr nodeStore.AddressNet)
通知有节点离线
func (*VnodeCenter) SearchVnodeId ¶
func (this *VnodeCenter) SearchVnodeId(nodeId *virtual_node.AddressNetExtend, recvProxyId, senderProxyId *nodeStore.AddressNet, onebyone bool, num uint16) (*[]byte, error)
查找虚拟逻辑节点的真实地址 @nodeId *AddressNetExtend 要查找的节点
func (*VnodeCenter) TriggerLoopGetVnodeinfo ¶
func (this *VnodeCenter) TriggerLoopGetVnodeinfo()
触发：定时获取邻居节点的虚拟节点地址
func (*VnodeCenter) TriggerLoopSendVnodeinfo ¶
func (this *VnodeCenter) TriggerLoopSendVnodeinfo()
* 触发：定时发送本节点的所有虚拟节点地址
Source Files
Click to show internal directories.
Click to hide internal directories.