Versions in this module Expand all Collapse all v0 v0.0.3 Apr 14, 2022 v0.0.2 Apr 14, 2022 Changes in this version + var RoomType_name = map[int32]string + var RoomType_value = map[string]int32 + func NewXClientForPigeonService(addr string) (client.XClient, error) + func NewXClientForRoomService(addr string) (client.XClient, error) + func ServeForPigeonService(addr string) error + func ServeForRoomService(addr string) error + type BroadcastArgs struct + Op uint32 + Proto *Proto + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BroadcastArgs) Descriptor() ([]byte, []int) + func (*BroadcastArgs) ProtoMessage() + func (m *BroadcastArgs) GetOp() uint32 + func (m *BroadcastArgs) GetProto() *Proto + func (m *BroadcastArgs) Reset() + func (m *BroadcastArgs) String() string + func (m *BroadcastArgs) XXX_DiscardUnknown() + func (m *BroadcastArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BroadcastArgs) XXX_Merge(src proto.Message) + func (m *BroadcastArgs) XXX_Size() int + func (m *BroadcastArgs) XXX_Unmarshal(b []byte) error + type JoinRoomArgs struct + Id int64 + RoomId int64 + RoomType RoomType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JoinRoomArgs) Descriptor() ([]byte, []int) + func (*JoinRoomArgs) ProtoMessage() + func (m *JoinRoomArgs) GetId() int64 + func (m *JoinRoomArgs) GetRoomId() int64 + func (m *JoinRoomArgs) GetRoomType() RoomType + func (m *JoinRoomArgs) Reset() + func (m *JoinRoomArgs) String() string + func (m *JoinRoomArgs) XXX_DiscardUnknown() + func (m *JoinRoomArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JoinRoomArgs) XXX_Merge(src proto.Message) + func (m *JoinRoomArgs) XXX_Size() int + func (m *JoinRoomArgs) XXX_Unmarshal(b []byte) error + type PigeonServiceAble interface + Broadcast func(ctx context.Context, args *BroadcastArgs, reply *common.Err) (err error) + PushMsgByClient func(ctx context.Context, args *PushMsgByClientArgs, reply *common.Err) (err error) + PushMsgByRoom func(ctx context.Context, args *PushMsgByRoomArgs, reply *common.Err) (err error) + PushMsgByUser func(ctx context.Context, args *PushMsgByUserArgs, reply *common.Err) (err error) + type PigeonServiceClient struct + func NewPigeonServiceClient(xclient client.XClient) *PigeonServiceClient + func (c *PigeonServiceClient) Broadcast(ctx context.Context, args *BroadcastArgs) (reply *common.Err, err error) + func (c *PigeonServiceClient) PushMsgByClient(ctx context.Context, args *PushMsgByClientArgs) (reply *common.Err, err error) + func (c *PigeonServiceClient) PushMsgByRoom(ctx context.Context, args *PushMsgByRoomArgs) (reply *common.Err, err error) + func (c *PigeonServiceClient) PushMsgByUser(ctx context.Context, args *PushMsgByUserArgs) (reply *common.Err, err error) + type PigeonServiceImpl struct + func (s *PigeonServiceImpl) Broadcast(ctx context.Context, args *BroadcastArgs, reply *common.Err) (err error) + func (s *PigeonServiceImpl) PushMsgByClient(ctx context.Context, args *PushMsgByClientArgs, reply *common.Err) (err error) + func (s *PigeonServiceImpl) PushMsgByRoom(ctx context.Context, args *PushMsgByRoomArgs, reply *common.Err) (err error) + func (s *PigeonServiceImpl) PushMsgByUser(ctx context.Context, args *PushMsgByUserArgs, reply *common.Err) (err error) + type PigeonServiceOneClient struct + func NewPigeonServiceOneClient(oneclient client.OneClient) *PigeonServiceOneClient + func (c *PigeonServiceOneClient) Broadcast(ctx context.Context, args *BroadcastArgs) (reply *common.Err, err error) + func (c *PigeonServiceOneClient) PushMsgByClient(ctx context.Context, args *PushMsgByClientArgs) (reply *common.Err, err error) + func (c *PigeonServiceOneClient) PushMsgByRoom(ctx context.Context, args *PushMsgByRoomArgs) (reply *common.Err, err error) + func (c *PigeonServiceOneClient) PushMsgByUser(ctx context.Context, args *PushMsgByUserArgs) (reply *common.Err, err error) + type Proto struct + Body []byte + DataLen uint32 + Op uint32 + Seq uint32 + Ver uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Proto) Descriptor() ([]byte, []int) + func (*Proto) ProtoMessage() + func (m *Proto) GetBody() []byte + func (m *Proto) GetDataLen() uint32 + func (m *Proto) GetOp() uint32 + func (m *Proto) GetSeq() uint32 + func (m *Proto) GetVer() uint32 + func (m *Proto) Reset() + func (m *Proto) String() string + func (m *Proto) XXX_DiscardUnknown() + func (m *Proto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Proto) XXX_Merge(src proto.Message) + func (m *Proto) XXX_Size() int + func (m *Proto) XXX_Unmarshal(b []byte) error + type PushMsgByClientArgs struct + CId uint64 + Op uint32 + Proto *Proto + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PushMsgByClientArgs) Descriptor() ([]byte, []int) + func (*PushMsgByClientArgs) ProtoMessage() + func (m *PushMsgByClientArgs) GetCId() uint64 + func (m *PushMsgByClientArgs) GetOp() uint32 + func (m *PushMsgByClientArgs) GetProto() *Proto + func (m *PushMsgByClientArgs) Reset() + func (m *PushMsgByClientArgs) String() string + func (m *PushMsgByClientArgs) XXX_DiscardUnknown() + func (m *PushMsgByClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PushMsgByClientArgs) XXX_Merge(src proto.Message) + func (m *PushMsgByClientArgs) XXX_Size() int + func (m *PushMsgByClientArgs) XXX_Unmarshal(b []byte) error + type PushMsgByRoomArgs struct + Op uint32 + Proto *Proto + RId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PushMsgByRoomArgs) Descriptor() ([]byte, []int) + func (*PushMsgByRoomArgs) ProtoMessage() + func (m *PushMsgByRoomArgs) GetOp() uint32 + func (m *PushMsgByRoomArgs) GetProto() *Proto + func (m *PushMsgByRoomArgs) GetRId() int64 + func (m *PushMsgByRoomArgs) Reset() + func (m *PushMsgByRoomArgs) String() string + func (m *PushMsgByRoomArgs) XXX_DiscardUnknown() + func (m *PushMsgByRoomArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PushMsgByRoomArgs) XXX_Merge(src proto.Message) + func (m *PushMsgByRoomArgs) XXX_Size() int + func (m *PushMsgByRoomArgs) XXX_Unmarshal(b []byte) error + type PushMsgByUserArgs struct + Op uint32 + Proto *Proto + UId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PushMsgByUserArgs) Descriptor() ([]byte, []int) + func (*PushMsgByUserArgs) ProtoMessage() + func (m *PushMsgByUserArgs) GetOp() uint32 + func (m *PushMsgByUserArgs) GetProto() *Proto + func (m *PushMsgByUserArgs) GetUId() int64 + func (m *PushMsgByUserArgs) Reset() + func (m *PushMsgByUserArgs) String() string + func (m *PushMsgByUserArgs) XXX_DiscardUnknown() + func (m *PushMsgByUserArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PushMsgByUserArgs) XXX_Merge(src proto.Message) + func (m *PushMsgByUserArgs) XXX_Size() int + func (m *PushMsgByUserArgs) XXX_Unmarshal(b []byte) error + type RoomServiceAble interface + JoinRoom func(ctx context.Context, args *JoinRoomArgs, reply *common.Err) (err error) + type RoomServiceClient struct + func NewRoomServiceClient(xclient client.XClient) *RoomServiceClient + func (c *RoomServiceClient) JoinRoom(ctx context.Context, args *JoinRoomArgs) (reply *common.Err, err error) + type RoomServiceImpl struct + func (s *RoomServiceImpl) JoinRoom(ctx context.Context, args *JoinRoomArgs, reply *common.Err) (err error) + type RoomServiceOneClient struct + func NewRoomServiceOneClient(oneclient client.OneClient) *RoomServiceOneClient + func (c *RoomServiceOneClient) JoinRoom(ctx context.Context, args *JoinRoomArgs) (reply *common.Err, err error) + type RoomType int32 + const RoomType_ChatRoom + const RoomType_LiveRoom + func (RoomType) EnumDescriptor() ([]byte, []int) + func (x RoomType) String() string
Go to main page