cherryProto

type MasterServiceClient interface {
	// member向master注册节点
	Register(ctx context.Context, in *Member, opts ...grpc.CallOption) (*MemberList, error)
	// member向master注销节点
	Unregister(ctx context.Context, in *NodeId, opts ...grpc.CallOption) (*Response, error)
}

type MasterServiceServer interface {
	// member向master注册节点
	Register(context.Context, *Member) (*MemberList, error)
	// member向master注销节点
	Unregister(context.Context, *NodeId) (*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 MemberServiceClient interface {
	// 新成员通知
	NewMember(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Response, error)
	// 删除成员通知
	RemoveMember(ctx context.Context, in *NodeId, opts ...grpc.CallOption) (*Response, error)
	// member请求关闭session
	//rpc SendCloseSession(SessionId) returns (Response) {}
	// 关闭session通知
	CloseSession(ctx context.Context, in *SessionId, opts ...grpc.CallOption) (*Response, error)
	// 消息转发
	Forward(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Response, error)
}

type MemberServiceServer interface {
	// 新成员通知
	NewMember(context.Context, *Member) (*Response, error)
	// 删除成员通知
	RemoveMember(context.Context, *NodeId) (*Response, error)
	// member请求关闭session
	//rpc SendCloseSession(SessionId) returns (Response) {}
	// 关闭session通知
	CloseSession(context.Context, *SessionId) (*Response, error)
	// 消息转发
	Forward(context.Context, *Message) (*Response, error)
}

type Message struct {
	RpcType RPCType `protobuf:"varint,1,opt,name=rpcType,proto3,enum=cherryCluster.RPCType" json:"rpcType,omitempty"` // rpc类型
	MsgType int32   `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"`                            // 消息类型(request,notify,response,push)
	NodeId  string  `protobuf:"bytes,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"`                               // 节点id
	Sid     int64   `protobuf:"varint,4,opt,name=sid,proto3" json:"sid,omitempty"`                                    // session id
	Id      int32   `protobuf:"varint,5,opt,name=id,proto3" json:"id,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 NodeId struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type RPCType int32

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

type SessionId struct {
	Sid int64 `protobuf:"varint,1,opt,name=sid,proto3" json:"sid,omitempty"` // session id
	// contains filtered or unexported fields
}

type UnimplementedMasterServiceServer struct {
}

type UnimplementedMemberServiceServer struct {
}