sys_rpc

Documentation

Index

• type ChildRpc
  • func (this *ChildRpc) CheckAlive(request *cluster.RpcRequest) (response map[string]interface{})
  • func (this *ChildRpc) CloseServer(request *cluster.RpcRequest)
  • func (this *ChildRpc) NodeDownNtf(request *cluster.RpcRequest)
  • func (this *ChildRpc) ReloadConfig(request *cluster.RpcRequest)
  • func (this *ChildRpc) RootTakeProxy(request *cluster.RpcRequest)
• type MasterRpc
  • func (this *MasterRpc) ChildOffLine(request *cluster.RpcRequest)
  • func (this *MasterRpc) TakeProxy(request *cluster.RpcRequest) (response map[string]interface{})
• type RootRpc
  • func (this *RootRpc) TakeProxy(request *cluster.RpcRequest)

Types

type ChildRpc

type ChildRpc struct {
}

func (*ChildRpc) CheckAlive

func (this *ChildRpc) CheckAlive(request *cluster.RpcRequest) (response map[string]interface{})

检查节点是否下线

func (*ChildRpc) CloseServer

func (this *ChildRpc) CloseServer(request *cluster.RpcRequest)

关闭节点信号

func (*ChildRpc) NodeDownNtf

func (this *ChildRpc) NodeDownNtf(request *cluster.RpcRequest)

通知节点掉线（父节点或子节点）

func (*ChildRpc) ReloadConfig

func (this *ChildRpc) ReloadConfig(request *cluster.RpcRequest)

重新加载配置文件

func (*ChildRpc) RootTakeProxy

func (this *ChildRpc) RootTakeProxy(request *cluster.RpcRequest)

master 通知父节点上线, 收到通知的子节点需要链接对应父节点

type MasterRpc

type MasterRpc struct {
}

func (*MasterRpc) ChildOffLine

func (this *MasterRpc) ChildOffLine(request *cluster.RpcRequest)

主动通知master 节点掉线

func (*MasterRpc) TakeProxy

func (this *MasterRpc) TakeProxy(request *cluster.RpcRequest) (response map[string]interface{})

type RootRpc

type RootRpc struct {
}

func (*RootRpc) TakeProxy

func (this *RootRpc) TakeProxy(request *cluster.RpcRequest)

子节点连上来的通知