pb

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_logic_proto protoreflect.FileDescriptor
View Source 
var File_task_proto protoreflect.FileDescriptor
View Source 
var File_ws_proto protoreflect.FileDescriptor
View Source 
var Logics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.logics",
	HandlerType: (*LogicsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Push",
			Handler:    _Logics_Push_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "logic.proto",
}

Logics_ServiceDesc is the grpc.ServiceDesc for Logics service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Task_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.task",
	HandlerType: (*TaskServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "pushSingleToConnect",
			Handler:    _Task_PushSingleToConnect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "task.proto",
}

Task_ServiceDesc is the grpc.ServiceDesc for Task service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Ws_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.ws",
	HandlerType: (*WsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushSingleMsg",
			Handler:    _Ws_PushSingleMsg_Handler,
		},
		{
			MethodName: "Connect",
			Handler:    _Ws_Connect_Handler,
		},
		{
			MethodName: "DisConnect",
			Handler:    _Ws_DisConnect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ws.proto",
}

Ws_ServiceDesc is the grpc.ServiceDesc for Ws service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLogicsServer 

func RegisterLogicsServer(s grpc.ServiceRegistrar, srv LogicsServer)

func RegisterTaskServer 

func RegisterTaskServer(s grpc.ServiceRegistrar, srv TaskServer)

func RegisterWsServer 

func RegisterWsServer(s grpc.ServiceRegistrar, srv WsServer)

Types

type ConnectReply 

