rpc

type Cluster struct {
	actor.Actor
	// contains filtered or unexported fields
}

type ClusterNode struct {
	*network.ClientSocket
	*rpc.ClusterInfo
}

type ClusterServer struct {
	actor.Actor
	*Service //集群注册
	// contains filtered or unexported fields
}

type HashClusterMap map[uint32]*rpc.ClusterInfo

type HashClusterSocketMap map[uint32]*rpc.ClusterInfo

type ICluster interface {
	actor.IActor
	InitCluster(info *rpc.ClusterInfo, Endpoints []string)
	AddCluster(info *rpc.ClusterInfo)
	DelCluster(info *rpc.ClusterInfo)
	GetCluster(rpc.RpcHead) *ClusterNode

	BindPacket(IClusterPacket)
	BindPacketFunc(network.PacketFunc)

	RandomCluster(head rpc.RpcHead) rpc.RpcHead ///随机分配
	// contains filtered or unexported methods
}

type IClusterPacket interface {
	actor.IActor
	SetClusterId(uint32)
}

type IClusterServer interface {
	InitService(info *rpc.ClusterInfo, Endpoints []string)
	RegisterClusterCall() //注册集群通用回调
	AddCluster(info *rpc.ClusterInfo)
	DelCluster(info *rpc.ClusterInfo)
	GetCluster(rpc.RpcHead) *rpc.ClusterInfo
	GetClusterBySocket(uint32) *rpc.ClusterInfo

	BindServer(*network.ServerSocket)
	SendMsg(rpc.RpcHead, string, ...interface{}) //发送给集群特定服务器
	Send(rpc.RpcHead, []byte)                    //发送给集群特定服务器

	RandomCluster(head rpc.RpcHead) rpc.RpcHead //随机分配
	// contains filtered or unexported methods
}

type MailBox etv3.MailBox

type Master etv3.Master

type Service etv3.Service

type Snowflake etv3.Snowflake