Versions in this module Expand all Collapse all v1 v1.1.2 Apr 3, 2024 v1.1.1 Apr 3, 2024 Changes in this version + var File_logic_proto protoreflect.FileDescriptor + var File_task_proto protoreflect.FileDescriptor + var File_ws_proto protoreflect.FileDescriptor + var Logics_ServiceDesc = grpc.ServiceDesc + var Task_ServiceDesc = grpc.ServiceDesc + var Ws_ServiceDesc = grpc.ServiceDesc + func RegisterLogicsServer(s grpc.ServiceRegistrar, srv LogicsServer) + func RegisterTaskServer(s grpc.ServiceRegistrar, srv TaskServer) + func RegisterWsServer(s grpc.ServiceRegistrar, srv WsServer) + type ConnectReply struct + UserId int64 + func (*ConnectReply) Descriptor() ([]byte, []int) + func (*ConnectReply) ProtoMessage() + func (x *ConnectReply) GetUserId() int64 + func (x *ConnectReply) ProtoReflect() protoreflect.Message + func (x *ConnectReply) Reset() + func (x *ConnectReply) String() string + type ConnectRequest struct + AuthToken string + RoomId int64 + ServerId string + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + func (x *ConnectRequest) GetAuthToken() string + func (x *ConnectRequest) GetRoomId() int64 + func (x *ConnectRequest) GetServerId() string + func (x *ConnectRequest) ProtoReflect() protoreflect.Message + func (x *ConnectRequest) Reset() + func (x *ConnectRequest) String() string + type DisConnectReply struct + Has bool + func (*DisConnectReply) Descriptor() ([]byte, []int) + func (*DisConnectReply) ProtoMessage() + func (x *DisConnectReply) GetHas() bool + func (x *DisConnectReply) ProtoReflect() protoreflect.Message + func (x *DisConnectReply) Reset() + func (x *DisConnectReply) String() string + type DisConnectRequest struct + RoomId int64 + UserId int64 + func (*DisConnectRequest) Descriptor() ([]byte, []int) + func (*DisConnectRequest) ProtoMessage() + func (x *DisConnectRequest) GetRoomId() int64 + func (x *DisConnectRequest) GetUserId() int64 + func (x *DisConnectRequest) ProtoReflect() protoreflect.Message + func (x *DisConnectRequest) Reset() + func (x *DisConnectRequest) String() string + type KqMsg struct + Count int64 + Msg []byte + Op int64 + RoomId int64 + RoomUserInfo map[string]string + ServerId string + UserId int64 + func (*KqMsg) Descriptor() ([]byte, []int) + func (*KqMsg) ProtoMessage() + func (x *KqMsg) GetCount() int64 + func (x *KqMsg) GetMsg() []byte + func (x *KqMsg) GetOp() int64 + func (x *KqMsg) GetRoomId() int64 + func (x *KqMsg) GetRoomUserInfo() map[string]string + func (x *KqMsg) GetServerId() string + func (x *KqMsg) GetUserId() int64 + func (x *KqMsg) ProtoReflect() protoreflect.Message + func (x *KqMsg) Reset() + func (x *KqMsg) String() string + type KqRoomCountMsg struct + Count int64 + Op int64 + func (*KqRoomCountMsg) Descriptor() ([]byte, []int) + func (*KqRoomCountMsg) ProtoMessage() + func (x *KqRoomCountMsg) GetCount() int64 + func (x *KqRoomCountMsg) GetOp() int64 + func (x *KqRoomCountMsg) ProtoReflect() protoreflect.Message + func (x *KqRoomCountMsg) Reset() + func (x *KqRoomCountMsg) String() string + type KqRoomInfo struct + Count int64 + Op int64 + RoomId int64 + RoomUserInfo map[string]string + func (*KqRoomInfo) Descriptor() ([]byte, []int) + func (*KqRoomInfo) ProtoMessage() + func (x *KqRoomInfo) GetCount() int64 + func (x *KqRoomInfo) GetOp() int64 + func (x *KqRoomInfo) GetRoomId() int64 + func (x *KqRoomInfo) GetRoomUserInfo() map[string]string + func (x *KqRoomInfo) ProtoReflect() protoreflect.Message + func (x *KqRoomInfo) Reset() + func (x *KqRoomInfo) String() string + type LGSuccessReply struct + Code int64 + Msg string + func (*LGSuccessReply) Descriptor() ([]byte, []int) + func (*LGSuccessReply) ProtoMessage() + func (x *LGSuccessReply) GetCode() int64 + func (x *LGSuccessReply) GetMsg() string + func (x *LGSuccessReply) ProtoReflect() protoreflect.Message + func (x *LGSuccessReply) Reset() + func (x *LGSuccessReply) String() string + type LogicsClient interface + Push func(ctx context.Context, in *Send, opts ...grpc.CallOption) (*LGSuccessReply, error) + func NewLogicsClient(cc grpc.ClientConnInterface) LogicsClient + type LogicsServer interface + Push func(context.Context, *Send) (*LGSuccessReply, error) + type Msg struct + Body []byte + Operation int64 + SeqId string + Ver int64 + func (*Msg) Descriptor() ([]byte, []int) + func (*Msg) ProtoMessage() + func (x *Msg) GetBody() []byte + func (x *Msg) GetOperation() int64 + func (x *Msg) GetSeqId() string + func (x *Msg) GetVer() int64 + func (x *Msg) ProtoReflect() protoreflect.Message + func (x *Msg) Reset() + func (x *Msg) String() string + type PushMsgRequest struct + Msg *Msg + UserId int64 + func (*PushMsgRequest) Descriptor() ([]byte, []int) + func (*PushMsgRequest) ProtoMessage() + func (x *PushMsgRequest) GetMsg() *Msg + func (x *PushMsgRequest) GetUserId() int64 + func (x *PushMsgRequest) ProtoReflect() protoreflect.Message + func (x *PushMsgRequest) Reset() + func (x *PushMsgRequest) String() string + type PushRoomCountRequest struct + Count int64 + RoomId int64 + func (*PushRoomCountRequest) Descriptor() ([]byte, []int) + func (*PushRoomCountRequest) ProtoMessage() + func (x *PushRoomCountRequest) GetCount() int64 + func (x *PushRoomCountRequest) GetRoomId() int64 + func (x *PushRoomCountRequest) ProtoReflect() protoreflect.Message + func (x *PushRoomCountRequest) Reset() + func (x *PushRoomCountRequest) String() string + type PushRoomMsgRequest struct + Msg *Msg + RoomId int64 + func (*PushRoomMsgRequest) Descriptor() ([]byte, []int) + func (*PushRoomMsgRequest) ProtoMessage() + func (x *PushRoomMsgRequest) GetMsg() *Msg + func (x *PushRoomMsgRequest) GetRoomId() int64 + func (x *PushRoomMsgRequest) ProtoReflect() protoreflect.Message + func (x *PushRoomMsgRequest) Reset() + func (x *PushRoomMsgRequest) String() string + type Send struct + Code int64 + CreateTime string + FromUserId int64 + FromUserName string + Msg string + Op int64 + RoomId int64 + ToUserId int64 + ToUserName string + func (*Send) Descriptor() ([]byte, []int) + func (*Send) ProtoMessage() + func (x *Send) GetCode() int64 + func (x *Send) GetCreateTime() string + func (x *Send) GetFromUserId() int64 + func (x *Send) GetFromUserName() string + func (x *Send) GetMsg() string + func (x *Send) GetOp() int64 + func (x *Send) GetRoomId() int64 + func (x *Send) GetToUserId() int64 + func (x *Send) GetToUserName() string + func (x *Send) ProtoReflect() protoreflect.Message + func (x *Send) Reset() + func (x *Send) String() string + type SuccessReply struct + Code int64 + Msg string + func (*SuccessReply) Descriptor() ([]byte, []int) + func (*SuccessReply) ProtoMessage() + func (x *SuccessReply) GetCode() int64 + func (x *SuccessReply) GetMsg() string + func (x *SuccessReply) ProtoReflect() protoreflect.Message + func (x *SuccessReply) Reset() + func (x *SuccessReply) String() string + type TaskClient interface + PushSingleToConnect func(ctx context.Context, in *TaskSend, opts ...grpc.CallOption) (*TaskSuccessReply, error) + func NewTaskClient(cc grpc.ClientConnInterface) TaskClient + type TaskSend struct + Send string + func (*TaskSend) Descriptor() ([]byte, []int) + func (*TaskSend) ProtoMessage() + func (x *TaskSend) GetSend() string + func (x *TaskSend) ProtoReflect() protoreflect.Message + func (x *TaskSend) Reset() + func (x *TaskSend) String() string + type TaskServer interface + PushSingleToConnect func(context.Context, *TaskSend) (*TaskSuccessReply, error) + type TaskSuccessReply struct + Code int64 + Msg string + func (*TaskSuccessReply) Descriptor() ([]byte, []int) + func (*TaskSuccessReply) ProtoMessage() + func (x *TaskSuccessReply) GetCode() int64 + func (x *TaskSuccessReply) GetMsg() string + func (x *TaskSuccessReply) ProtoReflect() protoreflect.Message + func (x *TaskSuccessReply) Reset() + func (x *TaskSuccessReply) String() string + type UnimplementedLogicsServer struct + func (UnimplementedLogicsServer) Push(context.Context, *Send) (*LGSuccessReply, error) + type UnimplementedTaskServer struct + func (UnimplementedTaskServer) PushSingleToConnect(context.Context, *TaskSend) (*TaskSuccessReply, error) + type UnimplementedWsServer struct + func (UnimplementedWsServer) Connect(context.Context, *ConnectRequest) (*ConnectReply, error) + func (UnimplementedWsServer) DisConnect(context.Context, *DisConnectRequest) (*DisConnectReply, error) + func (UnimplementedWsServer) PushSingleMsg(context.Context, *PushRoomMsgRequest) (*SuccessReply, error) + type UnsafeLogicsServer interface + type UnsafeTaskServer interface + type UnsafeWsServer interface + type WsClient interface + Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectReply, error) + DisConnect func(ctx context.Context, in *DisConnectRequest, opts ...grpc.CallOption) (*DisConnectReply, error) + PushSingleMsg func(ctx context.Context, in *PushRoomMsgRequest, opts ...grpc.CallOption) (*SuccessReply, error) + func NewWsClient(cc grpc.ClientConnInterface) WsClient + type WsServer interface + Connect func(context.Context, *ConnectRequest) (*ConnectReply, error) + DisConnect func(context.Context, *DisConnectRequest) (*DisConnectReply, error) + PushSingleMsg func(context.Context, *PushRoomMsgRequest) (*SuccessReply, error)
Go to main page