type ConnectReply struct {
	UserId int64 `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectReply) Descriptor deprecated 

func (*ConnectReply) Descriptor() ([]byte, []int)

Deprecated: Use ConnectReply.ProtoReflect.Descriptor instead.

func (*ConnectReply) GetUserId 

func (x *ConnectReply) GetUserId() int64

func (*ConnectReply) ProtoMessage 

func (*ConnectReply) ProtoMessage()

func (*ConnectReply) ProtoReflect 

func (x *ConnectReply) ProtoReflect() protoreflect.Message

func (*ConnectReply) Reset 

func (x *ConnectReply) Reset()

func (*ConnectReply) String 

func (x *ConnectReply) String() string

type ConnectRequest 

type ConnectRequest struct {
	AuthToken string `protobuf:"bytes,1,opt,name=AuthToken,proto3" json:"AuthToken,omitempty"`
	RoomId    int64  `protobuf:"varint,2,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	ServerId  string `protobuf:"bytes,3,opt,name=ServerId,proto3" json:"ServerId,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

func (*ConnectRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetAuthToken 

func (x *ConnectRequest) GetAuthToken() string

func (*ConnectRequest) GetRoomId 

func (x *ConnectRequest) GetRoomId() int64

func (*ConnectRequest) GetServerId 

func (x *ConnectRequest) GetServerId() string

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

func (x *ConnectRequest) ProtoReflect() protoreflect.Message

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type DisConnectReply 

type DisConnectReply struct {
	Has bool `protobuf:"varint,1,opt,name=Has,proto3" json:"Has,omitempty"`
	// contains filtered or unexported fields
}

func (*DisConnectReply) Descriptor deprecated 

func (*DisConnectReply) Descriptor() ([]byte, []int)

Deprecated: Use DisConnectReply.ProtoReflect.Descriptor instead.

func (*DisConnectReply) GetHas 

func (x *DisConnectReply) GetHas() bool

func (*DisConnectReply) ProtoMessage 

func (*DisConnectReply) ProtoMessage()

func (*DisConnectReply) ProtoReflect 

func (x *DisConnectReply) ProtoReflect() protoreflect.Message

func (*DisConnectReply) Reset 

func (x *DisConnectReply) Reset()

func (*DisConnectReply) String 

func (x *DisConnectReply) String() string

type DisConnectRequest 

type DisConnectRequest struct {
	RoomId int64 `protobuf:"varint,1,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=UserId,proto3" json:"UserId,omitempty"`
	// contains filtered or unexported fields
}

func (*DisConnectRequest) Descriptor deprecated 

func (*DisConnectRequest) Descriptor() ([]byte, []int)

Deprecated: Use DisConnectRequest.ProtoReflect.Descriptor instead.

func (*DisConnectRequest) GetRoomId 

func (x *DisConnectRequest) GetRoomId() int64

func (*DisConnectRequest) GetUserId 

func (x *DisConnectRequest) GetUserId() int64

func (*DisConnectRequest) ProtoMessage 

func (*DisConnectRequest) ProtoMessage()

func (*DisConnectRequest) ProtoReflect 

func (x *DisConnectRequest) ProtoReflect() protoreflect.Message

func (*DisConnectRequest) Reset 

func (x *DisConnectRequest) Reset()

func (*DisConnectRequest) String 

func (x *DisConnectRequest) String() string

type KqMsg 

type KqMsg struct {
	Op           int64             `protobuf:"varint,1,opt,name=Op,proto3" json:"Op,omitempty"`
	ServerId     string            `protobuf:"bytes,2,opt,name=ServerId,proto3" json:"ServerId,omitempty"`
	RoomId       int64             `protobuf:"varint,3,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	UserId       int64             `protobuf:"varint,4,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Msg          []byte            `protobuf:"bytes,5,opt,name=Msg,proto3" json:"Msg,omitempty"`
	Count        int64             `protobuf:"varint,6,opt,name=Count,proto3" json:"Count,omitempty"`
	RoomUserInfo map[string]string `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KqMsg) Descriptor deprecated 

func (*KqMsg) Descriptor() ([]byte, []int)

Deprecated: Use KqMsg.ProtoReflect.Descriptor instead.

func (*KqMsg) GetCount 

func (x *KqMsg) GetCount() int64

func (*KqMsg) GetMsg 

func (x *KqMsg) GetMsg() []byte

func (*KqMsg) GetOp 

func (x *KqMsg) GetOp() int64

func (*KqMsg) GetRoomId 

func (x *KqMsg) GetRoomId() int64

func (*KqMsg) GetRoomUserInfo 

func (x *KqMsg) GetRoomUserInfo() map[string]string

func (*KqMsg) GetServerId 

func (x *KqMsg) GetServerId() string

func (*KqMsg) GetUserId 

func (x *KqMsg) GetUserId() int64

func (*KqMsg) ProtoMessage 

func (*KqMsg) ProtoMessage()

func (*KqMsg) ProtoReflect 

func (x *KqMsg) ProtoReflect() protoreflect.Message

func (*KqMsg) Reset 

func (x *KqMsg) Reset()

func (*KqMsg) String 

func (x *KqMsg) String() string

type KqRoomCountMsg 

type KqRoomCountMsg struct {
	Count int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	Op    int64 `protobuf:"varint,2,opt,name=Op,proto3" json:"Op,omitempty"`
	// contains filtered or unexported fields
}

func (*KqRoomCountMsg) Descriptor deprecated 

func (*KqRoomCountMsg) Descriptor() ([]byte, []int)

Deprecated: Use KqRoomCountMsg.ProtoReflect.Descriptor instead.

func (*KqRoomCountMsg) GetCount 

func (x *KqRoomCountMsg) GetCount() int64

func (*KqRoomCountMsg) GetOp 

func (x *KqRoomCountMsg) GetOp() int64

func (*KqRoomCountMsg) ProtoMessage 

func (*KqRoomCountMsg) ProtoMessage()

func (*KqRoomCountMsg) ProtoReflect 

func (x *KqRoomCountMsg) ProtoReflect() protoreflect.Message

func (*KqRoomCountMsg) Reset 

func (x *KqRoomCountMsg) Reset()

func (*KqRoomCountMsg) String 

func (x *KqRoomCountMsg) String() string

type KqRoomInfo 

type KqRoomInfo struct {
	Op           int64             `protobuf:"varint,1,opt,name=Op,proto3" json:"Op,omitempty"`
	RoomId       int64             `protobuf:"varint,2,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	Count        int64             `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`
	RoomUserInfo map[string]string `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KqRoomInfo) Descriptor deprecated 

func (*KqRoomInfo) Descriptor() ([]byte, []int)

Deprecated: Use KqRoomInfo.ProtoReflect.Descriptor instead.

func (*KqRoomInfo) GetCount 

func (x *KqRoomInfo) GetCount() int64

func (*KqRoomInfo) GetOp 

func (x *KqRoomInfo) GetOp() int64

func (*KqRoomInfo) GetRoomId 

func (x *KqRoomInfo) GetRoomId() int64

func (*KqRoomInfo) GetRoomUserInfo 

func (x *KqRoomInfo) GetRoomUserInfo() map[string]string

func (*KqRoomInfo) ProtoMessage 

func (*KqRoomInfo) ProtoMessage()

func (*KqRoomInfo) ProtoReflect 

func (x *KqRoomInfo) ProtoReflect() protoreflect.Message

func (*KqRoomInfo) Reset 

func (x *KqRoomInfo) Reset()

func (*KqRoomInfo) String 

func (x *KqRoomInfo) String() string

type LGSuccessReply 

type LGSuccessReply struct {
	Code int64  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*LGSuccessReply) Descriptor deprecated 

func (*LGSuccessReply) Descriptor() ([]byte, []int)

Deprecated: Use LGSuccessReply.ProtoReflect.Descriptor instead.

func (*LGSuccessReply) GetCode 

func (x *LGSuccessReply) GetCode() int64

func (*LGSuccessReply) GetMsg 

func (x *LGSuccessReply) GetMsg() string

func (*LGSuccessReply) ProtoMessage 

func (*LGSuccessReply) ProtoMessage()

func (*LGSuccessReply) ProtoReflect 

func (x *LGSuccessReply) ProtoReflect() protoreflect.Message

func (*LGSuccessReply) Reset 

func (x *LGSuccessReply) Reset()

func (*LGSuccessReply) String 

func (x *LGSuccessReply) String() string

type LogicsClient 

type LogicsClient interface {
	//返送单条消息
	Push(ctx context.Context, in *Send, opts ...grpc.CallOption) (*LGSuccessReply, error)
}

LogicsClient is the client API for Logics service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLogicsClient 

func NewLogicsClient(cc grpc.ClientConnInterface) LogicsClient

type LogicsServer 

type LogicsServer interface {
	//返送单条消息
	Push(context.Context, *Send) (*LGSuccessReply, error)
	// contains filtered or unexported methods
}

LogicsServer is the server API for Logics service. All implementations must embed UnimplementedLogicsServer for forward compatibility

type Msg 

type Msg struct {
	Ver       int64  `protobuf:"varint,1,opt,name=Ver,proto3" json:"Ver,omitempty"`             // protocol version
	Operation int64  `protobuf:"varint,2,opt,name=Operation,proto3" json:"Operation,omitempty"` // operation for request
	SeqId     string `protobuf:"bytes,3,opt,name=SeqId,proto3" json:"SeqId,omitempty"`          // sequence number chosen by client
	Body      []byte `protobuf:"bytes,4,opt,name=Body,proto3" json:"Body,omitempty"`            // binary body bytes
	// contains filtered or unexported fields
}

func (*Msg) Descriptor deprecated 

func (*Msg) Descriptor() ([]byte, []int)

Deprecated: Use Msg.ProtoReflect.Descriptor instead.

func (*Msg) GetBody 

func (x *Msg) GetBody() []byte

func (*Msg) GetOperation 

func (x *Msg) GetOperation() int64

func (*Msg) GetSeqId 

func (x *Msg) GetSeqId() string

func (*Msg) GetVer 

func (x *Msg) GetVer() int64

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) ProtoReflect 

func (x *Msg) ProtoReflect() protoreflect.Message

func (*Msg) Reset 

func (x *Msg) Reset()

func (*Msg) String 

func (x *Msg) String() string

type PushMsgRequest 

type PushMsgRequest struct {
	UserId int64 `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Msg    *Msg  `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PushMsgRequest) Descriptor deprecated 

func (*PushMsgRequest) Descriptor() ([]byte, []int)

Deprecated: Use PushMsgRequest.ProtoReflect.Descriptor instead.

func (*PushMsgRequest) GetMsg 

func (x *PushMsgRequest) GetMsg() *Msg

func (*PushMsgRequest) GetUserId 

func (x *PushMsgRequest) GetUserId() int64

func (*PushMsgRequest) ProtoMessage 

func (*PushMsgRequest) ProtoMessage()

func (*PushMsgRequest) ProtoReflect 

func (x *PushMsgRequest) ProtoReflect() protoreflect.Message

func (*PushMsgRequest) Reset 

func (x *PushMsgRequest) Reset()

func (*PushMsgRequest) String 

func (x *PushMsgRequest) String() string

type PushRoomCountRequest 

type PushRoomCountRequest struct {
	RoomId int64 `protobuf:"varint,1,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	Count  int64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*PushRoomCountRequest) Descriptor deprecated 

func (*PushRoomCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use PushRoomCountRequest.ProtoReflect.Descriptor instead.

func (*PushRoomCountRequest) GetCount 

func (x *PushRoomCountRequest) GetCount() int64

func (*PushRoomCountRequest) GetRoomId 

func (x *PushRoomCountRequest) GetRoomId() int64

func (*PushRoomCountRequest) ProtoMessage 

func (*PushRoomCountRequest) ProtoMessage()

func (*PushRoomCountRequest) ProtoReflect 

func (x *PushRoomCountRequest) ProtoReflect() protoreflect.Message

func (*PushRoomCountRequest) Reset 

func (x *PushRoomCountRequest) Reset()

func (*PushRoomCountRequest) String 

func (x *PushRoomCountRequest) String() string

type PushRoomMsgRequest 

type PushRoomMsgRequest struct {
	RoomId int64 `protobuf:"varint,1,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	Msg    *Msg  `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PushRoomMsgRequest) Descriptor deprecated 

func (*PushRoomMsgRequest) Descriptor() ([]byte, []int)

Deprecated: Use PushRoomMsgRequest.ProtoReflect.Descriptor instead.

func (*PushRoomMsgRequest) GetMsg 

func (x *PushRoomMsgRequest) GetMsg() *Msg

func (*PushRoomMsgRequest) GetRoomId 

func (x *PushRoomMsgRequest) GetRoomId() int64

func (*PushRoomMsgRequest) ProtoMessage 

func (*PushRoomMsgRequest) ProtoMessage()

func (*PushRoomMsgRequest) ProtoReflect 

func (x *PushRoomMsgRequest) ProtoReflect() protoreflect.Message

func (*PushRoomMsgRequest) Reset 

func (x *PushRoomMsgRequest) Reset()

func (*PushRoomMsgRequest) String 

func (x *PushRoomMsgRequest) String() string

type Send 

type Send struct {
	Code         int64  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg          string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	FromUserId   int64  `protobuf:"varint,3,opt,name=FromUserId,proto3" json:"FromUserId,omitempty"`
	FromUserName string `protobuf:"bytes,4,opt,name=FromUserName,proto3" json:"FromUserName,omitempty"`
	ToUserId     int64  `protobuf:"varint,5,opt,name=ToUserId,proto3" json:"ToUserId,omitempty"`
	ToUserName   string `protobuf:"bytes,6,opt,name=ToUserName,proto3" json:"ToUserName,omitempty"`
	RoomId       int64  `protobuf:"varint,7,opt,name=RoomId,proto3" json:"RoomId,omitempty"`
	Op           int64  `protobuf:"varint,8,opt,name=Op,proto3" json:"Op,omitempty"`
	CreateTime   string `protobuf:"bytes,9,opt,name=CreateTime,proto3" json:"CreateTime,omitempty"`
	// contains filtered or unexported fields
}

func (*Send) Descriptor deprecated 

func (*Send) Descriptor() ([]byte, []int)

Deprecated: Use Send.ProtoReflect.Descriptor instead.

func (*Send) GetCode 

func (x *Send) GetCode() int64

func (*Send) GetCreateTime 

func (x *Send) GetCreateTime() string

func (*Send) GetFromUserId 

func (x *Send) GetFromUserId() int64

func (*Send) GetFromUserName 

func (x *Send) GetFromUserName() string

func (*Send) GetMsg 

func (x *Send) GetMsg() string

func (*Send) GetOp 

func (x *Send) GetOp() int64

func (*Send) GetRoomId 

func (x *Send) GetRoomId() int64

func (*Send) GetToUserId 

func (x *Send) GetToUserId() int64

func (*Send) GetToUserName 

func (x *Send) GetToUserName() string

func (*Send) ProtoMessage 

func (*Send) ProtoMessage()

func (*Send) ProtoReflect 

func (x *Send) ProtoReflect() protoreflect.Message

func (*Send) Reset 

func (x *Send) Reset()

func (*Send) String 

func (x *Send) String() string

type SuccessReply 

type SuccessReply struct {
	Code int64  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SuccessReply) Descriptor deprecated 

func (*SuccessReply) Descriptor() ([]byte, []int)

Deprecated: Use SuccessReply.ProtoReflect.Descriptor instead.

func (*SuccessReply) GetCode 

func (x *SuccessReply) GetCode() int64

func (*SuccessReply) GetMsg 

func (x *SuccessReply) GetMsg() string

func (*SuccessReply) ProtoMessage 

func (*SuccessReply) ProtoMessage()

func (*SuccessReply) ProtoReflect 

func (x *SuccessReply) ProtoReflect() protoreflect.Message

func (*SuccessReply) Reset 

func (x *SuccessReply) Reset()

func (*SuccessReply) String 

func (x *SuccessReply) String() string

type TaskClient 

type TaskClient interface {
	//返送单条消息
	PushSingleToConnect(ctx context.Context, in *TaskSend, opts ...grpc.CallOption) (*TaskSuccessReply, error)
}

TaskClient is the client API for Task service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskClient 

func NewTaskClient(cc grpc.ClientConnInterface) TaskClient

type TaskSend 

type TaskSend struct {
	Send string `protobuf:"bytes,1,opt,name=Send,proto3" json:"Send,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskSend) Descriptor deprecated 

func (*TaskSend) Descriptor() ([]byte, []int)

Deprecated: Use TaskSend.ProtoReflect.Descriptor instead.

func (*TaskSend) GetSend 

func (x *TaskSend) GetSend() string

func (*TaskSend) ProtoMessage 

func (*TaskSend) ProtoMessage()

func (*TaskSend) ProtoReflect 

func (x *TaskSend) ProtoReflect() protoreflect.Message

func (*TaskSend) Reset 

func (x *TaskSend) Reset()

func (*TaskSend) String 

func (x *TaskSend) String() string

type TaskServer 

type TaskServer interface {
	//返送单条消息
	PushSingleToConnect(context.Context, *TaskSend) (*TaskSuccessReply, error)
	// contains filtered or unexported methods
}

TaskServer is the server API for Task service. All implementations must embed UnimplementedTaskServer for forward compatibility

type TaskSuccessReply 

type TaskSuccessReply struct {
	Code int64  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskSuccessReply) Descriptor deprecated 

func (*TaskSuccessReply) Descriptor() ([]byte, []int)

Deprecated: Use TaskSuccessReply.ProtoReflect.Descriptor instead.

func (*TaskSuccessReply) GetCode 

func (x *TaskSuccessReply) GetCode() int64

func (*TaskSuccessReply) GetMsg 

func (x *TaskSuccessReply) GetMsg() string

func (*TaskSuccessReply) ProtoMessage 

func (*TaskSuccessReply) ProtoMessage()

func (*TaskSuccessReply) ProtoReflect 

func (x *TaskSuccessReply) ProtoReflect() protoreflect.Message

func (*TaskSuccessReply) Reset 

func (x *TaskSuccessReply) Reset()

func (*TaskSuccessReply) String 

func (x *TaskSuccessReply) String() string

type UnimplementedLogicsServer 

type UnimplementedLogicsServer struct {
}

UnimplementedLogicsServer must be embedded to have forward compatible implementations.

func (UnimplementedLogicsServer) Push 

func (UnimplementedLogicsServer) Push(context.Context, *Send) (*LGSuccessReply, error)

type UnimplementedTaskServer 

type UnimplementedTaskServer struct {
}

UnimplementedTaskServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServer) PushSingleToConnect 

func (UnimplementedTaskServer) PushSingleToConnect(context.Context, *TaskSend) (*TaskSuccessReply, error)

type UnimplementedWsServer 

type UnimplementedWsServer struct {
}

UnimplementedWsServer must be embedded to have forward compatible implementations.

func (UnimplementedWsServer) Connect 

func (UnimplementedWsServer) Connect(context.Context, *ConnectRequest) (*ConnectReply, error)

func (UnimplementedWsServer) DisConnect 

func (UnimplementedWsServer) DisConnect(context.Context, *DisConnectRequest) (*DisConnectReply, error)

func (UnimplementedWsServer) PushSingleMsg 

func (UnimplementedWsServer) PushSingleMsg(context.Context, *PushRoomMsgRequest) (*SuccessReply, error)

type UnsafeLogicsServer 

type UnsafeLogicsServer interface {
	// contains filtered or unexported methods
}

UnsafeLogicsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogicsServer will result in compilation errors.

type UnsafeTaskServer 

type UnsafeTaskServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServer will result in compilation errors.

type UnsafeWsServer 

type UnsafeWsServer interface {
	// contains filtered or unexported methods
}

UnsafeWsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WsServer will result in compilation errors.

type WsClient 

type WsClient interface {
	//返送单条消息
	PushSingleMsg(ctx context.Context, in *PushRoomMsgRequest, opts ...grpc.CallOption) (*SuccessReply, error)
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectReply, error)
	DisConnect(ctx context.Context, in *DisConnectRequest, opts ...grpc.CallOption) (*DisConnectReply, error)
}

WsClient is the client API for Ws service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWsClient 

func NewWsClient(cc grpc.ClientConnInterface) WsClient

type WsServer 

type WsServer interface {
	//返送单条消息
	PushSingleMsg(context.Context, *PushRoomMsgRequest) (*SuccessReply, error)
	Connect(context.Context, *ConnectRequest) (*ConnectReply, error)
	DisConnect(context.Context, *DisConnectRequest) (*DisConnectReply, error)
	// contains filtered or unexported methods
}

WsServer is the server API for Ws service. All implementations must embed UnimplementedWsServer for forward compatibility

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.