pb

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Chat_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pbChat.Chat",
	HandlerType: (*ChatServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMaxAndMinSeq",
			Handler:    _Chat_GetMaxAndMinSeq_Handler,
		},
		{
			MethodName: "GetMinAndMaxGroupSeq",
			Handler:    _Chat_GetMinAndMaxGroupSeq_Handler,
		},
		{
			MethodName: "PullMessageBySeqList",
			Handler:    _Chat_PullMessageBySeqList_Handler,
		},
		{
			MethodName: "PullMessageByGroupSeqList",
			Handler:    _Chat_PullMessageByGroupSeqList_Handler,
		},
		{
			MethodName: "SendMsg",
			Handler:    _Chat_SendMsg_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chat.proto",
}

Chat_ServiceDesc is the grpc.ServiceDesc for Chat 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 File_chat_proto protoreflect.FileDescriptor

Functions

func GetSwitchFromOptions 

func GetSwitchFromOptions(options *MsgOptions, key string, defaultValue bool) (result bool)

func RegisterChatServer 

func RegisterChatServer(s grpc.ServiceRegistrar, srv ChatServer)

func SetSwitchFromOptions 

func SetSwitchFromOptions(options *MsgOptions, key string, value bool)

Types

type ChatClient 

type ChatClient interface {
	GetMaxAndMinSeq(ctx context.Context, in *GetMinAndMaxSeqReq, opts ...grpc.CallOption) (*GetMinAndMaxSeqResp, error)
	GetMinAndMaxGroupSeq(ctx context.Context, in *GetMinAndMaxGroupSeqReq, opts ...grpc.CallOption) (*GetMinAndMaxGroupSeqResp, error)
	PullMessageBySeqList(ctx context.Context, in *PullMsgBySeqListReq, opts ...grpc.CallOption) (*PullMsgListResp, error)
	PullMessageByGroupSeqList(ctx context.Context, in *PullMsgByGroupSeqListReq, opts ...grpc.CallOption) (*PullMsgListResp, error)
	SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error)
}

ChatClient is the client API for Chat 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 NewChatClient 

func NewChatClient(cc grpc.ClientConnInterface) ChatClient

type ChatServer 

type ChatServer interface {
	GetMaxAndMinSeq(context.Context, *GetMinAndMaxSeqReq) (*GetMinAndMaxSeqResp, error)
	GetMinAndMaxGroupSeq(context.Context, *GetMinAndMaxGroupSeqReq) (*GetMinAndMaxGroupSeqResp, error)
	PullMessageBySeqList(context.Context, *PullMsgBySeqListReq) (*PullMsgListResp, error)
	PullMessageByGroupSeqList(context.Context, *PullMsgByGroupSeqListReq) (*PullMsgListResp, error)
	SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
	// contains filtered or unexported methods
}

ChatServer is the server API for Chat service. All implementations must embed UnimplementedChatServer for forward compatibility

type GetMinAndMaxGroupSeqItem 

