cherryProto

type ClusterServiceClient interface {
	// 推送消息到用户客户端
	// 适用于内部节点调用，网关节点接收消息后，找到对应的session进行push操作
	PushToUser(ctx context.Context, in *PushMessage, opts ...grpc.CallOption) (*Response, error)
	// 踢用户下线
	// 适用于内部节点调用，网关节点接收消息后，找到对应的session进行kick操作
	KickUser(ctx context.Context, in *KickMessage, opts ...grpc.CallOption) (*Response, error)
	// 本地消息转发
	// 适用于网关节点，接收用户的消息转发给内部节点
	LocalHandle(ctx context.Context, in *LocalMessage, opts ...grpc.CallOption) (*Response, error)
	// 远程消息转发
	// 适用于集群后的所有节点，手工调用进行消息通信
	RemoteHandle(ctx context.Context, in *RemoteMessage, opts ...grpc.CallOption) (*Response, error)
	// 关闭session通知
	// 接收session关闭的动作，对当前节点进行相关的逻辑处理
	CloseSession(ctx context.Context, in *Session, opts ...grpc.CallOption) (*Response, error)
}

type ClusterServiceServer interface {
	// 推送消息到用户客户端
	// 适用于内部节点调用，网关节点接收消息后，找到对应的session进行push操作
	PushToUser(context.Context, *PushMessage) (*Response, error)
	// 踢用户下线
	// 适用于内部节点调用，网关节点接收消息后，找到对应的session进行kick操作
	KickUser(context.Context, *KickMessage) (*Response, error)
	// 本地消息转发
	// 适用于网关节点，接收用户的消息转发给内部节点
	LocalHandle(context.Context, *LocalMessage) (*Response, error)
	// 远程消息转发
	// 适用于集群后的所有节点，手工调用进行消息通信
	RemoteHandle(context.Context, *RemoteMessage) (*Response, error)
	// 关闭session通知
	// 接收session关闭的动作，对当前节点进行相关的逻辑处理
	CloseSession(context.Context, *Session) (*Response, error)
}

type ErrorResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type KickMessage struct {
	Uid    int64  `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`      // 踢下线的uid
	Reason []byte `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // 原因自定义数据
	// contains filtered or unexported fields
}

type LocalMessage struct {
	Uid        int64  `protobuf:"varint,4,opt,name=uid,proto3" json:"uid,omitempty"`              // session uid
	FrontendId string `protobuf:"bytes,2,opt,name=frontendId,proto3" json:"frontendId,omitempty"` // 前端节点id
	MsgType    int32  `protobuf:"varint,1,opt,name=msgType,proto3" json:"msgType,omitempty"`      // 消息类型(request,notify,response,push)
	MsgId      int32  `protobuf:"varint,5,opt,name=msgId,proto3" json:"msgId,omitempty"`          // 消息序号id
	Route      string `protobuf:"bytes,6,opt,name=route,proto3" json:"route,omitempty"`           // 路由
	IsError    bool   `protobuf:"varint,7,opt,name=isError,proto3" json:"isError,omitempty"`      // 是否返回错误
	Data       []byte `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty"`             // 自定义数据
	// contains filtered or unexported fields
}

type MasterServiceClient interface {
	// 请求master服务节点，注册成员
	Register(ctx context.Context, in *Member, opts ...grpc.CallOption) (*MemberList, error)
	// 请求master服务节点，注销成员
	Unregister(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Response, error)
	// 接收新成员通知
	Add(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Response, error)
	// 接收删除成员通知
	Delete(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Response, error)
}

type MasterServiceServer interface {
	// 请求master服务节点，注册成员
	Register(context.Context, *Member) (*MemberList, error)
	// 请求master服务节点，注销成员
	Unregister(context.Context, *Member) (*Response, error)
	// 接收新成员通知
	Add(context.Context, *Member) (*Response, error)
	// 接收删除成员通知
	Delete(context.Context, *Member) (*Response, error)
}

type Member struct {
	NodeId   string            `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`     // 节点id
	NodeType string            `protobuf:"bytes,3,opt,name=nodeType,proto3" json:"nodeType,omitempty"` // 节点类型
	Address  string            `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`   // rpc连接地址
	Settings map[string]string ``                                                                      // 节点配置参数
	/* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MemberList struct {
	List []*Member `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

type PushMessage struct {
	Route string `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"` // 路由
	Uid   int64  `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`    // session uid
	Data  []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`   // 自定义数据
	// contains filtered or unexported fields
}

type RemoteMessage struct {
	NodeId string `protobuf:"bytes,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // 发送消息的节点id
	Route  string `protobuf:"bytes,6,opt,name=route,proto3" json:"route,omitempty"`   // 路由
	Data   []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`     // 自定义数据
	// contains filtered or unexported fields
}

type Response struct {
	// contains filtered or unexported fields
}

type Session struct {
	Uid  int64             `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Data map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type UnimplementedClusterServiceServer struct {
}

type UnimplementedMasterServiceServer struct {
}