Documentation ¶
Index ¶
- Variables
- func RegisterDanmakuServer(s *grpc.Server, srv DanmakuServer)
- type BatchRoomMessageRequest
- func (*BatchRoomMessageRequest) Descriptor() ([]byte, []int)
- func (m *BatchRoomMessageRequest) GetRoomMessage() []*RoomMessageRequest
- func (m *BatchRoomMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *BatchRoomMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BatchRoomMessageRequest) ProtoMessage()
- func (m *BatchRoomMessageRequest) Reset()
- func (m *BatchRoomMessageRequest) Size() (n int)
- func (m *BatchRoomMessageRequest) String() string
- func (m *BatchRoomMessageRequest) Unmarshal(dAtA []byte) error
- func (m *BatchRoomMessageRequest) XXX_DiscardUnknown()
- func (m *BatchRoomMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BatchRoomMessageRequest) XXX_Merge(src proto.Message)
- func (m *BatchRoomMessageRequest) XXX_Size() int
- func (m *BatchRoomMessageRequest) XXX_Unmarshal(b []byte) error
- type BatchUserMessageRequest
- func (*BatchUserMessageRequest) Descriptor() ([]byte, []int)
- func (m *BatchUserMessageRequest) GetUserMessage() []*UserMessageRequest
- func (m *BatchUserMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *BatchUserMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BatchUserMessageRequest) ProtoMessage()
- func (m *BatchUserMessageRequest) Reset()
- func (m *BatchUserMessageRequest) Size() (n int)
- func (m *BatchUserMessageRequest) String() string
- func (m *BatchUserMessageRequest) Unmarshal(dAtA []byte) error
- func (m *BatchUserMessageRequest) XXX_DiscardUnknown()
- func (m *BatchUserMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BatchUserMessageRequest) XXX_Merge(src proto.Message)
- func (m *BatchUserMessageRequest) XXX_Size() int
- func (m *BatchUserMessageRequest) XXX_Unmarshal(b []byte) error
- type BroadcastMessageRequest
- func (*BroadcastMessageRequest) Descriptor() ([]byte, []int)
- func (m *BroadcastMessageRequest) GetExcludeRoomId() []int32
- func (m *BroadcastMessageRequest) GetMessage() string
- func (m *BroadcastMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *BroadcastMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BroadcastMessageRequest) ProtoMessage()
- func (m *BroadcastMessageRequest) Reset()
- func (m *BroadcastMessageRequest) Size() (n int)
- func (m *BroadcastMessageRequest) String() string
- func (m *BroadcastMessageRequest) Unmarshal(dAtA []byte) error
- func (m *BroadcastMessageRequest) XXX_DiscardUnknown()
- func (m *BroadcastMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BroadcastMessageRequest) XXX_Merge(src proto.Message)
- func (m *BroadcastMessageRequest) XXX_Size() int
- func (m *BroadcastMessageRequest) XXX_Unmarshal(b []byte) error
- type Client
- type DanmakuClient
- type DanmakuServer
- type DispatchRequest
- func (*DispatchRequest) Descriptor() ([]byte, []int)
- func (m *DispatchRequest) GetUserId() int64
- func (m *DispatchRequest) GetUserIp() string
- func (m *DispatchRequest) Marshal() (dAtA []byte, err error)
- func (m *DispatchRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DispatchRequest) ProtoMessage()
- func (m *DispatchRequest) Reset()
- func (m *DispatchRequest) Size() (n int)
- func (m *DispatchRequest) String() string
- func (m *DispatchRequest) Unmarshal(dAtA []byte) error
- func (m *DispatchRequest) XXX_DiscardUnknown()
- func (m *DispatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DispatchRequest) XXX_Merge(src proto.Message)
- func (m *DispatchRequest) XXX_Size() int
- func (m *DispatchRequest) XXX_Unmarshal(b []byte) error
- type DispatchResponse
- func (*DispatchResponse) Descriptor() ([]byte, []int)
- func (m *DispatchResponse) GetHost() []string
- func (m *DispatchResponse) GetIp() []string
- func (m *DispatchResponse) Marshal() (dAtA []byte, err error)
- func (m *DispatchResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DispatchResponse) ProtoMessage()
- func (m *DispatchResponse) Reset()
- func (m *DispatchResponse) Size() (n int)
- func (m *DispatchResponse) String() string
- func (m *DispatchResponse) Unmarshal(dAtA []byte) error
- func (m *DispatchResponse) XXX_DiscardUnknown()
- func (m *DispatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DispatchResponse) XXX_Merge(src proto.Message)
- func (m *DispatchResponse) XXX_Size() int
- func (m *DispatchResponse) XXX_Unmarshal(b []byte) error
- type GeneralResponse
- func (*GeneralResponse) Descriptor() ([]byte, []int)
- func (m *GeneralResponse) Marshal() (dAtA []byte, err error)
- func (m *GeneralResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GeneralResponse) ProtoMessage()
- func (m *GeneralResponse) Reset()
- func (m *GeneralResponse) Size() (n int)
- func (m *GeneralResponse) String() string
- func (m *GeneralResponse) Unmarshal(dAtA []byte) error
- func (m *GeneralResponse) XXX_DiscardUnknown()
- func (m *GeneralResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GeneralResponse) XXX_Merge(src proto.Message)
- func (m *GeneralResponse) XXX_Size() int
- func (m *GeneralResponse) XXX_Unmarshal(b []byte) error
- type GetRoomOnlineCountRequest
- func (*GetRoomOnlineCountRequest) Descriptor() ([]byte, []int)
- func (m *GetRoomOnlineCountRequest) GetRoomId() []uint64
- func (m *GetRoomOnlineCountRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRoomOnlineCountRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetRoomOnlineCountRequest) ProtoMessage()
- func (m *GetRoomOnlineCountRequest) Reset()
- func (m *GetRoomOnlineCountRequest) Size() (n int)
- func (m *GetRoomOnlineCountRequest) String() string
- func (m *GetRoomOnlineCountRequest) Unmarshal(dAtA []byte) error
- func (m *GetRoomOnlineCountRequest) XXX_DiscardUnknown()
- func (m *GetRoomOnlineCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetRoomOnlineCountRequest) XXX_Merge(src proto.Message)
- func (m *GetRoomOnlineCountRequest) XXX_Size() int
- func (m *GetRoomOnlineCountRequest) XXX_Unmarshal(b []byte) error
- type GetRoomOnlineCountResponse
- func (*GetRoomOnlineCountResponse) Descriptor() ([]byte, []int)
- func (m *GetRoomOnlineCountResponse) GetRoomOnlineCount() map[uint64]uint64
- func (m *GetRoomOnlineCountResponse) Marshal() (dAtA []byte, err error)
- func (m *GetRoomOnlineCountResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GetRoomOnlineCountResponse) ProtoMessage()
- func (m *GetRoomOnlineCountResponse) Reset()
- func (m *GetRoomOnlineCountResponse) Size() (n int)
- func (m *GetRoomOnlineCountResponse) String() string
- func (m *GetRoomOnlineCountResponse) Unmarshal(dAtA []byte) error
- func (m *GetRoomOnlineCountResponse) XXX_DiscardUnknown()
- func (m *GetRoomOnlineCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetRoomOnlineCountResponse) XXX_Merge(src proto.Message)
- func (m *GetRoomOnlineCountResponse) XXX_Size() int
- func (m *GetRoomOnlineCountResponse) XXX_Unmarshal(b []byte) error
- type MultiRoomMessageRequest
- func (*MultiRoomMessageRequest) Descriptor() ([]byte, []int)
- func (m *MultiRoomMessageRequest) GetEnsure() int32
- func (m *MultiRoomMessageRequest) GetMessage() string
- func (m *MultiRoomMessageRequest) GetRoomId() []int32
- func (m *MultiRoomMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *MultiRoomMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (*MultiRoomMessageRequest) ProtoMessage()
- func (m *MultiRoomMessageRequest) Reset()
- func (m *MultiRoomMessageRequest) Size() (n int)
- func (m *MultiRoomMessageRequest) String() string
- func (m *MultiRoomMessageRequest) Unmarshal(dAtA []byte) error
- func (m *MultiRoomMessageRequest) XXX_DiscardUnknown()
- func (m *MultiRoomMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MultiRoomMessageRequest) XXX_Merge(src proto.Message)
- func (m *MultiRoomMessageRequest) XXX_Size() int
- func (m *MultiRoomMessageRequest) XXX_Unmarshal(b []byte) error
- type RoomMessageRequest
- func (*RoomMessageRequest) Descriptor() ([]byte, []int)
- func (m *RoomMessageRequest) GetEnsure() int32
- func (m *RoomMessageRequest) GetMessage() string
- func (m *RoomMessageRequest) GetRoomId() int32
- func (m *RoomMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *RoomMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RoomMessageRequest) ProtoMessage()
- func (m *RoomMessageRequest) Reset()
- func (m *RoomMessageRequest) Size() (n int)
- func (m *RoomMessageRequest) String() string
- func (m *RoomMessageRequest) Unmarshal(dAtA []byte) error
- func (m *RoomMessageRequest) XXX_DiscardUnknown()
- func (m *RoomMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RoomMessageRequest) XXX_Merge(src proto.Message)
- func (m *RoomMessageRequest) XXX_Size() int
- func (m *RoomMessageRequest) XXX_Unmarshal(b []byte) error
- type SetAngryValueRequest
- func (*SetAngryValueRequest) Descriptor() ([]byte, []int)
- func (m *SetAngryValueRequest) GetAngryValue() map[uint64]uint64
- func (m *SetAngryValueRequest) Marshal() (dAtA []byte, err error)
- func (m *SetAngryValueRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SetAngryValueRequest) ProtoMessage()
- func (m *SetAngryValueRequest) Reset()
- func (m *SetAngryValueRequest) Size() (n int)
- func (m *SetAngryValueRequest) String() string
- func (m *SetAngryValueRequest) Unmarshal(dAtA []byte) error
- func (m *SetAngryValueRequest) XXX_DiscardUnknown()
- func (m *SetAngryValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SetAngryValueRequest) XXX_Merge(src proto.Message)
- func (m *SetAngryValueRequest) XXX_Size() int
- func (m *SetAngryValueRequest) XXX_Unmarshal(b []byte) error
- type SetAngryValueResponse
- func (*SetAngryValueResponse) Descriptor() ([]byte, []int)
- func (m *SetAngryValueResponse) Marshal() (dAtA []byte, err error)
- func (m *SetAngryValueResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SetAngryValueResponse) ProtoMessage()
- func (m *SetAngryValueResponse) Reset()
- func (m *SetAngryValueResponse) Size() (n int)
- func (m *SetAngryValueResponse) String() string
- func (m *SetAngryValueResponse) Unmarshal(dAtA []byte) error
- func (m *SetAngryValueResponse) XXX_DiscardUnknown()
- func (m *SetAngryValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SetAngryValueResponse) XXX_Merge(src proto.Message)
- func (m *SetAngryValueResponse) XXX_Size() int
- func (m *SetAngryValueResponse) XXX_Unmarshal(b []byte) error
- type UserMessageRequest
- func (*UserMessageRequest) Descriptor() ([]byte, []int)
- func (m *UserMessageRequest) GetMessage() string
- func (m *UserMessageRequest) GetUserId() int64
- func (m *UserMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *UserMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (*UserMessageRequest) ProtoMessage()
- func (m *UserMessageRequest) Reset()
- func (m *UserMessageRequest) Size() (n int)
- func (m *UserMessageRequest) String() string
- func (m *UserMessageRequest) Unmarshal(dAtA []byte) error
- func (m *UserMessageRequest) XXX_DiscardUnknown()
- func (m *UserMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *UserMessageRequest) XXX_Merge(src proto.Message)
- func (m *UserMessageRequest) XXX_Size() int
- func (m *UserMessageRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterDanmakuServer ¶
func RegisterDanmakuServer(s *grpc.Server, srv DanmakuServer)
Types ¶
type BatchRoomMessageRequest ¶
type BatchRoomMessageRequest struct { RoomMessage []*RoomMessageRequest `protobuf:"bytes,1,rep,name=room_message,json=roomMessage" json:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BatchRoomMessageRequest) Descriptor ¶
func (*BatchRoomMessageRequest) Descriptor() ([]byte, []int)
func (*BatchRoomMessageRequest) GetRoomMessage ¶
func (m *BatchRoomMessageRequest) GetRoomMessage() []*RoomMessageRequest
func (*BatchRoomMessageRequest) Marshal ¶
func (m *BatchRoomMessageRequest) Marshal() (dAtA []byte, err error)
func (*BatchRoomMessageRequest) MarshalTo ¶
func (m *BatchRoomMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*BatchRoomMessageRequest) ProtoMessage ¶
func (*BatchRoomMessageRequest) ProtoMessage()
func (*BatchRoomMessageRequest) Reset ¶
func (m *BatchRoomMessageRequest) Reset()
func (*BatchRoomMessageRequest) Size ¶
func (m *BatchRoomMessageRequest) Size() (n int)
func (*BatchRoomMessageRequest) String ¶
func (m *BatchRoomMessageRequest) String() string
func (*BatchRoomMessageRequest) Unmarshal ¶
func (m *BatchRoomMessageRequest) Unmarshal(dAtA []byte) error
func (*BatchRoomMessageRequest) XXX_DiscardUnknown ¶
func (m *BatchRoomMessageRequest) XXX_DiscardUnknown()
func (*BatchRoomMessageRequest) XXX_Marshal ¶
func (m *BatchRoomMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchRoomMessageRequest) XXX_Merge ¶
func (dst *BatchRoomMessageRequest) XXX_Merge(src proto.Message)
func (*BatchRoomMessageRequest) XXX_Size ¶
func (m *BatchRoomMessageRequest) XXX_Size() int
func (*BatchRoomMessageRequest) XXX_Unmarshal ¶
func (m *BatchRoomMessageRequest) XXX_Unmarshal(b []byte) error
type BatchUserMessageRequest ¶
type BatchUserMessageRequest struct { UserMessage []*UserMessageRequest `protobuf:"bytes,1,rep,name=user_message,json=userMessage" json:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BatchUserMessageRequest) Descriptor ¶
func (*BatchUserMessageRequest) Descriptor() ([]byte, []int)
func (*BatchUserMessageRequest) GetUserMessage ¶
func (m *BatchUserMessageRequest) GetUserMessage() []*UserMessageRequest
func (*BatchUserMessageRequest) Marshal ¶
func (m *BatchUserMessageRequest) Marshal() (dAtA []byte, err error)
func (*BatchUserMessageRequest) MarshalTo ¶
func (m *BatchUserMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*BatchUserMessageRequest) ProtoMessage ¶
func (*BatchUserMessageRequest) ProtoMessage()
func (*BatchUserMessageRequest) Reset ¶
func (m *BatchUserMessageRequest) Reset()
func (*BatchUserMessageRequest) Size ¶
func (m *BatchUserMessageRequest) Size() (n int)
func (*BatchUserMessageRequest) String ¶
func (m *BatchUserMessageRequest) String() string
func (*BatchUserMessageRequest) Unmarshal ¶
func (m *BatchUserMessageRequest) Unmarshal(dAtA []byte) error
func (*BatchUserMessageRequest) XXX_DiscardUnknown ¶
func (m *BatchUserMessageRequest) XXX_DiscardUnknown()
func (*BatchUserMessageRequest) XXX_Marshal ¶
func (m *BatchUserMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchUserMessageRequest) XXX_Merge ¶
func (dst *BatchUserMessageRequest) XXX_Merge(src proto.Message)
func (*BatchUserMessageRequest) XXX_Size ¶
func (m *BatchUserMessageRequest) XXX_Size() int
func (*BatchUserMessageRequest) XXX_Unmarshal ¶
func (m *BatchUserMessageRequest) XXX_Unmarshal(b []byte) error
type BroadcastMessageRequest ¶
type BroadcastMessageRequest struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` ExcludeRoomId []int32 `protobuf:"varint,2,rep,packed,name=exclude_room_id,json=excludeRoomId" json:"exclude_room_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BroadcastMessageRequest) Descriptor ¶
func (*BroadcastMessageRequest) Descriptor() ([]byte, []int)
func (*BroadcastMessageRequest) GetExcludeRoomId ¶
func (m *BroadcastMessageRequest) GetExcludeRoomId() []int32
func (*BroadcastMessageRequest) GetMessage ¶
func (m *BroadcastMessageRequest) GetMessage() string
func (*BroadcastMessageRequest) Marshal ¶
func (m *BroadcastMessageRequest) Marshal() (dAtA []byte, err error)
func (*BroadcastMessageRequest) MarshalTo ¶
func (m *BroadcastMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*BroadcastMessageRequest) ProtoMessage ¶
func (*BroadcastMessageRequest) ProtoMessage()
func (*BroadcastMessageRequest) Reset ¶
func (m *BroadcastMessageRequest) Reset()
func (*BroadcastMessageRequest) Size ¶
func (m *BroadcastMessageRequest) Size() (n int)
func (*BroadcastMessageRequest) String ¶
func (m *BroadcastMessageRequest) String() string
func (*BroadcastMessageRequest) Unmarshal ¶
func (m *BroadcastMessageRequest) Unmarshal(dAtA []byte) error
func (*BroadcastMessageRequest) XXX_DiscardUnknown ¶
func (m *BroadcastMessageRequest) XXX_DiscardUnknown()
func (*BroadcastMessageRequest) XXX_Marshal ¶
func (m *BroadcastMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BroadcastMessageRequest) XXX_Merge ¶
func (dst *BroadcastMessageRequest) XXX_Merge(src proto.Message)
func (*BroadcastMessageRequest) XXX_Size ¶
func (m *BroadcastMessageRequest) XXX_Size() int
func (*BroadcastMessageRequest) XXX_Unmarshal ¶
func (m *BroadcastMessageRequest) XXX_Unmarshal(b []byte) error
type Client ¶
type Client struct {
DanmakuClient
}
func NewClient ¶
func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (*Client, error)
NewClient new resource grpc client
type DanmakuClient ¶
type DanmakuClient interface { RoomMessage(ctx context.Context, in *RoomMessageRequest, opts ...grpc.CallOption) (*GeneralResponse, error) BroadcastMessage(ctx context.Context, in *BroadcastMessageRequest, opts ...grpc.CallOption) (*GeneralResponse, error) MultiRoomMessage(ctx context.Context, in *MultiRoomMessageRequest, opts ...grpc.CallOption) (*GeneralResponse, error) BatchRoomMessage(ctx context.Context, in *BatchRoomMessageRequest, opts ...grpc.CallOption) (*GeneralResponse, error) UserMessage(ctx context.Context, in *UserMessageRequest, opts ...grpc.CallOption) (*GeneralResponse, error) BatchUserMessage(ctx context.Context, in *BatchUserMessageRequest, opts ...grpc.CallOption) (*GeneralResponse, error) Dispatch(ctx context.Context, in *DispatchRequest, opts ...grpc.CallOption) (*DispatchResponse, error) SetAngryValue(ctx context.Context, in *SetAngryValueRequest, opts ...grpc.CallOption) (*SetAngryValueResponse, error) GetRoomOnlineCount(ctx context.Context, in *GetRoomOnlineCountRequest, opts ...grpc.CallOption) (*GetRoomOnlineCountResponse, error) }
DanmakuClient is the client API for Danmaku service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDanmakuClient ¶
func NewDanmakuClient(cc *grpc.ClientConn) DanmakuClient
type DanmakuServer ¶
type DanmakuServer interface { RoomMessage(context.Context, *RoomMessageRequest) (*GeneralResponse, error) BroadcastMessage(context.Context, *BroadcastMessageRequest) (*GeneralResponse, error) MultiRoomMessage(context.Context, *MultiRoomMessageRequest) (*GeneralResponse, error) BatchRoomMessage(context.Context, *BatchRoomMessageRequest) (*GeneralResponse, error) UserMessage(context.Context, *UserMessageRequest) (*GeneralResponse, error) BatchUserMessage(context.Context, *BatchUserMessageRequest) (*GeneralResponse, error) Dispatch(context.Context, *DispatchRequest) (*DispatchResponse, error) SetAngryValue(context.Context, *SetAngryValueRequest) (*SetAngryValueResponse, error) GetRoomOnlineCount(context.Context, *GetRoomOnlineCountRequest) (*GetRoomOnlineCountResponse, error) }
DanmakuServer is the server API for Danmaku service.
type DispatchRequest ¶
type DispatchRequest struct { UserId int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"uid"` UserIp string `protobuf:"bytes,2,opt,name=user_ip,json=userIp,proto3" json:"ip"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DispatchRequest) Descriptor ¶
func (*DispatchRequest) Descriptor() ([]byte, []int)
func (*DispatchRequest) GetUserId ¶
func (m *DispatchRequest) GetUserId() int64
func (*DispatchRequest) GetUserIp ¶
func (m *DispatchRequest) GetUserIp() string
func (*DispatchRequest) Marshal ¶
func (m *DispatchRequest) Marshal() (dAtA []byte, err error)
func (*DispatchRequest) ProtoMessage ¶
func (*DispatchRequest) ProtoMessage()
func (*DispatchRequest) Reset ¶
func (m *DispatchRequest) Reset()
func (*DispatchRequest) Size ¶
func (m *DispatchRequest) Size() (n int)
func (*DispatchRequest) String ¶
func (m *DispatchRequest) String() string
func (*DispatchRequest) Unmarshal ¶
func (m *DispatchRequest) Unmarshal(dAtA []byte) error
func (*DispatchRequest) XXX_DiscardUnknown ¶
func (m *DispatchRequest) XXX_DiscardUnknown()
func (*DispatchRequest) XXX_Marshal ¶
func (m *DispatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DispatchRequest) XXX_Merge ¶
func (dst *DispatchRequest) XXX_Merge(src proto.Message)
func (*DispatchRequest) XXX_Size ¶
func (m *DispatchRequest) XXX_Size() int
func (*DispatchRequest) XXX_Unmarshal ¶
func (m *DispatchRequest) XXX_Unmarshal(b []byte) error
type DispatchResponse ¶
type DispatchResponse struct { Ip []string `protobuf:"bytes,1,rep,name=ip" json:"ip"` Host []string `protobuf:"bytes,2,rep,name=host" json:"host"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DispatchResponse) Descriptor ¶
func (*DispatchResponse) Descriptor() ([]byte, []int)
func (*DispatchResponse) GetHost ¶
func (m *DispatchResponse) GetHost() []string
func (*DispatchResponse) GetIp ¶
func (m *DispatchResponse) GetIp() []string
func (*DispatchResponse) Marshal ¶
func (m *DispatchResponse) Marshal() (dAtA []byte, err error)
func (*DispatchResponse) ProtoMessage ¶
func (*DispatchResponse) ProtoMessage()
func (*DispatchResponse) Reset ¶
func (m *DispatchResponse) Reset()
func (*DispatchResponse) Size ¶
func (m *DispatchResponse) Size() (n int)
func (*DispatchResponse) String ¶
func (m *DispatchResponse) String() string
func (*DispatchResponse) Unmarshal ¶
func (m *DispatchResponse) Unmarshal(dAtA []byte) error
func (*DispatchResponse) XXX_DiscardUnknown ¶
func (m *DispatchResponse) XXX_DiscardUnknown()
func (*DispatchResponse) XXX_Marshal ¶
func (m *DispatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DispatchResponse) XXX_Merge ¶
func (dst *DispatchResponse) XXX_Merge(src proto.Message)
func (*DispatchResponse) XXX_Size ¶
func (m *DispatchResponse) XXX_Size() int
func (*DispatchResponse) XXX_Unmarshal ¶
func (m *DispatchResponse) XXX_Unmarshal(b []byte) error
type GeneralResponse ¶
type GeneralResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GeneralResponse) Descriptor ¶
func (*GeneralResponse) Descriptor() ([]byte, []int)
func (*GeneralResponse) Marshal ¶
func (m *GeneralResponse) Marshal() (dAtA []byte, err error)
func (*GeneralResponse) ProtoMessage ¶
func (*GeneralResponse) ProtoMessage()
func (*GeneralResponse) Reset ¶
func (m *GeneralResponse) Reset()
func (*GeneralResponse) Size ¶
func (m *GeneralResponse) Size() (n int)
func (*GeneralResponse) String ¶
func (m *GeneralResponse) String() string
func (*GeneralResponse) Unmarshal ¶
func (m *GeneralResponse) Unmarshal(dAtA []byte) error
func (*GeneralResponse) XXX_DiscardUnknown ¶
func (m *GeneralResponse) XXX_DiscardUnknown()
func (*GeneralResponse) XXX_Marshal ¶
func (m *GeneralResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GeneralResponse) XXX_Merge ¶
func (dst *GeneralResponse) XXX_Merge(src proto.Message)
func (*GeneralResponse) XXX_Size ¶
func (m *GeneralResponse) XXX_Size() int
func (*GeneralResponse) XXX_Unmarshal ¶
func (m *GeneralResponse) XXX_Unmarshal(b []byte) error
type GetRoomOnlineCountRequest ¶
type GetRoomOnlineCountRequest struct { RoomId []uint64 `protobuf:"varint,1,rep,packed,name=room_id,json=roomId" json:"room_id"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRoomOnlineCountRequest) Descriptor ¶
func (*GetRoomOnlineCountRequest) Descriptor() ([]byte, []int)
func (*GetRoomOnlineCountRequest) GetRoomId ¶
func (m *GetRoomOnlineCountRequest) GetRoomId() []uint64
func (*GetRoomOnlineCountRequest) Marshal ¶
func (m *GetRoomOnlineCountRequest) Marshal() (dAtA []byte, err error)
func (*GetRoomOnlineCountRequest) MarshalTo ¶
func (m *GetRoomOnlineCountRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetRoomOnlineCountRequest) ProtoMessage ¶
func (*GetRoomOnlineCountRequest) ProtoMessage()
func (*GetRoomOnlineCountRequest) Reset ¶
func (m *GetRoomOnlineCountRequest) Reset()
func (*GetRoomOnlineCountRequest) Size ¶
func (m *GetRoomOnlineCountRequest) Size() (n int)
func (*GetRoomOnlineCountRequest) String ¶
func (m *GetRoomOnlineCountRequest) String() string
func (*GetRoomOnlineCountRequest) Unmarshal ¶
func (m *GetRoomOnlineCountRequest) Unmarshal(dAtA []byte) error
func (*GetRoomOnlineCountRequest) XXX_DiscardUnknown ¶
func (m *GetRoomOnlineCountRequest) XXX_DiscardUnknown()
func (*GetRoomOnlineCountRequest) XXX_Marshal ¶
func (m *GetRoomOnlineCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRoomOnlineCountRequest) XXX_Merge ¶
func (dst *GetRoomOnlineCountRequest) XXX_Merge(src proto.Message)
func (*GetRoomOnlineCountRequest) XXX_Size ¶
func (m *GetRoomOnlineCountRequest) XXX_Size() int
func (*GetRoomOnlineCountRequest) XXX_Unmarshal ¶
func (m *GetRoomOnlineCountRequest) XXX_Unmarshal(b []byte) error
type GetRoomOnlineCountResponse ¶
type GetRoomOnlineCountResponse struct { RoomOnlineCount map[uint64]uint64 `` /* 181-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRoomOnlineCountResponse) Descriptor ¶
func (*GetRoomOnlineCountResponse) Descriptor() ([]byte, []int)
func (*GetRoomOnlineCountResponse) GetRoomOnlineCount ¶
func (m *GetRoomOnlineCountResponse) GetRoomOnlineCount() map[uint64]uint64
func (*GetRoomOnlineCountResponse) Marshal ¶
func (m *GetRoomOnlineCountResponse) Marshal() (dAtA []byte, err error)
func (*GetRoomOnlineCountResponse) MarshalTo ¶
func (m *GetRoomOnlineCountResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetRoomOnlineCountResponse) ProtoMessage ¶
func (*GetRoomOnlineCountResponse) ProtoMessage()
func (*GetRoomOnlineCountResponse) Reset ¶
func (m *GetRoomOnlineCountResponse) Reset()
func (*GetRoomOnlineCountResponse) Size ¶
func (m *GetRoomOnlineCountResponse) Size() (n int)
func (*GetRoomOnlineCountResponse) String ¶
func (m *GetRoomOnlineCountResponse) String() string
func (*GetRoomOnlineCountResponse) Unmarshal ¶
func (m *GetRoomOnlineCountResponse) Unmarshal(dAtA []byte) error
func (*GetRoomOnlineCountResponse) XXX_DiscardUnknown ¶
func (m *GetRoomOnlineCountResponse) XXX_DiscardUnknown()
func (*GetRoomOnlineCountResponse) XXX_Marshal ¶
func (m *GetRoomOnlineCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRoomOnlineCountResponse) XXX_Merge ¶
func (dst *GetRoomOnlineCountResponse) XXX_Merge(src proto.Message)
func (*GetRoomOnlineCountResponse) XXX_Size ¶
func (m *GetRoomOnlineCountResponse) XXX_Size() int
func (*GetRoomOnlineCountResponse) XXX_Unmarshal ¶
func (m *GetRoomOnlineCountResponse) XXX_Unmarshal(b []byte) error
type MultiRoomMessageRequest ¶
type MultiRoomMessageRequest struct { RoomId []int32 `protobuf:"varint,1,rep,packed,name=room_id,json=roomId" json:"room_id"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"msg"` Ensure int32 `protobuf:"varint,3,opt,name=ensure,proto3" json:"ensure,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MultiRoomMessageRequest) Descriptor ¶
func (*MultiRoomMessageRequest) Descriptor() ([]byte, []int)
func (*MultiRoomMessageRequest) GetEnsure ¶
func (m *MultiRoomMessageRequest) GetEnsure() int32
func (*MultiRoomMessageRequest) GetMessage ¶
func (m *MultiRoomMessageRequest) GetMessage() string
func (*MultiRoomMessageRequest) GetRoomId ¶
func (m *MultiRoomMessageRequest) GetRoomId() []int32
func (*MultiRoomMessageRequest) Marshal ¶
func (m *MultiRoomMessageRequest) Marshal() (dAtA []byte, err error)
func (*MultiRoomMessageRequest) MarshalTo ¶
func (m *MultiRoomMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*MultiRoomMessageRequest) ProtoMessage ¶
func (*MultiRoomMessageRequest) ProtoMessage()
func (*MultiRoomMessageRequest) Reset ¶
func (m *MultiRoomMessageRequest) Reset()
func (*MultiRoomMessageRequest) Size ¶
func (m *MultiRoomMessageRequest) Size() (n int)
func (*MultiRoomMessageRequest) String ¶
func (m *MultiRoomMessageRequest) String() string
func (*MultiRoomMessageRequest) Unmarshal ¶
func (m *MultiRoomMessageRequest) Unmarshal(dAtA []byte) error
func (*MultiRoomMessageRequest) XXX_DiscardUnknown ¶
func (m *MultiRoomMessageRequest) XXX_DiscardUnknown()
func (*MultiRoomMessageRequest) XXX_Marshal ¶
func (m *MultiRoomMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MultiRoomMessageRequest) XXX_Merge ¶
func (dst *MultiRoomMessageRequest) XXX_Merge(src proto.Message)
func (*MultiRoomMessageRequest) XXX_Size ¶
func (m *MultiRoomMessageRequest) XXX_Size() int
func (*MultiRoomMessageRequest) XXX_Unmarshal ¶
func (m *MultiRoomMessageRequest) XXX_Unmarshal(b []byte) error
type RoomMessageRequest ¶
type RoomMessageRequest struct { RoomId int32 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"msg"` Ensure int32 `protobuf:"varint,3,opt,name=ensure,proto3" json:"ensure,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RoomMessageRequest) Descriptor ¶
func (*RoomMessageRequest) Descriptor() ([]byte, []int)
func (*RoomMessageRequest) GetEnsure ¶
func (m *RoomMessageRequest) GetEnsure() int32
func (*RoomMessageRequest) GetMessage ¶
func (m *RoomMessageRequest) GetMessage() string
func (*RoomMessageRequest) GetRoomId ¶
func (m *RoomMessageRequest) GetRoomId() int32
func (*RoomMessageRequest) Marshal ¶
func (m *RoomMessageRequest) Marshal() (dAtA []byte, err error)
func (*RoomMessageRequest) MarshalTo ¶
func (m *RoomMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*RoomMessageRequest) ProtoMessage ¶
func (*RoomMessageRequest) ProtoMessage()
func (*RoomMessageRequest) Reset ¶
func (m *RoomMessageRequest) Reset()
func (*RoomMessageRequest) Size ¶
func (m *RoomMessageRequest) Size() (n int)
func (*RoomMessageRequest) String ¶
func (m *RoomMessageRequest) String() string
func (*RoomMessageRequest) Unmarshal ¶
func (m *RoomMessageRequest) Unmarshal(dAtA []byte) error
func (*RoomMessageRequest) XXX_DiscardUnknown ¶
func (m *RoomMessageRequest) XXX_DiscardUnknown()
func (*RoomMessageRequest) XXX_Marshal ¶
func (m *RoomMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoomMessageRequest) XXX_Merge ¶
func (dst *RoomMessageRequest) XXX_Merge(src proto.Message)
func (*RoomMessageRequest) XXX_Size ¶
func (m *RoomMessageRequest) XXX_Size() int
func (*RoomMessageRequest) XXX_Unmarshal ¶
func (m *RoomMessageRequest) XXX_Unmarshal(b []byte) error
type SetAngryValueRequest ¶
type SetAngryValueRequest struct { AngryValue map[uint64]uint64 `` /* 164-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetAngryValueRequest) Descriptor ¶
func (*SetAngryValueRequest) Descriptor() ([]byte, []int)
func (*SetAngryValueRequest) GetAngryValue ¶
func (m *SetAngryValueRequest) GetAngryValue() map[uint64]uint64
func (*SetAngryValueRequest) Marshal ¶
func (m *SetAngryValueRequest) Marshal() (dAtA []byte, err error)
func (*SetAngryValueRequest) MarshalTo ¶
func (m *SetAngryValueRequest) MarshalTo(dAtA []byte) (int, error)
func (*SetAngryValueRequest) ProtoMessage ¶
func (*SetAngryValueRequest) ProtoMessage()
func (*SetAngryValueRequest) Reset ¶
func (m *SetAngryValueRequest) Reset()
func (*SetAngryValueRequest) Size ¶
func (m *SetAngryValueRequest) Size() (n int)
func (*SetAngryValueRequest) String ¶
func (m *SetAngryValueRequest) String() string
func (*SetAngryValueRequest) Unmarshal ¶
func (m *SetAngryValueRequest) Unmarshal(dAtA []byte) error
func (*SetAngryValueRequest) XXX_DiscardUnknown ¶
func (m *SetAngryValueRequest) XXX_DiscardUnknown()
func (*SetAngryValueRequest) XXX_Marshal ¶
func (m *SetAngryValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetAngryValueRequest) XXX_Merge ¶
func (dst *SetAngryValueRequest) XXX_Merge(src proto.Message)
func (*SetAngryValueRequest) XXX_Size ¶
func (m *SetAngryValueRequest) XXX_Size() int
func (*SetAngryValueRequest) XXX_Unmarshal ¶
func (m *SetAngryValueRequest) XXX_Unmarshal(b []byte) error
type SetAngryValueResponse ¶
type SetAngryValueResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetAngryValueResponse) Descriptor ¶
func (*SetAngryValueResponse) Descriptor() ([]byte, []int)
func (*SetAngryValueResponse) Marshal ¶
func (m *SetAngryValueResponse) Marshal() (dAtA []byte, err error)
func (*SetAngryValueResponse) MarshalTo ¶
func (m *SetAngryValueResponse) MarshalTo(dAtA []byte) (int, error)
func (*SetAngryValueResponse) ProtoMessage ¶
func (*SetAngryValueResponse) ProtoMessage()
func (*SetAngryValueResponse) Reset ¶
func (m *SetAngryValueResponse) Reset()
func (*SetAngryValueResponse) Size ¶
func (m *SetAngryValueResponse) Size() (n int)
func (*SetAngryValueResponse) String ¶
func (m *SetAngryValueResponse) String() string
func (*SetAngryValueResponse) Unmarshal ¶
func (m *SetAngryValueResponse) Unmarshal(dAtA []byte) error
func (*SetAngryValueResponse) XXX_DiscardUnknown ¶
func (m *SetAngryValueResponse) XXX_DiscardUnknown()
func (*SetAngryValueResponse) XXX_Marshal ¶
func (m *SetAngryValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetAngryValueResponse) XXX_Merge ¶
func (dst *SetAngryValueResponse) XXX_Merge(src proto.Message)
func (*SetAngryValueResponse) XXX_Size ¶
func (m *SetAngryValueResponse) XXX_Size() int
func (*SetAngryValueResponse) XXX_Unmarshal ¶
func (m *SetAngryValueResponse) XXX_Unmarshal(b []byte) error
type UserMessageRequest ¶
type UserMessageRequest struct { UserId int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"uid"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"msg"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UserMessageRequest) Descriptor ¶
func (*UserMessageRequest) Descriptor() ([]byte, []int)
func (*UserMessageRequest) GetMessage ¶
func (m *UserMessageRequest) GetMessage() string
func (*UserMessageRequest) GetUserId ¶
func (m *UserMessageRequest) GetUserId() int64
func (*UserMessageRequest) Marshal ¶
func (m *UserMessageRequest) Marshal() (dAtA []byte, err error)
func (*UserMessageRequest) MarshalTo ¶
func (m *UserMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*UserMessageRequest) ProtoMessage ¶
func (*UserMessageRequest) ProtoMessage()
func (*UserMessageRequest) Reset ¶
func (m *UserMessageRequest) Reset()
func (*UserMessageRequest) Size ¶
func (m *UserMessageRequest) Size() (n int)
func (*UserMessageRequest) String ¶
func (m *UserMessageRequest) String() string
func (*UserMessageRequest) Unmarshal ¶
func (m *UserMessageRequest) Unmarshal(dAtA []byte) error
func (*UserMessageRequest) XXX_DiscardUnknown ¶
func (m *UserMessageRequest) XXX_DiscardUnknown()
func (*UserMessageRequest) XXX_Marshal ¶
func (m *UserMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UserMessageRequest) XXX_Merge ¶
func (dst *UserMessageRequest) XXX_Merge(src proto.Message)
func (*UserMessageRequest) XXX_Size ¶
func (m *UserMessageRequest) XXX_Size() int
func (*UserMessageRequest) XXX_Unmarshal ¶
func (m *UserMessageRequest) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.