type GetMinAndMaxGroupSeqItem struct {
	GroupID string `protobuf:"bytes,1,opt,name=groupID,proto3" json:"groupID,omitempty"`
	MinSeq  uint32 `protobuf:"varint,2,opt,name=minSeq,proto3" json:"minSeq,omitempty"`
	MaxSeq  uint32 `protobuf:"varint,3,opt,name=maxSeq,proto3" json:"maxSeq,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMinAndMaxGroupSeqItem) Descriptor deprecated 

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

Deprecated: Use GetMinAndMaxGroupSeqItem.ProtoReflect.Descriptor instead.

func (*GetMinAndMaxGroupSeqItem) GetGroupID 

func (x *GetMinAndMaxGroupSeqItem) GetGroupID() string

func (*GetMinAndMaxGroupSeqItem) GetMaxSeq 

func (x *GetMinAndMaxGroupSeqItem) GetMaxSeq() uint32

func (*GetMinAndMaxGroupSeqItem) GetMinSeq 

func (x *GetMinAndMaxGroupSeqItem) GetMinSeq() uint32

func (*GetMinAndMaxGroupSeqItem) ProtoMessage 

func (*GetMinAndMaxGroupSeqItem) ProtoMessage()

func (*GetMinAndMaxGroupSeqItem) ProtoReflect 

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

func (*GetMinAndMaxGroupSeqItem) Reset 

func (x *GetMinAndMaxGroupSeqItem) Reset()

func (*GetMinAndMaxGroupSeqItem) String 

func (x *GetMinAndMaxGroupSeqItem) String() string

type GetMinAndMaxGroupSeqReq 

type GetMinAndMaxGroupSeqReq struct {
	GroupIDList []string `protobuf:"bytes,1,rep,name=groupIDList,proto3" json:"groupIDList,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMinAndMaxGroupSeqReq) Descriptor deprecated 

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

Deprecated: Use GetMinAndMaxGroupSeqReq.ProtoReflect.Descriptor instead.

func (*GetMinAndMaxGroupSeqReq) GetGroupIDList 

func (x *GetMinAndMaxGroupSeqReq) GetGroupIDList() []string

func (*GetMinAndMaxGroupSeqReq) ProtoMessage 

func (*GetMinAndMaxGroupSeqReq) ProtoMessage()

func (*GetMinAndMaxGroupSeqReq) ProtoReflect 

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

func (*GetMinAndMaxGroupSeqReq) Reset 

func (x *GetMinAndMaxGroupSeqReq) Reset()

func (*GetMinAndMaxGroupSeqReq) String 

func (x *GetMinAndMaxGroupSeqReq) String() string

type GetMinAndMaxGroupSeqResp 

type GetMinAndMaxGroupSeqResp struct {
	GroupSeqList []*GetMinAndMaxGroupSeqItem `protobuf:"bytes,1,rep,name=groupSeqList,proto3" json:"groupSeqList,omitempty"`
	ErrCode      uint32                      `protobuf:"varint,2,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"`
	ErrMsg       string                      `protobuf:"bytes,3,opt,name=ErrMsg,proto3" json:"ErrMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMinAndMaxGroupSeqResp) Descriptor deprecated 

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

Deprecated: Use GetMinAndMaxGroupSeqResp.ProtoReflect.Descriptor instead.

func (*GetMinAndMaxGroupSeqResp) GetErrCode 

func (x *GetMinAndMaxGroupSeqResp) GetErrCode() uint32

func (*GetMinAndMaxGroupSeqResp) GetErrMsg 

func (x *GetMinAndMaxGroupSeqResp) GetErrMsg() string

func (*GetMinAndMaxGroupSeqResp) GetGroupSeqList 

func (x *GetMinAndMaxGroupSeqResp) GetGroupSeqList() []*GetMinAndMaxGroupSeqItem

func (*GetMinAndMaxGroupSeqResp) ProtoMessage 

func (*GetMinAndMaxGroupSeqResp) ProtoMessage()

func (*GetMinAndMaxGroupSeqResp) ProtoReflect 

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

func (*GetMinAndMaxGroupSeqResp) Reset 

func (x *GetMinAndMaxGroupSeqResp) Reset()

func (*GetMinAndMaxGroupSeqResp) String 

func (x *GetMinAndMaxGroupSeqResp) String() string

type GetMinAndMaxSeqReq 

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

func (*GetMinAndMaxSeqReq) Descriptor deprecated 

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

Deprecated: Use GetMinAndMaxSeqReq.ProtoReflect.Descriptor instead.

func (*GetMinAndMaxSeqReq) GetUserID 

func (x *GetMinAndMaxSeqReq) GetUserID() string

func (*GetMinAndMaxSeqReq) ProtoMessage 

func (*GetMinAndMaxSeqReq) ProtoMessage()

func (*GetMinAndMaxSeqReq) ProtoReflect 

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

func (*GetMinAndMaxSeqReq) Reset 

func (x *GetMinAndMaxSeqReq) Reset()

func (*GetMinAndMaxSeqReq) String 

func (x *GetMinAndMaxSeqReq) String() string

type GetMinAndMaxSeqResp 

type GetMinAndMaxSeqResp struct {
	MinSeq  uint32 `protobuf:"varint,1,opt,name=MinSeq,proto3" json:"MinSeq,omitempty"`
	MaxSeq  uint32 `protobuf:"varint,2,opt,name=MaxSeq,proto3" json:"MaxSeq,omitempty"`
	ErrCode uint32 `protobuf:"varint,3,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"`
	ErrMsg  string `protobuf:"bytes,4,opt,name=ErrMsg,proto3" json:"ErrMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMinAndMaxSeqResp) Descriptor deprecated 

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

Deprecated: Use GetMinAndMaxSeqResp.ProtoReflect.Descriptor instead.

func (*GetMinAndMaxSeqResp) GetErrCode 

func (x *GetMinAndMaxSeqResp) GetErrCode() uint32

func (*GetMinAndMaxSeqResp) GetErrMsg 

func (x *GetMinAndMaxSeqResp) GetErrMsg() string

func (*GetMinAndMaxSeqResp) GetMaxSeq 

func (x *GetMinAndMaxSeqResp) GetMaxSeq() uint32

func (*GetMinAndMaxSeqResp) GetMinSeq 

func (x *GetMinAndMaxSeqResp) GetMinSeq() uint32

func (*GetMinAndMaxSeqResp) ProtoMessage 

func (*GetMinAndMaxSeqResp) ProtoMessage()

func (*GetMinAndMaxSeqResp) ProtoReflect 

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

func (*GetMinAndMaxSeqResp) Reset 

func (x *GetMinAndMaxSeqResp) Reset()

func (*GetMinAndMaxSeqResp) String 

func (x *GetMinAndMaxSeqResp) String() string

type MsgData 

type MsgData struct {
	ClientMsgID      string       `protobuf:"bytes,1,opt,name=clientMsgID,proto3" json:"clientMsgID,omitempty"`
	ServerMsgID      string       `protobuf:"bytes,2,opt,name=serverMsgID,proto3" json:"serverMsgID,omitempty"`
	ConversationType uint32       `protobuf:"varint,3,opt,name=conversationType,proto3" json:"conversationType,omitempty"`
	SendID           string       `protobuf:"bytes,4,opt,name=sendID,proto3" json:"sendID,omitempty"`
	ReceiveID        string       `protobuf:"bytes,5,opt,name=receiveID,proto3" json:"receiveID,omitempty"`
	ContentType      uint32       `protobuf:"varint,6,opt,name=contentType,proto3" json:"contentType,omitempty"`
	Content          []byte       `protobuf:"bytes,7,opt,name=content,proto3" json:"content,omitempty"`
	AtUserIDList     []string     `protobuf:"bytes,8,rep,name=atUserIDList,proto3" json:"atUserIDList,omitempty"`
	ClientTime       int64        `protobuf:"varint,9,opt,name=clientTime,proto3" json:"clientTime,omitempty"`
	ServerTime       int64        `protobuf:"varint,10,opt,name=serverTime,proto3" json:"serverTime,omitempty"`
	Seq              uint32       `protobuf:"varint,11,opt,name=seq,proto3" json:"seq,omitempty"`
	OfflinePush      *OfflinePush `protobuf:"bytes,12,opt,name=offlinePush,proto3" json:"offlinePush,omitempty"`
	MsgOptions       *MsgOptions  `protobuf:"bytes,13,opt,name=msgOptions,proto3" json:"msgOptions,omitempty"`
	// contains filtered or unexported fields
}

func (*MsgData) Bytes 

func (x *MsgData) Bytes() []byte

func (*MsgData) Descriptor deprecated 

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

Deprecated: Use MsgData.ProtoReflect.Descriptor instead.

func (*MsgData) GetAtUserIDList 

func (x *MsgData) GetAtUserIDList() []string

func (*MsgData) GetClientMsgID 

func (x *MsgData) GetClientMsgID() string

func (*MsgData) GetClientTime 

func (x *MsgData) GetClientTime() int64

func (*MsgData) GetContent 

func (x *MsgData) GetContent() []byte

func (*MsgData) GetContentType 

func (x *MsgData) GetContentType() uint32

func (*MsgData) GetConversationType 

func (x *MsgData) GetConversationType() uint32

func (*MsgData) GetMsgOptions 

func (x *MsgData) GetMsgOptions() *MsgOptions

func (*MsgData) GetOfflinePush 

func (x *MsgData) GetOfflinePush() *OfflinePush

func (*MsgData) GetReceiveID 

func (x *MsgData) GetReceiveID() string

func (*MsgData) GetSendID 

func (x *MsgData) GetSendID() string

func (*MsgData) GetSeq 

func (x *MsgData) GetSeq() uint32

func (*MsgData) GetServerMsgID 

func (x *MsgData) GetServerMsgID() string

func (*MsgData) GetServerTime 

func (x *MsgData) GetServerTime() int64

func (*MsgData) ProtoMessage 

func (*MsgData) ProtoMessage()

func (*MsgData) ProtoReflect 

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

func (*MsgData) Reset 

func (x *MsgData) Reset()

func (*MsgData) String 

func (x *MsgData) String() string

type MsgDataToDB 

type MsgDataToDB struct {
	TraceId string   `protobuf:"bytes,1,opt,name=traceId,proto3" json:"traceId,omitempty"`
	MsgData *MsgData `protobuf:"bytes,2,opt,name=msgData,proto3" json:"msgData,omitempty"`
	// contains filtered or unexported fields
}

func (*MsgDataToDB) Descriptor deprecated 

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

Deprecated: Use MsgDataToDB.ProtoReflect.Descriptor instead.

func (*MsgDataToDB) GetMsgData 

func (x *MsgDataToDB) GetMsgData() *MsgData

func (*MsgDataToDB) GetTraceId 

func (x *MsgDataToDB) GetTraceId() string

func (*MsgDataToDB) ProtoMessage 

func (*MsgDataToDB) ProtoMessage()

func (*MsgDataToDB) ProtoReflect 

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

func (*MsgDataToDB) Reset 

func (x *MsgDataToDB) Reset()

func (*MsgDataToDB) String 

func (x *MsgDataToDB) String() string

type MsgDataToMQ 

type MsgDataToMQ struct {
	TraceId string   `protobuf:"bytes,1,opt,name=traceId,proto3" json:"traceId,omitempty"`
	MsgData *MsgData `protobuf:"bytes,2,opt,name=msgData,proto3" json:"msgData,omitempty"`
	// contains filtered or unexported fields
}

func (*MsgDataToMQ) Descriptor deprecated 

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

Deprecated: Use MsgDataToMQ.ProtoReflect.Descriptor instead.

func (*MsgDataToMQ) GetMsgData 

func (x *MsgDataToMQ) GetMsgData() *MsgData

func (*MsgDataToMQ) GetTraceId 

func (x *MsgDataToMQ) GetTraceId() string

func (*MsgDataToMQ) ProtoMessage 

func (*MsgDataToMQ) ProtoMessage()

func (*MsgDataToMQ) ProtoReflect 

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

func (*MsgDataToMQ) Reset 

func (x *MsgDataToMQ) Reset()

func (*MsgDataToMQ) String 

func (x *MsgDataToMQ) String() string

type MsgOptions 

type MsgOptions struct {
	Persistent         bool `protobuf:"varint,1,opt,name=persistent,proto3" json:"persistent,omitempty"`
	History            bool `protobuf:"varint,2,opt,name=history,proto3" json:"history,omitempty"`
	Local              bool `protobuf:"varint,3,opt,name=local,proto3" json:"local,omitempty"`
	UpdateUnreadCount  bool `protobuf:"varint,4,opt,name=updateUnreadCount,proto3" json:"updateUnreadCount,omitempty"`
	UpdateConversation bool `protobuf:"varint,5,opt,name=updateConversation,proto3" json:"updateConversation,omitempty"`
	// server端控制
	NeedBeFriend bool `protobuf:"varint,6,opt,name=needBeFriend,proto3" json:"needBeFriend,omitempty"`
	OfflinePush  bool `protobuf:"varint,7,opt,name=offlinePush,proto3" json:"offlinePush,omitempty"`
	SenderSync   bool `protobuf:"varint,8,opt,name=senderSync,proto3" json:"senderSync,omitempty"`
	// contains filtered or unexported fields
}

func (*MsgOptions) Descriptor deprecated 

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

Deprecated: Use MsgOptions.ProtoReflect.Descriptor instead.

func (*MsgOptions) GetHistory 

func (x *MsgOptions) GetHistory() bool

func (*MsgOptions) GetLocal 

func (x *MsgOptions) GetLocal() bool

func (*MsgOptions) GetNeedBeFriend 

func (x *MsgOptions) GetNeedBeFriend() bool

func (*MsgOptions) GetOfflinePush 

func (x *MsgOptions) GetOfflinePush() bool

func (*MsgOptions) GetPersistent 

func (x *MsgOptions) GetPersistent() bool

func (*MsgOptions) GetSenderSync 

func (x *MsgOptions) GetSenderSync() bool

func (*MsgOptions) GetUpdateConversation 

func (x *MsgOptions) GetUpdateConversation() bool

func (*MsgOptions) GetUpdateUnreadCount 

func (x *MsgOptions) GetUpdateUnreadCount() bool

func (*MsgOptions) ProtoMessage 

func (*MsgOptions) ProtoMessage()

func (*MsgOptions) ProtoReflect 

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

func (*MsgOptions) Reset 

func (x *MsgOptions) Reset()

func (*MsgOptions) String 

func (x *MsgOptions) String() string

type OfflinePush 

type OfflinePush struct {
	Title         string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Desc          string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	Ex            string `protobuf:"bytes,3,opt,name=ex,proto3" json:"ex,omitempty"`
	IOSPushSound  string `protobuf:"bytes,4,opt,name=iOSPushSound,proto3" json:"iOSPushSound,omitempty"`
	IOSBadgeCount bool   `protobuf:"varint,5,opt,name=iOSBadgeCount,proto3" json:"iOSBadgeCount,omitempty"`
	// contains filtered or unexported fields
}

func (*OfflinePush) Descriptor deprecated 

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

Deprecated: Use OfflinePush.ProtoReflect.Descriptor instead.

func (*OfflinePush) GetDesc 

func (x *OfflinePush) GetDesc() string

func (*OfflinePush) GetEx 

func (x *OfflinePush) GetEx() string

func (*OfflinePush) GetIOSBadgeCount 

func (x *OfflinePush) GetIOSBadgeCount() bool

func (*OfflinePush) GetIOSPushSound 

func (x *OfflinePush) GetIOSPushSound() string

func (*OfflinePush) GetTitle 

func (x *OfflinePush) GetTitle() string

func (*OfflinePush) ProtoMessage 

func (*OfflinePush) ProtoMessage()

func (*OfflinePush) ProtoReflect 

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

func (*OfflinePush) Reset 

func (x *OfflinePush) Reset()

func (*OfflinePush) String 

func (x *OfflinePush) String() string

type PullMsgByGroupSeqListReq 

type PullMsgByGroupSeqListReq struct {
	GroupID string   `protobuf:"bytes,1,opt,name=groupID,proto3" json:"groupID,omitempty"`
	SeqList []uint32 `protobuf:"varint,2,rep,packed,name=seqList,proto3" json:"seqList,omitempty"`
	// contains filtered or unexported fields
}

func (*PullMsgByGroupSeqListReq) Descriptor deprecated 

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

Deprecated: Use PullMsgByGroupSeqListReq.ProtoReflect.Descriptor instead.

func (*PullMsgByGroupSeqListReq) GetGroupID 

func (x *PullMsgByGroupSeqListReq) GetGroupID() string

func (*PullMsgByGroupSeqListReq) GetSeqList 

func (x *PullMsgByGroupSeqListReq) GetSeqList() []uint32

func (*PullMsgByGroupSeqListReq) ProtoMessage 

func (*PullMsgByGroupSeqListReq) ProtoMessage()

func (*PullMsgByGroupSeqListReq) ProtoReflect 

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

func (*PullMsgByGroupSeqListReq) Reset 

func (x *PullMsgByGroupSeqListReq) Reset()

func (*PullMsgByGroupSeqListReq) String 

func (x *PullMsgByGroupSeqListReq) String() string

type PullMsgBySeqListReq 

type PullMsgBySeqListReq struct {
	SeqList []uint32 `protobuf:"varint,1,rep,packed,name=seqList,proto3" json:"seqList,omitempty"`
	UserID  string   `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID,omitempty"`
	// contains filtered or unexported fields
}

func (*PullMsgBySeqListReq) Descriptor deprecated 

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

Deprecated: Use PullMsgBySeqListReq.ProtoReflect.Descriptor instead.

func (*PullMsgBySeqListReq) GetSeqList 

func (x *PullMsgBySeqListReq) GetSeqList() []uint32

func (*PullMsgBySeqListReq) GetUserID 

func (x *PullMsgBySeqListReq) GetUserID() string

func (*PullMsgBySeqListReq) ProtoMessage 

func (*PullMsgBySeqListReq) ProtoMessage()

func (*PullMsgBySeqListReq) ProtoReflect 

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

func (*PullMsgBySeqListReq) Reset 

func (x *PullMsgBySeqListReq) Reset()

func (*PullMsgBySeqListReq) String 

func (x *PullMsgBySeqListReq) String() string

type PullMsgListResp 

type PullMsgListResp struct {
	List    []*MsgData `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	ErrCode int32      `protobuf:"varint,2,opt,name=errCode,proto3" json:"errCode,omitempty"`
	ErrMsg  string     `protobuf:"bytes,3,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*PullMsgListResp) Descriptor deprecated 

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

Deprecated: Use PullMsgListResp.ProtoReflect.Descriptor instead.

func (*PullMsgListResp) GetErrCode 

func (x *PullMsgListResp) GetErrCode() int32

func (*PullMsgListResp) GetErrMsg 

func (x *PullMsgListResp) GetErrMsg() string

func (*PullMsgListResp) GetList 

func (x *PullMsgListResp) GetList() []*MsgData

func (*PullMsgListResp) ProtoMessage 

func (*PullMsgListResp) ProtoMessage()

func (*PullMsgListResp) ProtoReflect 

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

func (*PullMsgListResp) Reset 

func (x *PullMsgListResp) Reset()

func (*PullMsgListResp) String 

func (x *PullMsgListResp) String() string

type PushMsgDataToMQ 

type PushMsgDataToMQ struct {
	TraceId      string   `protobuf:"bytes,1,opt,name=traceId,proto3" json:"traceId,omitempty"`
	MsgData      *MsgData `protobuf:"bytes,2,opt,name=msgData,proto3" json:"msgData,omitempty"`
	PushToUserID []string `protobuf:"bytes,3,rep,name=pushToUserID,proto3" json:"pushToUserID,omitempty"`
	// contains filtered or unexported fields
}

func (*PushMsgDataToMQ) Descriptor deprecated 

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

Deprecated: Use PushMsgDataToMQ.ProtoReflect.Descriptor instead.

func (*PushMsgDataToMQ) GetMsgData 

func (x *PushMsgDataToMQ) GetMsgData() *MsgData

func (*PushMsgDataToMQ) GetPushToUserID 

func (x *PushMsgDataToMQ) GetPushToUserID() []string

func (*PushMsgDataToMQ) GetTraceId 

func (x *PushMsgDataToMQ) GetTraceId() string

func (*PushMsgDataToMQ) ProtoMessage 

func (*PushMsgDataToMQ) ProtoMessage()

func (*PushMsgDataToMQ) ProtoReflect 

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

func (*PushMsgDataToMQ) Reset 

func (x *PushMsgDataToMQ) Reset()

func (*PushMsgDataToMQ) String 

func (x *PushMsgDataToMQ) String() string

type SendMsgReq 

type SendMsgReq struct {
	MsgData *MsgData `protobuf:"bytes,1,opt,name=msgData,proto3" json:"msgData,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMsgReq) Descriptor deprecated 

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

Deprecated: Use SendMsgReq.ProtoReflect.Descriptor instead.

func (*SendMsgReq) GetMsgData 

func (x *SendMsgReq) GetMsgData() *MsgData

func (*SendMsgReq) ProtoMessage 

func (*SendMsgReq) ProtoMessage()

func (*SendMsgReq) ProtoReflect 

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

func (*SendMsgReq) Reset 

func (x *SendMsgReq) Reset()

func (*SendMsgReq) String 

func (x *SendMsgReq) String() string

type SendMsgResp 

type SendMsgResp struct {
	ClientMsgID      string `protobuf:"bytes,1,opt,name=clientMsgID,proto3" json:"clientMsgID,omitempty"`
	ServerMsgID      string `protobuf:"bytes,2,opt,name=serverMsgID,proto3" json:"serverMsgID,omitempty"`
	ConversationType uint32 `protobuf:"varint,3,opt,name=conversationType,proto3" json:"conversationType,omitempty"`
	ReceiveID        string `protobuf:"bytes,4,opt,name=receiveID,proto3" json:"receiveID,omitempty"`
	ContentType      uint32 `protobuf:"varint,5,opt,name=contentType,proto3" json:"contentType,omitempty"`
	ServerTime       int64  `protobuf:"varint,6,opt,name=serverTime,proto3" json:"serverTime,omitempty"`
	ErrCode          int32  `protobuf:"varint,7,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"`
	ErrMsg           string `protobuf:"bytes,8,opt,name=ErrMsg,proto3" json:"ErrMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMsgResp) Descriptor deprecated 

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

Deprecated: Use SendMsgResp.ProtoReflect.Descriptor instead.

func (*SendMsgResp) GetClientMsgID 

func (x *SendMsgResp) GetClientMsgID() string

func (*SendMsgResp) GetContentType 

func (x *SendMsgResp) GetContentType() uint32

func (*SendMsgResp) GetConversationType 

func (x *SendMsgResp) GetConversationType() uint32

func (*SendMsgResp) GetErrCode 

func (x *SendMsgResp) GetErrCode() int32

func (*SendMsgResp) GetErrMsg 

func (x *SendMsgResp) GetErrMsg() string

func (*SendMsgResp) GetReceiveID 

func (x *SendMsgResp) GetReceiveID() string

func (*SendMsgResp) GetServerMsgID 

func (x *SendMsgResp) GetServerMsgID() string

func (*SendMsgResp) GetServerTime 

func (x *SendMsgResp) GetServerTime() int64

func (*SendMsgResp) ProtoMessage 

func (*SendMsgResp) ProtoMessage()

func (*SendMsgResp) ProtoReflect 

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

func (*SendMsgResp) Reset 

func (x *SendMsgResp) Reset()

func (*SendMsgResp) String 

func (x *SendMsgResp) String() string

type UnimplementedChatServer 

type UnimplementedChatServer struct {
}

UnimplementedChatServer must be embedded to have forward compatible implementations.

func (UnimplementedChatServer) GetMaxAndMinSeq 

func (UnimplementedChatServer) GetMaxAndMinSeq(context.Context, *GetMinAndMaxSeqReq) (*GetMinAndMaxSeqResp, error)

func (UnimplementedChatServer) GetMinAndMaxGroupSeq 

func (UnimplementedChatServer) GetMinAndMaxGroupSeq(context.Context, *GetMinAndMaxGroupSeqReq) (*GetMinAndMaxGroupSeqResp, error)

func (UnimplementedChatServer) PullMessageByGroupSeqList 

func (UnimplementedChatServer) PullMessageByGroupSeqList(context.Context, *PullMsgByGroupSeqListReq) (*PullMsgListResp, error)

func (UnimplementedChatServer) PullMessageBySeqList 

func (UnimplementedChatServer) PullMessageBySeqList(context.Context, *PullMsgBySeqListReq) (*PullMsgListResp, error)

func (UnimplementedChatServer) SendMsg 

func (UnimplementedChatServer) SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)

type UnsafeChatServer 

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

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

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.