Documentation
¶
Index ¶
- Variables
- func RegisterStreamLogicServiceServer(s *grpc.Server, srv StreamLogicServiceServer)
- func RegisterStreamRoomServiceServer(s *grpc.Server, srv StreamRoomServiceServer)
- type ConnectRoomInfo
- func (*ConnectRoomInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectRoomInfo) GetIp() uint32
- func (x *ConnectRoomInfo) GetPort() uint32
- func (*ConnectRoomInfo) ProtoMessage()
- func (x *ConnectRoomInfo) ProtoReflect() protoreflect.Message
- func (x *ConnectRoomInfo) Reset()
- func (x *ConnectRoomInfo) String() string
- type LogicRequest
- type LogicResponse
- type MsgType
- type RoomRequest
- type RoomResponse
- type StreamLogicServiceClient
- type StreamLogicServiceServer
- type StreamRoomServiceClient
- type StreamRoomServiceServer
- type StreamRoomService_RouteClient
- type StreamRoomService_RouteServer
- type UnimplementedStreamLogicServiceServer
- type UnimplementedStreamRoomServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( MsgType_name = map[int32]string{ 0: "Regist", 1: "Update", } MsgType_value = map[string]int32{ "Regist": 0, "Update": 1, } )
Enum value maps for MsgType.
var File_proto_server_proto protoreflect.FileDescriptor
Functions ¶
func RegisterStreamLogicServiceServer ¶
func RegisterStreamLogicServiceServer(s *grpc.Server, srv StreamLogicServiceServer)
func RegisterStreamRoomServiceServer ¶
func RegisterStreamRoomServiceServer(s *grpc.Server, srv StreamRoomServiceServer)
Types ¶
type ConnectRoomInfo ¶
type ConnectRoomInfo struct { Ip uint32 `protobuf:"fixed32,1,opt,name=ip,proto3" json:"ip,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*ConnectRoomInfo) Descriptor
deprecated
func (*ConnectRoomInfo) Descriptor() ([]byte, []int)
Deprecated: Use ConnectRoomInfo.ProtoReflect.Descriptor instead.
func (*ConnectRoomInfo) GetIp ¶
func (x *ConnectRoomInfo) GetIp() uint32
func (*ConnectRoomInfo) GetPort ¶
func (x *ConnectRoomInfo) GetPort() uint32
func (*ConnectRoomInfo) ProtoMessage ¶
func (*ConnectRoomInfo) ProtoMessage()
func (*ConnectRoomInfo) ProtoReflect ¶
func (x *ConnectRoomInfo) ProtoReflect() protoreflect.Message
func (*ConnectRoomInfo) Reset ¶
func (x *ConnectRoomInfo) Reset()
func (*ConnectRoomInfo) String ¶
func (x *ConnectRoomInfo) String() string
type LogicRequest ¶
type LogicRequest struct { Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"` // contains filtered or unexported fields }
func (*LogicRequest) Descriptor
deprecated
func (*LogicRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogicRequest.ProtoReflect.Descriptor instead.
func (*LogicRequest) GetToken ¶
func (x *LogicRequest) GetToken() string
func (*LogicRequest) ProtoMessage ¶
func (*LogicRequest) ProtoMessage()
func (*LogicRequest) ProtoReflect ¶
func (x *LogicRequest) ProtoReflect() protoreflect.Message
func (*LogicRequest) Reset ¶
func (x *LogicRequest) Reset()
func (*LogicRequest) String ¶
func (x *LogicRequest) String() string
type LogicResponse ¶
type LogicResponse struct { MInfo *ConnectRoomInfo `protobuf:"bytes,1,opt,name=mInfo,proto3" json:"mInfo,omitempty"` // contains filtered or unexported fields }
func (*LogicResponse) Descriptor
deprecated
func (*LogicResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogicResponse.ProtoReflect.Descriptor instead.
func (*LogicResponse) GetMInfo ¶
func (x *LogicResponse) GetMInfo() *ConnectRoomInfo
func (*LogicResponse) ProtoMessage ¶
func (*LogicResponse) ProtoMessage()
func (*LogicResponse) ProtoReflect ¶
func (x *LogicResponse) ProtoReflect() protoreflect.Message
func (*LogicResponse) Reset ¶
func (x *LogicResponse) Reset()
func (*LogicResponse) String ¶
func (x *LogicResponse) String() string
type MsgType ¶
type MsgType int32
func (MsgType) Descriptor ¶
func (MsgType) Descriptor() protoreflect.EnumDescriptor
func (MsgType) EnumDescriptor
deprecated
func (MsgType) Number ¶
func (x MsgType) Number() protoreflect.EnumNumber
func (MsgType) Type ¶
func (MsgType) Type() protoreflect.EnumType
type RoomRequest ¶
type RoomRequest struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.MsgType" json:"type,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RoomRequest) Descriptor
deprecated
func (*RoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use RoomRequest.ProtoReflect.Descriptor instead.
func (*RoomRequest) GetData ¶
func (x *RoomRequest) GetData() []byte
func (*RoomRequest) GetType ¶
func (x *RoomRequest) GetType() MsgType
func (*RoomRequest) ProtoMessage ¶
func (*RoomRequest) ProtoMessage()
func (*RoomRequest) ProtoReflect ¶
func (x *RoomRequest) ProtoReflect() protoreflect.Message
func (*RoomRequest) Reset ¶
func (x *RoomRequest) Reset()
func (*RoomRequest) String ¶
func (x *RoomRequest) String() string
type RoomResponse ¶
type RoomResponse struct {
// contains filtered or unexported fields
}
func (*RoomResponse) Descriptor
deprecated
func (*RoomResponse) Descriptor() ([]byte, []int)
Deprecated: Use RoomResponse.ProtoReflect.Descriptor instead.
func (*RoomResponse) ProtoMessage ¶
func (*RoomResponse) ProtoMessage()
func (*RoomResponse) ProtoReflect ¶
func (x *RoomResponse) ProtoReflect() protoreflect.Message
func (*RoomResponse) Reset ¶
func (x *RoomResponse) Reset()
func (*RoomResponse) String ¶
func (x *RoomResponse) String() string
type StreamLogicServiceClient ¶
type StreamLogicServiceClient interface {
Route(ctx context.Context, in *LogicRequest, opts ...grpc.CallOption) (*LogicResponse, error)
}
StreamLogicServiceClient is the client API for StreamLogicService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStreamLogicServiceClient ¶
func NewStreamLogicServiceClient(cc grpc.ClientConnInterface) StreamLogicServiceClient
type StreamLogicServiceServer ¶
type StreamLogicServiceServer interface {
Route(context.Context, *LogicRequest) (*LogicResponse, error)
}
StreamLogicServiceServer is the server API for StreamLogicService service.
type StreamRoomServiceClient ¶
type StreamRoomServiceClient interface {
Route(ctx context.Context, opts ...grpc.CallOption) (StreamRoomService_RouteClient, error)
}
StreamRoomServiceClient is the client API for StreamRoomService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStreamRoomServiceClient ¶
func NewStreamRoomServiceClient(cc grpc.ClientConnInterface) StreamRoomServiceClient
type StreamRoomServiceServer ¶
type StreamRoomServiceServer interface {
Route(StreamRoomService_RouteServer) error
}
StreamRoomServiceServer is the server API for StreamRoomService service.
type StreamRoomService_RouteClient ¶
type StreamRoomService_RouteClient interface { Send(*RoomRequest) error Recv() (*RoomResponse, error) grpc.ClientStream }
type StreamRoomService_RouteServer ¶
type StreamRoomService_RouteServer interface { Send(*RoomResponse) error Recv() (*RoomRequest, error) grpc.ServerStream }
type UnimplementedStreamLogicServiceServer ¶
type UnimplementedStreamLogicServiceServer struct { }
UnimplementedStreamLogicServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedStreamLogicServiceServer) Route ¶
func (*UnimplementedStreamLogicServiceServer) Route(context.Context, *LogicRequest) (*LogicResponse, error)
type UnimplementedStreamRoomServiceServer ¶
type UnimplementedStreamRoomServiceServer struct { }
UnimplementedStreamRoomServiceServer can be embedded to have forward compatible implementations.