Documentation ¶
Index ¶
- Variables
- func RegisterHistoryMessageServiceServer(s grpc.ServiceRegistrar, srv HistoryMessageServiceServer)
- func RegisterOfflineMessageServiceServer(s grpc.ServiceRegistrar, srv OfflineMessageServiceServer)
- func RegisterPushMessageServiceServer(s grpc.ServiceRegistrar, srv PushMessageServiceServer)
- type ConfirmLastMsgIDReq
- func (*ConfirmLastMsgIDReq) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmLastMsgIDReq) GetLastMsgId() int64
- func (x *ConfirmLastMsgIDReq) GetUid() int64
- func (*ConfirmLastMsgIDReq) ProtoMessage()
- func (x *ConfirmLastMsgIDReq) ProtoReflect() protoreflect.Message
- func (x *ConfirmLastMsgIDReq) Reset()
- func (x *ConfirmLastMsgIDReq) String() string
- func (m *ConfirmLastMsgIDReq) Validate() error
- func (m *ConfirmLastMsgIDReq) ValidateAll() error
- type ConfirmLastMsgIDReqMultiError
- type ConfirmLastMsgIDReqValidationError
- func (e ConfirmLastMsgIDReqValidationError) Cause() error
- func (e ConfirmLastMsgIDReqValidationError) Error() string
- func (e ConfirmLastMsgIDReqValidationError) ErrorName() string
- func (e ConfirmLastMsgIDReqValidationError) Field() string
- func (e ConfirmLastMsgIDReqValidationError) Key() bool
- func (e ConfirmLastMsgIDReqValidationError) Reason() string
- type ConfirmLastMsgIDResp
- func (*ConfirmLastMsgIDResp) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmLastMsgIDResp) GetError() *errors.Error
- func (x *ConfirmLastMsgIDResp) GetLastMsgId() int64
- func (*ConfirmLastMsgIDResp) ProtoMessage()
- func (x *ConfirmLastMsgIDResp) ProtoReflect() protoreflect.Message
- func (x *ConfirmLastMsgIDResp) Reset()
- func (x *ConfirmLastMsgIDResp) String() string
- func (m *ConfirmLastMsgIDResp) Validate() error
- func (m *ConfirmLastMsgIDResp) ValidateAll() error
- type ConfirmLastMsgIDRespMultiError
- type ConfirmLastMsgIDRespValidationError
- func (e ConfirmLastMsgIDRespValidationError) Cause() error
- func (e ConfirmLastMsgIDRespValidationError) Error() string
- func (e ConfirmLastMsgIDRespValidationError) ErrorName() string
- func (e ConfirmLastMsgIDRespValidationError) Field() string
- func (e ConfirmLastMsgIDRespValidationError) Key() bool
- func (e ConfirmLastMsgIDRespValidationError) Reason() string
- type HistoryMessageServiceClient
- type HistoryMessageServiceServer
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetContent() string
- func (x *Message) GetContentType() MessageContentType
- func (x *Message) GetCreateTime() int64
- func (x *Message) GetFrom() int64
- func (x *Message) GetMsgId() int64
- func (x *Message) GetSessionId() string
- func (x *Message) GetSessionType() SessionType
- func (x *Message) GetTo() int64
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- func (m *Message) Validate() error
- func (m *Message) ValidateAll() error
- type MessageContentType
- func (MessageContentType) Descriptor() protoreflect.EnumDescriptor
- func (x MessageContentType) Enum() *MessageContentType
- func (MessageContentType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageContentType) Number() protoreflect.EnumNumber
- func (x MessageContentType) String() string
- func (MessageContentType) Type() protoreflect.EnumType
- type MessageMultiError
- type MessageValidationError
- type OfflineMessageServiceClient
- type OfflineMessageServiceServer
- type PushMessageReq
- func (*PushMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *PushMessageReq) GetMessage() *Message
- func (x *PushMessageReq) GetToUsers() []int64
- func (*PushMessageReq) ProtoMessage()
- func (x *PushMessageReq) ProtoReflect() protoreflect.Message
- func (x *PushMessageReq) Reset()
- func (x *PushMessageReq) String() string
- func (m *PushMessageReq) Validate() error
- func (m *PushMessageReq) ValidateAll() error
- type PushMessageReqMultiError
- type PushMessageReqValidationError
- func (e PushMessageReqValidationError) Cause() error
- func (e PushMessageReqValidationError) Error() string
- func (e PushMessageReqValidationError) ErrorName() string
- func (e PushMessageReqValidationError) Field() string
- func (e PushMessageReqValidationError) Key() bool
- func (e PushMessageReqValidationError) Reason() string
- type PushMessageResp
- func (*PushMessageResp) Descriptor() ([]byte, []int)deprecated
- func (x *PushMessageResp) GetError() *errors.Error
- func (x *PushMessageResp) GetFailedUsers() []int64
- func (*PushMessageResp) ProtoMessage()
- func (x *PushMessageResp) ProtoReflect() protoreflect.Message
- func (x *PushMessageResp) Reset()
- func (x *PushMessageResp) String() string
- func (m *PushMessageResp) Validate() error
- func (m *PushMessageResp) ValidateAll() error
- type PushMessageRespMultiError
- type PushMessageRespValidationError
- func (e PushMessageRespValidationError) Cause() error
- func (e PushMessageRespValidationError) Error() string
- func (e PushMessageRespValidationError) ErrorName() string
- func (e PushMessageRespValidationError) Field() string
- func (e PushMessageRespValidationError) Key() bool
- func (e PushMessageRespValidationError) Reason() string
- type PushMessageServiceClient
- type PushMessageServiceServer
- type QueryOfflineMessageReq
- func (*QueryOfflineMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *QueryOfflineMessageReq) GetLastMsgId() int64
- func (x *QueryOfflineMessageReq) GetOnlyCount() bool
- func (x *QueryOfflineMessageReq) GetPage() int32
- func (x *QueryOfflineMessageReq) GetPageSize() int32
- func (x *QueryOfflineMessageReq) GetUid() int64
- func (*QueryOfflineMessageReq) ProtoMessage()
- func (x *QueryOfflineMessageReq) ProtoReflect() protoreflect.Message
- func (x *QueryOfflineMessageReq) Reset()
- func (x *QueryOfflineMessageReq) String() string
- func (m *QueryOfflineMessageReq) Validate() error
- func (m *QueryOfflineMessageReq) ValidateAll() error
- type QueryOfflineMessageReqMultiError
- type QueryOfflineMessageReqValidationError
- func (e QueryOfflineMessageReqValidationError) Cause() error
- func (e QueryOfflineMessageReqValidationError) Error() string
- func (e QueryOfflineMessageReqValidationError) ErrorName() string
- func (e QueryOfflineMessageReqValidationError) Field() string
- func (e QueryOfflineMessageReqValidationError) Key() bool
- func (e QueryOfflineMessageReqValidationError) Reason() string
- type QueryOfflineMessageResp
- func (*QueryOfflineMessageResp) Descriptor() ([]byte, []int)deprecated
- func (x *QueryOfflineMessageResp) GetError() *errors.Error
- func (x *QueryOfflineMessageResp) GetMessages() []*Message
- func (x *QueryOfflineMessageResp) GetTotal() int32
- func (*QueryOfflineMessageResp) ProtoMessage()
- func (x *QueryOfflineMessageResp) ProtoReflect() protoreflect.Message
- func (x *QueryOfflineMessageResp) Reset()
- func (x *QueryOfflineMessageResp) String() string
- func (m *QueryOfflineMessageResp) Validate() error
- func (m *QueryOfflineMessageResp) ValidateAll() error
- type QueryOfflineMessageRespMultiError
- type QueryOfflineMessageRespValidationError
- func (e QueryOfflineMessageRespValidationError) Cause() error
- func (e QueryOfflineMessageRespValidationError) Error() string
- func (e QueryOfflineMessageRespValidationError) ErrorName() string
- func (e QueryOfflineMessageRespValidationError) Field() string
- func (e QueryOfflineMessageRespValidationError) Key() bool
- func (e QueryOfflineMessageRespValidationError) Reason() string
- type QuerySessionHistoryMessageReq
- func (*QuerySessionHistoryMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *QuerySessionHistoryMessageReq) GetLastMsgId() int64
- func (x *QuerySessionHistoryMessageReq) GetPage() int32
- func (x *QuerySessionHistoryMessageReq) GetPageSize() int32
- func (x *QuerySessionHistoryMessageReq) GetSessionId() string
- func (x *QuerySessionHistoryMessageReq) GetUid() int64
- func (*QuerySessionHistoryMessageReq) ProtoMessage()
- func (x *QuerySessionHistoryMessageReq) ProtoReflect() protoreflect.Message
- func (x *QuerySessionHistoryMessageReq) Reset()
- func (x *QuerySessionHistoryMessageReq) String() string
- func (m *QuerySessionHistoryMessageReq) Validate() error
- func (m *QuerySessionHistoryMessageReq) ValidateAll() error
- type QuerySessionHistoryMessageReqMultiError
- type QuerySessionHistoryMessageReqValidationError
- func (e QuerySessionHistoryMessageReqValidationError) Cause() error
- func (e QuerySessionHistoryMessageReqValidationError) Error() string
- func (e QuerySessionHistoryMessageReqValidationError) ErrorName() string
- func (e QuerySessionHistoryMessageReqValidationError) Field() string
- func (e QuerySessionHistoryMessageReqValidationError) Key() bool
- func (e QuerySessionHistoryMessageReqValidationError) Reason() string
- type QuerySessionHistoryMessageResp
- func (*QuerySessionHistoryMessageResp) Descriptor() ([]byte, []int)deprecated
- func (x *QuerySessionHistoryMessageResp) GetError() *errors.Error
- func (x *QuerySessionHistoryMessageResp) GetMessages() []*Message
- func (x *QuerySessionHistoryMessageResp) GetTotal() int32
- func (*QuerySessionHistoryMessageResp) ProtoMessage()
- func (x *QuerySessionHistoryMessageResp) ProtoReflect() protoreflect.Message
- func (x *QuerySessionHistoryMessageResp) Reset()
- func (x *QuerySessionHistoryMessageResp) String() string
- func (m *QuerySessionHistoryMessageResp) Validate() error
- func (m *QuerySessionHistoryMessageResp) ValidateAll() error
- type QuerySessionHistoryMessageRespMultiError
- type QuerySessionHistoryMessageRespValidationError
- func (e QuerySessionHistoryMessageRespValidationError) Cause() error
- func (e QuerySessionHistoryMessageRespValidationError) Error() string
- func (e QuerySessionHistoryMessageRespValidationError) ErrorName() string
- func (e QuerySessionHistoryMessageRespValidationError) Field() string
- func (e QuerySessionHistoryMessageRespValidationError) Key() bool
- func (e QuerySessionHistoryMessageRespValidationError) Reason() string
- type SendMessageReq
- func (*SendMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageReq) GetContent() string
- func (x *SendMessageReq) GetContentType() MessageContentType
- func (x *SendMessageReq) GetFrom() int64
- func (x *SendMessageReq) GetSessionId() string
- func (x *SendMessageReq) GetSessionType() SessionType
- func (x *SendMessageReq) GetTo() int64
- func (*SendMessageReq) ProtoMessage()
- func (x *SendMessageReq) ProtoReflect() protoreflect.Message
- func (x *SendMessageReq) Reset()
- func (x *SendMessageReq) String() string
- func (m *SendMessageReq) Validate() error
- func (m *SendMessageReq) ValidateAll() error
- type SendMessageReqMultiError
- type SendMessageReqValidationError
- func (e SendMessageReqValidationError) Cause() error
- func (e SendMessageReqValidationError) Error() string
- func (e SendMessageReqValidationError) ErrorName() string
- func (e SendMessageReqValidationError) Field() string
- func (e SendMessageReqValidationError) Key() bool
- func (e SendMessageReqValidationError) Reason() string
- type SessionType
- func (SessionType) Descriptor() protoreflect.EnumDescriptor
- func (x SessionType) Enum() *SessionType
- func (SessionType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SessionType) Number() protoreflect.EnumNumber
- func (x SessionType) String() string
- func (SessionType) Type() protoreflect.EnumType
- type StorageMessage
- func (*StorageMessage) Descriptor() ([]byte, []int)deprecated
- func (x *StorageMessage) GetContent() *StorageMessage_Content
- func (x *StorageMessage) GetExtra() *StorageMessage_Extra
- func (x *StorageMessage) GetRowKey() string
- func (x *StorageMessage) GetUsers() *StorageMessage_Users
- func (x *StorageMessage) HbaseRowKey() string
- func (x *StorageMessage) HbaseValues() map[string]map[string][]byte
- func (*StorageMessage) ProtoMessage()
- func (x *StorageMessage) ProtoReflect() protoreflect.Message
- func (x *StorageMessage) Reset()
- func (x *StorageMessage) String() string
- func (x *StorageMessage) TableName() string
- func (m *StorageMessage) Validate() error
- func (m *StorageMessage) ValidateAll() error
- type StorageMessageMultiError
- type StorageMessageValidationError
- func (e StorageMessageValidationError) Cause() error
- func (e StorageMessageValidationError) Error() string
- func (e StorageMessageValidationError) ErrorName() string
- func (e StorageMessageValidationError) Field() string
- func (e StorageMessageValidationError) Key() bool
- func (e StorageMessageValidationError) Reason() string
- type StorageMessage_Content
- func (*StorageMessage_Content) Descriptor() ([]byte, []int)deprecated
- func (x *StorageMessage_Content) GetContent() string
- func (x *StorageMessage_Content) GetContentType() MessageContentType
- func (*StorageMessage_Content) ProtoMessage()
- func (x *StorageMessage_Content) ProtoReflect() protoreflect.Message
- func (x *StorageMessage_Content) Reset()
- func (x *StorageMessage_Content) String() string
- func (m *StorageMessage_Content) Validate() error
- func (m *StorageMessage_Content) ValidateAll() error
- type StorageMessage_ContentMultiError
- type StorageMessage_ContentValidationError
- func (e StorageMessage_ContentValidationError) Cause() error
- func (e StorageMessage_ContentValidationError) Error() string
- func (e StorageMessage_ContentValidationError) ErrorName() string
- func (e StorageMessage_ContentValidationError) Field() string
- func (e StorageMessage_ContentValidationError) Key() bool
- func (e StorageMessage_ContentValidationError) Reason() string
- type StorageMessage_Extra
- func (*StorageMessage_Extra) Descriptor() ([]byte, []int)deprecated
- func (x *StorageMessage_Extra) GetCreateTime() *timestamppb.Timestamp
- func (*StorageMessage_Extra) ProtoMessage()
- func (x *StorageMessage_Extra) ProtoReflect() protoreflect.Message
- func (x *StorageMessage_Extra) Reset()
- func (x *StorageMessage_Extra) String() string
- func (m *StorageMessage_Extra) Validate() error
- func (m *StorageMessage_Extra) ValidateAll() error
- type StorageMessage_ExtraMultiError
- type StorageMessage_ExtraValidationError
- func (e StorageMessage_ExtraValidationError) Cause() error
- func (e StorageMessage_ExtraValidationError) Error() string
- func (e StorageMessage_ExtraValidationError) ErrorName() string
- func (e StorageMessage_ExtraValidationError) Field() string
- func (e StorageMessage_ExtraValidationError) Key() bool
- func (e StorageMessage_ExtraValidationError) Reason() string
- type StorageMessage_Users
- func (*StorageMessage_Users) Descriptor() ([]byte, []int)deprecated
- func (x *StorageMessage_Users) GetFromID() int64
- func (x *StorageMessage_Users) GetSessionID() string
- func (x *StorageMessage_Users) GetToID() int64
- func (*StorageMessage_Users) ProtoMessage()
- func (x *StorageMessage_Users) ProtoReflect() protoreflect.Message
- func (x *StorageMessage_Users) Reset()
- func (x *StorageMessage_Users) String() string
- func (m *StorageMessage_Users) Validate() error
- func (m *StorageMessage_Users) ValidateAll() error
- type StorageMessage_UsersMultiError
- type StorageMessage_UsersValidationError
- func (e StorageMessage_UsersValidationError) Cause() error
- func (e StorageMessage_UsersValidationError) Error() string
- func (e StorageMessage_UsersValidationError) ErrorName() string
- func (e StorageMessage_UsersValidationError) Field() string
- func (e StorageMessage_UsersValidationError) Key() bool
- func (e StorageMessage_UsersValidationError) Reason() string
- type SyncHistoryMessageReq
- func (*SyncHistoryMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *SyncHistoryMessageReq) GetLastMsgId() int64
- func (x *SyncHistoryMessageReq) GetPage() int32
- func (x *SyncHistoryMessageReq) GetPageSize() int32
- func (x *SyncHistoryMessageReq) GetUid() int64
- func (*SyncHistoryMessageReq) ProtoMessage()
- func (x *SyncHistoryMessageReq) ProtoReflect() protoreflect.Message
- func (x *SyncHistoryMessageReq) Reset()
- func (x *SyncHistoryMessageReq) String() string
- func (m *SyncHistoryMessageReq) Validate() error
- func (m *SyncHistoryMessageReq) ValidateAll() error
- type SyncHistoryMessageReqMultiError
- type SyncHistoryMessageReqValidationError
- func (e SyncHistoryMessageReqValidationError) Cause() error
- func (e SyncHistoryMessageReqValidationError) Error() string
- func (e SyncHistoryMessageReqValidationError) ErrorName() string
- func (e SyncHistoryMessageReqValidationError) Field() string
- func (e SyncHistoryMessageReqValidationError) Key() bool
- func (e SyncHistoryMessageReqValidationError) Reason() string
- type SyncHistoryMessageResp
- func (*SyncHistoryMessageResp) Descriptor() ([]byte, []int)deprecated
- func (x *SyncHistoryMessageResp) GetError() *errors.Error
- func (x *SyncHistoryMessageResp) GetMessages() []*Message
- func (x *SyncHistoryMessageResp) GetTotal() int32
- func (*SyncHistoryMessageResp) ProtoMessage()
- func (x *SyncHistoryMessageResp) ProtoReflect() protoreflect.Message
- func (x *SyncHistoryMessageResp) Reset()
- func (x *SyncHistoryMessageResp) String() string
- func (m *SyncHistoryMessageResp) Validate() error
- func (m *SyncHistoryMessageResp) ValidateAll() error
- type SyncHistoryMessageRespMultiError
- type SyncHistoryMessageRespValidationError
- func (e SyncHistoryMessageRespValidationError) Cause() error
- func (e SyncHistoryMessageRespValidationError) Error() string
- func (e SyncHistoryMessageRespValidationError) ErrorName() string
- func (e SyncHistoryMessageRespValidationError) Field() string
- func (e SyncHistoryMessageRespValidationError) Key() bool
- func (e SyncHistoryMessageRespValidationError) Reason() string
- type UnimplementedHistoryMessageServiceServer
- func (UnimplementedHistoryMessageServiceServer) QuerySessionHistoryMessage(context.Context, *QuerySessionHistoryMessageReq) (*QuerySessionHistoryMessageResp, error)
- func (UnimplementedHistoryMessageServiceServer) SyncHistoryMessage(context.Context, *SyncHistoryMessageReq) (*SyncHistoryMessageResp, error)
- type UnimplementedOfflineMessageServiceServer
- type UnimplementedPushMessageServiceServer
- type UnsafeHistoryMessageServiceServer
- type UnsafeOfflineMessageServiceServer
- type UnsafePushMessageServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( MessageContentType_name = map[int32]string{ 0: "Text", 1: "Image", 2: "Voice", } MessageContentType_value = map[string]int32{ "Text": 0, "Image": 1, "Voice": 2, } )
Enum value maps for MessageContentType.
var ( SessionType_name = map[int32]string{ 0: "SingleChat", 1: "GroupChat", 2: "Broadcast", 3: "Channel", } SessionType_value = map[string]int32{ "SingleChat": 0, "GroupChat": 1, "Broadcast": 2, "Channel": 3, } )
Enum value maps for SessionType.
var File_message_v1_message_proto protoreflect.FileDescriptor
var HistoryMessageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.message.v1.HistoryMessageService", HandlerType: (*HistoryMessageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QuerySessionHistoryMessage", Handler: _HistoryMessageService_QuerySessionHistoryMessage_Handler, }, { MethodName: "SyncHistoryMessage", Handler: _HistoryMessageService_SyncHistoryMessage_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "message/v1/message.proto", }
HistoryMessageService_ServiceDesc is the grpc.ServiceDesc for HistoryMessageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var OfflineMessageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.message.v1.OfflineMessageService", HandlerType: (*OfflineMessageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QueryOfflineMessage", Handler: _OfflineMessageService_QueryOfflineMessage_Handler, }, { MethodName: "ConfirmLastMstID", Handler: _OfflineMessageService_ConfirmLastMstID_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "message/v1/message.proto", }
OfflineMessageService_ServiceDesc is the grpc.ServiceDesc for OfflineMessageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PushMessageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.message.v1.PushMessageService", HandlerType: (*PushMessageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PushMessage", Handler: _PushMessageService_PushMessage_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "message/v1/message.proto", }
PushMessageService_ServiceDesc is the grpc.ServiceDesc for PushMessageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterHistoryMessageServiceServer ¶ added in v0.0.9
func RegisterHistoryMessageServiceServer(s grpc.ServiceRegistrar, srv HistoryMessageServiceServer)
func RegisterOfflineMessageServiceServer ¶ added in v0.0.6
func RegisterOfflineMessageServiceServer(s grpc.ServiceRegistrar, srv OfflineMessageServiceServer)
func RegisterPushMessageServiceServer ¶ added in v0.0.6
func RegisterPushMessageServiceServer(s grpc.ServiceRegistrar, srv PushMessageServiceServer)
Types ¶
type ConfirmLastMsgIDReq ¶ added in v0.0.9
type ConfirmLastMsgIDReq struct { Uid int64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` LastMsgId int64 `protobuf:"varint,2,opt,name=last_msg_id,json=lastMsgId,proto3" json:"last_msg_id,omitempty"` // contains filtered or unexported fields }
func (*ConfirmLastMsgIDReq) Descriptor
deprecated
added in
v0.0.9
func (*ConfirmLastMsgIDReq) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmLastMsgIDReq.ProtoReflect.Descriptor instead.
func (*ConfirmLastMsgIDReq) GetLastMsgId ¶ added in v0.0.9
func (x *ConfirmLastMsgIDReq) GetLastMsgId() int64
func (*ConfirmLastMsgIDReq) GetUid ¶ added in v0.0.9
func (x *ConfirmLastMsgIDReq) GetUid() int64
func (*ConfirmLastMsgIDReq) ProtoMessage ¶ added in v0.0.9
func (*ConfirmLastMsgIDReq) ProtoMessage()
func (*ConfirmLastMsgIDReq) ProtoReflect ¶ added in v0.0.9
func (x *ConfirmLastMsgIDReq) ProtoReflect() protoreflect.Message
func (*ConfirmLastMsgIDReq) Reset ¶ added in v0.0.9
func (x *ConfirmLastMsgIDReq) Reset()
func (*ConfirmLastMsgIDReq) String ¶ added in v0.0.9
func (x *ConfirmLastMsgIDReq) String() string
func (*ConfirmLastMsgIDReq) Validate ¶ added in v0.0.9
func (m *ConfirmLastMsgIDReq) Validate() error
Validate checks the field values on ConfirmLastMsgIDReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ConfirmLastMsgIDReq) ValidateAll ¶ added in v0.0.9
func (m *ConfirmLastMsgIDReq) ValidateAll() error
ValidateAll checks the field values on ConfirmLastMsgIDReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConfirmLastMsgIDReqMultiError, or nil if none found.
type ConfirmLastMsgIDReqMultiError ¶ added in v0.0.9
type ConfirmLastMsgIDReqMultiError []error
ConfirmLastMsgIDReqMultiError is an error wrapping multiple validation errors returned by ConfirmLastMsgIDReq.ValidateAll() if the designated constraints aren't met.
func (ConfirmLastMsgIDReqMultiError) AllErrors ¶ added in v0.0.9
func (m ConfirmLastMsgIDReqMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ConfirmLastMsgIDReqMultiError) Error ¶ added in v0.0.9
func (m ConfirmLastMsgIDReqMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ConfirmLastMsgIDReqValidationError ¶ added in v0.0.9
type ConfirmLastMsgIDReqValidationError struct {
// contains filtered or unexported fields
}
ConfirmLastMsgIDReqValidationError is the validation error returned by ConfirmLastMsgIDReq.Validate if the designated constraints aren't met.
func (ConfirmLastMsgIDReqValidationError) Cause ¶ added in v0.0.9
func (e ConfirmLastMsgIDReqValidationError) Cause() error
Cause function returns cause value.
func (ConfirmLastMsgIDReqValidationError) Error ¶ added in v0.0.9
func (e ConfirmLastMsgIDReqValidationError) Error() string
Error satisfies the builtin error interface
func (ConfirmLastMsgIDReqValidationError) ErrorName ¶ added in v0.0.9
func (e ConfirmLastMsgIDReqValidationError) ErrorName() string
ErrorName returns error name.
func (ConfirmLastMsgIDReqValidationError) Field ¶ added in v0.0.9
func (e ConfirmLastMsgIDReqValidationError) Field() string
Field function returns field value.
func (ConfirmLastMsgIDReqValidationError) Key ¶ added in v0.0.9
func (e ConfirmLastMsgIDReqValidationError) Key() bool
Key function returns key value.
func (ConfirmLastMsgIDReqValidationError) Reason ¶ added in v0.0.9
func (e ConfirmLastMsgIDReqValidationError) Reason() string
Reason function returns reason value.
type ConfirmLastMsgIDResp ¶ added in v0.0.9
type ConfirmLastMsgIDResp struct { Error *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` LastMsgId int64 `protobuf:"varint,2,opt,name=last_msg_id,json=lastMsgId,proto3" json:"last_msg_id,omitempty"` // contains filtered or unexported fields }
func (*ConfirmLastMsgIDResp) Descriptor
deprecated
added in
v0.0.9
func (*ConfirmLastMsgIDResp) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmLastMsgIDResp.ProtoReflect.Descriptor instead.
func (*ConfirmLastMsgIDResp) GetError ¶ added in v0.0.9
func (x *ConfirmLastMsgIDResp) GetError() *errors.Error
func (*ConfirmLastMsgIDResp) GetLastMsgId ¶ added in v0.0.9
func (x *ConfirmLastMsgIDResp) GetLastMsgId() int64
func (*ConfirmLastMsgIDResp) ProtoMessage ¶ added in v0.0.9
func (*ConfirmLastMsgIDResp) ProtoMessage()
func (*ConfirmLastMsgIDResp) ProtoReflect ¶ added in v0.0.9
func (x *ConfirmLastMsgIDResp) ProtoReflect() protoreflect.Message
func (*ConfirmLastMsgIDResp) Reset ¶ added in v0.0.9
func (x *ConfirmLastMsgIDResp) Reset()
func (*ConfirmLastMsgIDResp) String ¶ added in v0.0.9
func (x *ConfirmLastMsgIDResp) String() string
func (*ConfirmLastMsgIDResp) Validate ¶ added in v0.0.9
func (m *ConfirmLastMsgIDResp) Validate() error
Validate checks the field values on ConfirmLastMsgIDResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ConfirmLastMsgIDResp) ValidateAll ¶ added in v0.0.9
func (m *ConfirmLastMsgIDResp) ValidateAll() error
ValidateAll checks the field values on ConfirmLastMsgIDResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConfirmLastMsgIDRespMultiError, or nil if none found.
type ConfirmLastMsgIDRespMultiError ¶ added in v0.0.9
type ConfirmLastMsgIDRespMultiError []error
ConfirmLastMsgIDRespMultiError is an error wrapping multiple validation errors returned by ConfirmLastMsgIDResp.ValidateAll() if the designated constraints aren't met.
func (ConfirmLastMsgIDRespMultiError) AllErrors ¶ added in v0.0.9
func (m ConfirmLastMsgIDRespMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ConfirmLastMsgIDRespMultiError) Error ¶ added in v0.0.9
func (m ConfirmLastMsgIDRespMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ConfirmLastMsgIDRespValidationError ¶ added in v0.0.9
type ConfirmLastMsgIDRespValidationError struct {
// contains filtered or unexported fields
}
ConfirmLastMsgIDRespValidationError is the validation error returned by ConfirmLastMsgIDResp.Validate if the designated constraints aren't met.
func (ConfirmLastMsgIDRespValidationError) Cause ¶ added in v0.0.9
func (e ConfirmLastMsgIDRespValidationError) Cause() error
Cause function returns cause value.
func (ConfirmLastMsgIDRespValidationError) Error ¶ added in v0.0.9
func (e ConfirmLastMsgIDRespValidationError) Error() string
Error satisfies the builtin error interface
func (ConfirmLastMsgIDRespValidationError) ErrorName ¶ added in v0.0.9
func (e ConfirmLastMsgIDRespValidationError) ErrorName() string
ErrorName returns error name.
func (ConfirmLastMsgIDRespValidationError) Field ¶ added in v0.0.9
func (e ConfirmLastMsgIDRespValidationError) Field() string
Field function returns field value.
func (ConfirmLastMsgIDRespValidationError) Key ¶ added in v0.0.9
func (e ConfirmLastMsgIDRespValidationError) Key() bool
Key function returns key value.
func (ConfirmLastMsgIDRespValidationError) Reason ¶ added in v0.0.9
func (e ConfirmLastMsgIDRespValidationError) Reason() string
Reason function returns reason value.
type HistoryMessageServiceClient ¶ added in v0.0.9
type HistoryMessageServiceClient interface { QuerySessionHistoryMessage(ctx context.Context, in *QuerySessionHistoryMessageReq, opts ...grpc.CallOption) (*QuerySessionHistoryMessageResp, error) SyncHistoryMessage(ctx context.Context, in *SyncHistoryMessageReq, opts ...grpc.CallOption) (*SyncHistoryMessageResp, error) }
HistoryMessageServiceClient is the client API for HistoryMessageService 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 NewHistoryMessageServiceClient ¶ added in v0.0.9
func NewHistoryMessageServiceClient(cc grpc.ClientConnInterface) HistoryMessageServiceClient
type HistoryMessageServiceServer ¶ added in v0.0.9
type HistoryMessageServiceServer interface { QuerySessionHistoryMessage(context.Context, *QuerySessionHistoryMessageReq) (*QuerySessionHistoryMessageResp, error) SyncHistoryMessage(context.Context, *SyncHistoryMessageReq) (*SyncHistoryMessageResp, error) // contains filtered or unexported methods }
HistoryMessageServiceServer is the server API for HistoryMessageService service. All implementations must embed UnimplementedHistoryMessageServiceServer for forward compatibility
type Message ¶ added in v0.0.6
type Message struct { MsgId int64 `protobuf:"varint,1,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"` From int64 `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"` To int64 `protobuf:"varint,3,opt,name=to,proto3" json:"to,omitempty"` // user id or group id or room id etc. SessionType SessionType `` /* 127-byte string literal not displayed */ SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` ContentType MessageContentType `` /* 134-byte string literal not displayed */ Content string `protobuf:"bytes,7,opt,name=content,proto3" json:"content,omitempty"` CreateTime int64 `protobuf:"varint,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // contains filtered or unexported fields }
Message is definition of message
func (*Message) Descriptor
deprecated
added in
v0.0.6
func (*Message) GetContent ¶ added in v0.0.6
func (*Message) GetContentType ¶ added in v0.0.6
func (x *Message) GetContentType() MessageContentType
func (*Message) GetCreateTime ¶ added in v0.0.6
func (*Message) GetSessionId ¶ added in v0.0.6
func (*Message) GetSessionType ¶ added in v0.0.6
func (x *Message) GetSessionType() SessionType
func (*Message) ProtoMessage ¶ added in v0.0.6
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶ added in v0.0.6
func (x *Message) ProtoReflect() protoreflect.Message
func (*Message) Validate ¶ added in v0.0.6
Validate checks the field values on Message with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Message) ValidateAll ¶ added in v0.0.6
ValidateAll checks the field values on Message with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in MessageMultiError, or nil if none found.
type MessageContentType ¶
type MessageContentType int32
const ( MessageContentType_Text MessageContentType = 0 MessageContentType_Image MessageContentType = 1 MessageContentType_Voice MessageContentType = 2 )
func (MessageContentType) Descriptor ¶
func (MessageContentType) Descriptor() protoreflect.EnumDescriptor
func (MessageContentType) Enum ¶
func (x MessageContentType) Enum() *MessageContentType
func (MessageContentType) EnumDescriptor
deprecated
func (MessageContentType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageContentType.Descriptor instead.
func (MessageContentType) Number ¶
func (x MessageContentType) Number() protoreflect.EnumNumber
func (MessageContentType) String ¶
func (x MessageContentType) String() string
func (MessageContentType) Type ¶
func (MessageContentType) Type() protoreflect.EnumType
type MessageMultiError ¶ added in v0.0.6
type MessageMultiError []error
MessageMultiError is an error wrapping multiple validation errors returned by Message.ValidateAll() if the designated constraints aren't met.
func (MessageMultiError) AllErrors ¶ added in v0.0.6
func (m MessageMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (MessageMultiError) Error ¶ added in v0.0.6
func (m MessageMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type MessageValidationError ¶ added in v0.0.6
type MessageValidationError struct {
// contains filtered or unexported fields
}
MessageValidationError is the validation error returned by Message.Validate if the designated constraints aren't met.
func (MessageValidationError) Cause ¶ added in v0.0.6
func (e MessageValidationError) Cause() error
Cause function returns cause value.
func (MessageValidationError) Error ¶ added in v0.0.6
func (e MessageValidationError) Error() string
Error satisfies the builtin error interface
func (MessageValidationError) ErrorName ¶ added in v0.0.6
func (e MessageValidationError) ErrorName() string
ErrorName returns error name.
func (MessageValidationError) Field ¶ added in v0.0.6
func (e MessageValidationError) Field() string
Field function returns field value.
func (MessageValidationError) Key ¶ added in v0.0.6
func (e MessageValidationError) Key() bool
Key function returns key value.
func (MessageValidationError) Reason ¶ added in v0.0.6
func (e MessageValidationError) Reason() string
Reason function returns reason value.
type OfflineMessageServiceClient ¶ added in v0.0.6
type OfflineMessageServiceClient interface { QueryOfflineMessage(ctx context.Context, in *QueryOfflineMessageReq, opts ...grpc.CallOption) (*QueryOfflineMessageResp, error) ConfirmLastMstID(ctx context.Context, in *ConfirmLastMsgIDReq, opts ...grpc.CallOption) (*ConfirmLastMsgIDResp, error) }
OfflineMessageServiceClient is the client API for OfflineMessageService 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 NewOfflineMessageServiceClient ¶ added in v0.0.6
func NewOfflineMessageServiceClient(cc grpc.ClientConnInterface) OfflineMessageServiceClient
type OfflineMessageServiceServer ¶ added in v0.0.6
type OfflineMessageServiceServer interface { QueryOfflineMessage(context.Context, *QueryOfflineMessageReq) (*QueryOfflineMessageResp, error) ConfirmLastMstID(context.Context, *ConfirmLastMsgIDReq) (*ConfirmLastMsgIDResp, error) // contains filtered or unexported methods }
OfflineMessageServiceServer is the server API for OfflineMessageService service. All implementations must embed UnimplementedOfflineMessageServiceServer for forward compatibility
type PushMessageReq ¶
type PushMessageReq struct { Message *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // ToUsers is a list of user id who receive this message ToUsers []int64 `protobuf:"varint,2,rep,packed,name=to_users,json=toUsers,proto3" json:"to_users,omitempty"` // contains filtered or unexported fields }
PushMessage use for push a message to persistence connection server
func (*PushMessageReq) Descriptor
deprecated
func (*PushMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use PushMessageReq.ProtoReflect.Descriptor instead.
func (*PushMessageReq) GetMessage ¶ added in v0.0.6
func (x *PushMessageReq) GetMessage() *Message
func (*PushMessageReq) GetToUsers ¶ added in v0.0.6
func (x *PushMessageReq) GetToUsers() []int64
func (*PushMessageReq) ProtoMessage ¶
func (*PushMessageReq) ProtoMessage()
func (*PushMessageReq) ProtoReflect ¶
func (x *PushMessageReq) ProtoReflect() protoreflect.Message
func (*PushMessageReq) Reset ¶
func (x *PushMessageReq) Reset()
func (*PushMessageReq) String ¶
func (x *PushMessageReq) String() string
func (*PushMessageReq) Validate ¶
func (m *PushMessageReq) Validate() error
Validate checks the field values on PushMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PushMessageReq) ValidateAll ¶
func (m *PushMessageReq) ValidateAll() error
ValidateAll checks the field values on PushMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushMessageReqMultiError, or nil if none found.
type PushMessageReqMultiError ¶
type PushMessageReqMultiError []error
PushMessageReqMultiError is an error wrapping multiple validation errors returned by PushMessageReq.ValidateAll() if the designated constraints aren't met.
func (PushMessageReqMultiError) AllErrors ¶
func (m PushMessageReqMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PushMessageReqMultiError) Error ¶
func (m PushMessageReqMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PushMessageReqValidationError ¶
type PushMessageReqValidationError struct {
// contains filtered or unexported fields
}
PushMessageReqValidationError is the validation error returned by PushMessageReq.Validate if the designated constraints aren't met.
func (PushMessageReqValidationError) Cause ¶
func (e PushMessageReqValidationError) Cause() error
Cause function returns cause value.
func (PushMessageReqValidationError) Error ¶
func (e PushMessageReqValidationError) Error() string
Error satisfies the builtin error interface
func (PushMessageReqValidationError) ErrorName ¶
func (e PushMessageReqValidationError) ErrorName() string
ErrorName returns error name.
func (PushMessageReqValidationError) Field ¶
func (e PushMessageReqValidationError) Field() string
Field function returns field value.
func (PushMessageReqValidationError) Key ¶
func (e PushMessageReqValidationError) Key() bool
Key function returns key value.
func (PushMessageReqValidationError) Reason ¶
func (e PushMessageReqValidationError) Reason() string
Reason function returns reason value.
type PushMessageResp ¶ added in v0.0.6
type PushMessageResp struct { Error *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` FailedUsers []int64 `protobuf:"varint,2,rep,packed,name=failed_users,json=failedUsers,proto3" json:"failed_users,omitempty"` // contains filtered or unexported fields }
func (*PushMessageResp) Descriptor
deprecated
added in
v0.0.6
func (*PushMessageResp) Descriptor() ([]byte, []int)
Deprecated: Use PushMessageResp.ProtoReflect.Descriptor instead.
func (*PushMessageResp) GetError ¶ added in v0.0.9
func (x *PushMessageResp) GetError() *errors.Error
func (*PushMessageResp) GetFailedUsers ¶ added in v0.0.6
func (x *PushMessageResp) GetFailedUsers() []int64
func (*PushMessageResp) ProtoMessage ¶ added in v0.0.6
func (*PushMessageResp) ProtoMessage()
func (*PushMessageResp) ProtoReflect ¶ added in v0.0.6
func (x *PushMessageResp) ProtoReflect() protoreflect.Message
func (*PushMessageResp) Reset ¶ added in v0.0.6
func (x *PushMessageResp) Reset()
func (*PushMessageResp) String ¶ added in v0.0.6
func (x *PushMessageResp) String() string
func (*PushMessageResp) Validate ¶ added in v0.0.6
func (m *PushMessageResp) Validate() error
Validate checks the field values on PushMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PushMessageResp) ValidateAll ¶ added in v0.0.6
func (m *PushMessageResp) ValidateAll() error
ValidateAll checks the field values on PushMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushMessageRespMultiError, or nil if none found.
type PushMessageRespMultiError ¶ added in v0.0.6
type PushMessageRespMultiError []error
PushMessageRespMultiError is an error wrapping multiple validation errors returned by PushMessageResp.ValidateAll() if the designated constraints aren't met.
func (PushMessageRespMultiError) AllErrors ¶ added in v0.0.6
func (m PushMessageRespMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PushMessageRespMultiError) Error ¶ added in v0.0.6
func (m PushMessageRespMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PushMessageRespValidationError ¶ added in v0.0.6
type PushMessageRespValidationError struct {
// contains filtered or unexported fields
}
PushMessageRespValidationError is the validation error returned by PushMessageResp.Validate if the designated constraints aren't met.
func (PushMessageRespValidationError) Cause ¶ added in v0.0.6
func (e PushMessageRespValidationError) Cause() error
Cause function returns cause value.
func (PushMessageRespValidationError) Error ¶ added in v0.0.6
func (e PushMessageRespValidationError) Error() string
Error satisfies the builtin error interface
func (PushMessageRespValidationError) ErrorName ¶ added in v0.0.6
func (e PushMessageRespValidationError) ErrorName() string
ErrorName returns error name.
func (PushMessageRespValidationError) Field ¶ added in v0.0.6
func (e PushMessageRespValidationError) Field() string
Field function returns field value.
func (PushMessageRespValidationError) Key ¶ added in v0.0.6
func (e PushMessageRespValidationError) Key() bool
Key function returns key value.
func (PushMessageRespValidationError) Reason ¶ added in v0.0.6
func (e PushMessageRespValidationError) Reason() string
Reason function returns reason value.
type PushMessageServiceClient ¶ added in v0.0.6
type PushMessageServiceClient interface {
PushMessage(ctx context.Context, in *PushMessageReq, opts ...grpc.CallOption) (*PushMessageResp, error)
}
PushMessageServiceClient is the client API for PushMessageService 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 NewPushMessageServiceClient ¶ added in v0.0.6
func NewPushMessageServiceClient(cc grpc.ClientConnInterface) PushMessageServiceClient
type PushMessageServiceServer ¶ added in v0.0.6
type PushMessageServiceServer interface { PushMessage(context.Context, *PushMessageReq) (*PushMessageResp, error) // contains filtered or unexported methods }
PushMessageServiceServer is the server API for PushMessageService service. All implementations must embed UnimplementedPushMessageServiceServer for forward compatibility
type QueryOfflineMessageReq ¶
type QueryOfflineMessageReq struct { Uid int64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` LastMsgId int64 `protobuf:"varint,2,opt,name=last_msg_id,json=lastMsgId,proto3" json:"last_msg_id,omitempty"` OnlyCount bool `protobuf:"varint,3,opt,name=onlyCount,proto3" json:"onlyCount,omitempty"` Page int32 `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"` PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // contains filtered or unexported fields }
func (*QueryOfflineMessageReq) Descriptor
deprecated
func (*QueryOfflineMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use QueryOfflineMessageReq.ProtoReflect.Descriptor instead.
func (*QueryOfflineMessageReq) GetLastMsgId ¶ added in v0.0.6
func (x *QueryOfflineMessageReq) GetLastMsgId() int64
func (*QueryOfflineMessageReq) GetOnlyCount ¶
func (x *QueryOfflineMessageReq) GetOnlyCount() bool
func (*QueryOfflineMessageReq) GetPage ¶
func (x *QueryOfflineMessageReq) GetPage() int32
func (*QueryOfflineMessageReq) GetPageSize ¶
func (x *QueryOfflineMessageReq) GetPageSize() int32
func (*QueryOfflineMessageReq) GetUid ¶ added in v0.0.7
func (x *QueryOfflineMessageReq) GetUid() int64
func (*QueryOfflineMessageReq) ProtoMessage ¶
func (*QueryOfflineMessageReq) ProtoMessage()
func (*QueryOfflineMessageReq) ProtoReflect ¶
func (x *QueryOfflineMessageReq) ProtoReflect() protoreflect.Message
func (*QueryOfflineMessageReq) Reset ¶
func (x *QueryOfflineMessageReq) Reset()
func (*QueryOfflineMessageReq) String ¶
func (x *QueryOfflineMessageReq) String() string
func (*QueryOfflineMessageReq) Validate ¶
func (m *QueryOfflineMessageReq) Validate() error
Validate checks the field values on QueryOfflineMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*QueryOfflineMessageReq) ValidateAll ¶
func (m *QueryOfflineMessageReq) ValidateAll() error
ValidateAll checks the field values on QueryOfflineMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueryOfflineMessageReqMultiError, or nil if none found.
type QueryOfflineMessageReqMultiError ¶
type QueryOfflineMessageReqMultiError []error
QueryOfflineMessageReqMultiError is an error wrapping multiple validation errors returned by QueryOfflineMessageReq.ValidateAll() if the designated constraints aren't met.
func (QueryOfflineMessageReqMultiError) AllErrors ¶
func (m QueryOfflineMessageReqMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (QueryOfflineMessageReqMultiError) Error ¶
func (m QueryOfflineMessageReqMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type QueryOfflineMessageReqValidationError ¶
type QueryOfflineMessageReqValidationError struct {
// contains filtered or unexported fields
}
QueryOfflineMessageReqValidationError is the validation error returned by QueryOfflineMessageReq.Validate if the designated constraints aren't met.
func (QueryOfflineMessageReqValidationError) Cause ¶
func (e QueryOfflineMessageReqValidationError) Cause() error
Cause function returns cause value.
func (QueryOfflineMessageReqValidationError) Error ¶
func (e QueryOfflineMessageReqValidationError) Error() string
Error satisfies the builtin error interface
func (QueryOfflineMessageReqValidationError) ErrorName ¶
func (e QueryOfflineMessageReqValidationError) ErrorName() string
ErrorName returns error name.
func (QueryOfflineMessageReqValidationError) Field ¶
func (e QueryOfflineMessageReqValidationError) Field() string
Field function returns field value.
func (QueryOfflineMessageReqValidationError) Key ¶
func (e QueryOfflineMessageReqValidationError) Key() bool
Key function returns key value.
func (QueryOfflineMessageReqValidationError) Reason ¶
func (e QueryOfflineMessageReqValidationError) Reason() string
Reason function returns reason value.
type QueryOfflineMessageResp ¶
type QueryOfflineMessageResp struct { Error *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` Messages []*Message `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*QueryOfflineMessageResp) Descriptor
deprecated
func (*QueryOfflineMessageResp) Descriptor() ([]byte, []int)
Deprecated: Use QueryOfflineMessageResp.ProtoReflect.Descriptor instead.
func (*QueryOfflineMessageResp) GetError ¶ added in v0.0.9
func (x *QueryOfflineMessageResp) GetError() *errors.Error
func (*QueryOfflineMessageResp) GetMessages ¶
func (x *QueryOfflineMessageResp) GetMessages() []*Message
func (*QueryOfflineMessageResp) GetTotal ¶
func (x *QueryOfflineMessageResp) GetTotal() int32
func (*QueryOfflineMessageResp) ProtoMessage ¶
func (*QueryOfflineMessageResp) ProtoMessage()
func (*QueryOfflineMessageResp) ProtoReflect ¶
func (x *QueryOfflineMessageResp) ProtoReflect() protoreflect.Message
func (*QueryOfflineMessageResp) Reset ¶
func (x *QueryOfflineMessageResp) Reset()
func (*QueryOfflineMessageResp) String ¶
func (x *QueryOfflineMessageResp) String() string
func (*QueryOfflineMessageResp) Validate ¶
func (m *QueryOfflineMessageResp) Validate() error
Validate checks the field values on QueryOfflineMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*QueryOfflineMessageResp) ValidateAll ¶
func (m *QueryOfflineMessageResp) ValidateAll() error
ValidateAll checks the field values on QueryOfflineMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueryOfflineMessageRespMultiError, or nil if none found.
type QueryOfflineMessageRespMultiError ¶
type QueryOfflineMessageRespMultiError []error
QueryOfflineMessageRespMultiError is an error wrapping multiple validation errors returned by QueryOfflineMessageResp.ValidateAll() if the designated constraints aren't met.
func (QueryOfflineMessageRespMultiError) AllErrors ¶
func (m QueryOfflineMessageRespMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (QueryOfflineMessageRespMultiError) Error ¶
func (m QueryOfflineMessageRespMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type QueryOfflineMessageRespValidationError ¶
type QueryOfflineMessageRespValidationError struct {
// contains filtered or unexported fields
}
QueryOfflineMessageRespValidationError is the validation error returned by QueryOfflineMessageResp.Validate if the designated constraints aren't met.
func (QueryOfflineMessageRespValidationError) Cause ¶
func (e QueryOfflineMessageRespValidationError) Cause() error
Cause function returns cause value.
func (QueryOfflineMessageRespValidationError) Error ¶
func (e QueryOfflineMessageRespValidationError) Error() string
Error satisfies the builtin error interface
func (QueryOfflineMessageRespValidationError) ErrorName ¶
func (e QueryOfflineMessageRespValidationError) ErrorName() string
ErrorName returns error name.
func (QueryOfflineMessageRespValidationError) Field ¶
func (e QueryOfflineMessageRespValidationError) Field() string
Field function returns field value.
func (QueryOfflineMessageRespValidationError) Key ¶
func (e QueryOfflineMessageRespValidationError) Key() bool
Key function returns key value.
func (QueryOfflineMessageRespValidationError) Reason ¶
func (e QueryOfflineMessageRespValidationError) Reason() string
Reason function returns reason value.
type QuerySessionHistoryMessageReq ¶ added in v0.0.9
type QuerySessionHistoryMessageReq struct { Uid int64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` LastMsgId int64 `protobuf:"varint,3,opt,name=last_msg_id,json=lastMsgId,proto3" json:"last_msg_id,omitempty"` Page int32 `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"` PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // contains filtered or unexported fields }
func (*QuerySessionHistoryMessageReq) Descriptor
deprecated
added in
v0.0.9
func (*QuerySessionHistoryMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use QuerySessionHistoryMessageReq.ProtoReflect.Descriptor instead.
func (*QuerySessionHistoryMessageReq) GetLastMsgId ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) GetLastMsgId() int64
func (*QuerySessionHistoryMessageReq) GetPage ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) GetPage() int32
func (*QuerySessionHistoryMessageReq) GetPageSize ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) GetPageSize() int32
func (*QuerySessionHistoryMessageReq) GetSessionId ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) GetSessionId() string
func (*QuerySessionHistoryMessageReq) GetUid ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) GetUid() int64
func (*QuerySessionHistoryMessageReq) ProtoMessage ¶ added in v0.0.9
func (*QuerySessionHistoryMessageReq) ProtoMessage()
func (*QuerySessionHistoryMessageReq) ProtoReflect ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) ProtoReflect() protoreflect.Message
func (*QuerySessionHistoryMessageReq) Reset ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) Reset()
func (*QuerySessionHistoryMessageReq) String ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageReq) String() string
func (*QuerySessionHistoryMessageReq) Validate ¶ added in v0.0.9
func (m *QuerySessionHistoryMessageReq) Validate() error
Validate checks the field values on QuerySessionHistoryMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*QuerySessionHistoryMessageReq) ValidateAll ¶ added in v0.0.9
func (m *QuerySessionHistoryMessageReq) ValidateAll() error
ValidateAll checks the field values on QuerySessionHistoryMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QuerySessionHistoryMessageReqMultiError, or nil if none found.
type QuerySessionHistoryMessageReqMultiError ¶ added in v0.0.9
type QuerySessionHistoryMessageReqMultiError []error
QuerySessionHistoryMessageReqMultiError is an error wrapping multiple validation errors returned by QuerySessionHistoryMessageReq.ValidateAll() if the designated constraints aren't met.
func (QuerySessionHistoryMessageReqMultiError) AllErrors ¶ added in v0.0.9
func (m QuerySessionHistoryMessageReqMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (QuerySessionHistoryMessageReqMultiError) Error ¶ added in v0.0.9
func (m QuerySessionHistoryMessageReqMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type QuerySessionHistoryMessageReqValidationError ¶ added in v0.0.9
type QuerySessionHistoryMessageReqValidationError struct {
// contains filtered or unexported fields
}
QuerySessionHistoryMessageReqValidationError is the validation error returned by QuerySessionHistoryMessageReq.Validate if the designated constraints aren't met.
func (QuerySessionHistoryMessageReqValidationError) Cause ¶ added in v0.0.9
func (e QuerySessionHistoryMessageReqValidationError) Cause() error
Cause function returns cause value.
func (QuerySessionHistoryMessageReqValidationError) Error ¶ added in v0.0.9
func (e QuerySessionHistoryMessageReqValidationError) Error() string
Error satisfies the builtin error interface
func (QuerySessionHistoryMessageReqValidationError) ErrorName ¶ added in v0.0.9
func (e QuerySessionHistoryMessageReqValidationError) ErrorName() string
ErrorName returns error name.
func (QuerySessionHistoryMessageReqValidationError) Field ¶ added in v0.0.9
func (e QuerySessionHistoryMessageReqValidationError) Field() string
Field function returns field value.
func (QuerySessionHistoryMessageReqValidationError) Key ¶ added in v0.0.9
func (e QuerySessionHistoryMessageReqValidationError) Key() bool
Key function returns key value.
func (QuerySessionHistoryMessageReqValidationError) Reason ¶ added in v0.0.9
func (e QuerySessionHistoryMessageReqValidationError) Reason() string
Reason function returns reason value.
type QuerySessionHistoryMessageResp ¶ added in v0.0.9
type QuerySessionHistoryMessageResp struct { Error *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` Messages []*Message `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*QuerySessionHistoryMessageResp) Descriptor
deprecated
added in
v0.0.9
func (*QuerySessionHistoryMessageResp) Descriptor() ([]byte, []int)
Deprecated: Use QuerySessionHistoryMessageResp.ProtoReflect.Descriptor instead.
func (*QuerySessionHistoryMessageResp) GetError ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageResp) GetError() *errors.Error
func (*QuerySessionHistoryMessageResp) GetMessages ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageResp) GetMessages() []*Message
func (*QuerySessionHistoryMessageResp) GetTotal ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageResp) GetTotal() int32
func (*QuerySessionHistoryMessageResp) ProtoMessage ¶ added in v0.0.9
func (*QuerySessionHistoryMessageResp) ProtoMessage()
func (*QuerySessionHistoryMessageResp) ProtoReflect ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageResp) ProtoReflect() protoreflect.Message
func (*QuerySessionHistoryMessageResp) Reset ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageResp) Reset()
func (*QuerySessionHistoryMessageResp) String ¶ added in v0.0.9
func (x *QuerySessionHistoryMessageResp) String() string
func (*QuerySessionHistoryMessageResp) Validate ¶ added in v0.0.9
func (m *QuerySessionHistoryMessageResp) Validate() error
Validate checks the field values on QuerySessionHistoryMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*QuerySessionHistoryMessageResp) ValidateAll ¶ added in v0.0.9
func (m *QuerySessionHistoryMessageResp) ValidateAll() error
ValidateAll checks the field values on QuerySessionHistoryMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QuerySessionHistoryMessageRespMultiError, or nil if none found.
type QuerySessionHistoryMessageRespMultiError ¶ added in v0.0.9
type QuerySessionHistoryMessageRespMultiError []error
QuerySessionHistoryMessageRespMultiError is an error wrapping multiple validation errors returned by QuerySessionHistoryMessageResp.ValidateAll() if the designated constraints aren't met.
func (QuerySessionHistoryMessageRespMultiError) AllErrors ¶ added in v0.0.9
func (m QuerySessionHistoryMessageRespMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (QuerySessionHistoryMessageRespMultiError) Error ¶ added in v0.0.9
func (m QuerySessionHistoryMessageRespMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type QuerySessionHistoryMessageRespValidationError ¶ added in v0.0.9
type QuerySessionHistoryMessageRespValidationError struct {
// contains filtered or unexported fields
}
QuerySessionHistoryMessageRespValidationError is the validation error returned by QuerySessionHistoryMessageResp.Validate if the designated constraints aren't met.
func (QuerySessionHistoryMessageRespValidationError) Cause ¶ added in v0.0.9
func (e QuerySessionHistoryMessageRespValidationError) Cause() error
Cause function returns cause value.
func (QuerySessionHistoryMessageRespValidationError) Error ¶ added in v0.0.9
func (e QuerySessionHistoryMessageRespValidationError) Error() string
Error satisfies the builtin error interface
func (QuerySessionHistoryMessageRespValidationError) ErrorName ¶ added in v0.0.9
func (e QuerySessionHistoryMessageRespValidationError) ErrorName() string
ErrorName returns error name.
func (QuerySessionHistoryMessageRespValidationError) Field ¶ added in v0.0.9
func (e QuerySessionHistoryMessageRespValidationError) Field() string
Field function returns field value.
func (QuerySessionHistoryMessageRespValidationError) Key ¶ added in v0.0.9
func (e QuerySessionHistoryMessageRespValidationError) Key() bool
Key function returns key value.
func (QuerySessionHistoryMessageRespValidationError) Reason ¶ added in v0.0.9
func (e QuerySessionHistoryMessageRespValidationError) Reason() string
Reason function returns reason value.
type SendMessageReq ¶
type SendMessageReq struct { From int64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"` To int64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"` SessionType SessionType `` /* 127-byte string literal not displayed */ SessionId *string `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"` ContentType MessageContentType `` /* 134-byte string literal not displayed */ Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
SendMessageReq receive data from gateway
func (*SendMessageReq) Descriptor
deprecated
func (*SendMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageReq.ProtoReflect.Descriptor instead.
func (*SendMessageReq) GetContent ¶
func (x *SendMessageReq) GetContent() string
func (*SendMessageReq) GetContentType ¶
func (x *SendMessageReq) GetContentType() MessageContentType
func (*SendMessageReq) GetFrom ¶ added in v0.0.6
func (x *SendMessageReq) GetFrom() int64
func (*SendMessageReq) GetSessionId ¶ added in v0.0.6
func (x *SendMessageReq) GetSessionId() string
func (*SendMessageReq) GetSessionType ¶ added in v0.0.6
func (x *SendMessageReq) GetSessionType() SessionType
func (*SendMessageReq) GetTo ¶ added in v0.0.6
func (x *SendMessageReq) GetTo() int64
func (*SendMessageReq) ProtoMessage ¶
func (*SendMessageReq) ProtoMessage()
func (*SendMessageReq) ProtoReflect ¶
func (x *SendMessageReq) ProtoReflect() protoreflect.Message
func (*SendMessageReq) Reset ¶
func (x *SendMessageReq) Reset()
func (*SendMessageReq) String ¶
func (x *SendMessageReq) String() string
func (*SendMessageReq) Validate ¶
func (m *SendMessageReq) Validate() error
Validate checks the field values on SendMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*SendMessageReq) ValidateAll ¶
func (m *SendMessageReq) ValidateAll() error
ValidateAll checks the field values on SendMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SendMessageReqMultiError, or nil if none found.
type SendMessageReqMultiError ¶
type SendMessageReqMultiError []error
SendMessageReqMultiError is an error wrapping multiple validation errors returned by SendMessageReq.ValidateAll() if the designated constraints aren't met.
func (SendMessageReqMultiError) AllErrors ¶
func (m SendMessageReqMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SendMessageReqMultiError) Error ¶
func (m SendMessageReqMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SendMessageReqValidationError ¶
type SendMessageReqValidationError struct {
// contains filtered or unexported fields
}
SendMessageReqValidationError is the validation error returned by SendMessageReq.Validate if the designated constraints aren't met.
func (SendMessageReqValidationError) Cause ¶
func (e SendMessageReqValidationError) Cause() error
Cause function returns cause value.
func (SendMessageReqValidationError) Error ¶
func (e SendMessageReqValidationError) Error() string
Error satisfies the builtin error interface
func (SendMessageReqValidationError) ErrorName ¶
func (e SendMessageReqValidationError) ErrorName() string
ErrorName returns error name.
func (SendMessageReqValidationError) Field ¶
func (e SendMessageReqValidationError) Field() string
Field function returns field value.
func (SendMessageReqValidationError) Key ¶
func (e SendMessageReqValidationError) Key() bool
Key function returns key value.
func (SendMessageReqValidationError) Reason ¶
func (e SendMessageReqValidationError) Reason() string
Reason function returns reason value.
type SessionType ¶ added in v0.0.7
type SessionType int32
define session type and status
const ( SessionType_SingleChat SessionType = 0 SessionType_GroupChat SessionType = 1 // broadcast actually not a standard chat type, but we still use it here SessionType_Broadcast SessionType = 2 // Channel is for user subscribed channel msgs SessionType_Channel SessionType = 3 // 255 at most )
func (SessionType) Descriptor ¶ added in v0.0.7
func (SessionType) Descriptor() protoreflect.EnumDescriptor
func (SessionType) Enum ¶ added in v0.0.7
func (x SessionType) Enum() *SessionType
func (SessionType) EnumDescriptor
deprecated
added in
v0.0.7
func (SessionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SessionType.Descriptor instead.
func (SessionType) Number ¶ added in v0.0.7
func (x SessionType) Number() protoreflect.EnumNumber
func (SessionType) String ¶ added in v0.0.7
func (x SessionType) String() string
func (SessionType) Type ¶ added in v0.0.7
func (SessionType) Type() protoreflect.EnumType
type StorageMessage ¶ added in v0.0.8
type StorageMessage struct { RowKey string `protobuf:"bytes,1,opt,name=rowKey,proto3" json:"rowKey,omitempty"` Users *StorageMessage_Users `protobuf:"bytes,2,opt,name=users,proto3" json:"users,omitempty"` Content *StorageMessage_Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` Extra *StorageMessage_Extra `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"` // contains filtered or unexported fields }
storage message
func (*StorageMessage) Descriptor
deprecated
added in
v0.0.8
func (*StorageMessage) Descriptor() ([]byte, []int)
Deprecated: Use StorageMessage.ProtoReflect.Descriptor instead.
func (*StorageMessage) GetContent ¶ added in v0.0.8
func (x *StorageMessage) GetContent() *StorageMessage_Content
func (*StorageMessage) GetExtra ¶ added in v0.0.8
func (x *StorageMessage) GetExtra() *StorageMessage_Extra
func (*StorageMessage) GetRowKey ¶ added in v0.0.8
func (x *StorageMessage) GetRowKey() string
func (*StorageMessage) GetUsers ¶ added in v0.0.8
func (x *StorageMessage) GetUsers() *StorageMessage_Users
func (*StorageMessage) HbaseRowKey ¶ added in v0.0.8
func (x *StorageMessage) HbaseRowKey() string
func (*StorageMessage) HbaseValues ¶ added in v0.0.8
func (x *StorageMessage) HbaseValues() map[string]map[string][]byte
func (*StorageMessage) ProtoMessage ¶ added in v0.0.8
func (*StorageMessage) ProtoMessage()
func (*StorageMessage) ProtoReflect ¶ added in v0.0.8
func (x *StorageMessage) ProtoReflect() protoreflect.Message
func (*StorageMessage) Reset ¶ added in v0.0.8
func (x *StorageMessage) Reset()
func (*StorageMessage) String ¶ added in v0.0.8
func (x *StorageMessage) String() string
func (*StorageMessage) TableName ¶ added in v0.0.8
func (x *StorageMessage) TableName() string
func (*StorageMessage) Validate ¶ added in v0.0.8
func (m *StorageMessage) Validate() error
Validate checks the field values on StorageMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StorageMessage) ValidateAll ¶ added in v0.0.8
func (m *StorageMessage) ValidateAll() error
ValidateAll checks the field values on StorageMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageMessageMultiError, or nil if none found.
type StorageMessageMultiError ¶ added in v0.0.8
type StorageMessageMultiError []error
StorageMessageMultiError is an error wrapping multiple validation errors returned by StorageMessage.ValidateAll() if the designated constraints aren't met.
func (StorageMessageMultiError) AllErrors ¶ added in v0.0.8
func (m StorageMessageMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StorageMessageMultiError) Error ¶ added in v0.0.8
func (m StorageMessageMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StorageMessageValidationError ¶ added in v0.0.8
type StorageMessageValidationError struct {
// contains filtered or unexported fields
}
StorageMessageValidationError is the validation error returned by StorageMessage.Validate if the designated constraints aren't met.
func (StorageMessageValidationError) Cause ¶ added in v0.0.8
func (e StorageMessageValidationError) Cause() error
Cause function returns cause value.
func (StorageMessageValidationError) Error ¶ added in v0.0.8
func (e StorageMessageValidationError) Error() string
Error satisfies the builtin error interface
func (StorageMessageValidationError) ErrorName ¶ added in v0.0.8
func (e StorageMessageValidationError) ErrorName() string
ErrorName returns error name.
func (StorageMessageValidationError) Field ¶ added in v0.0.8
func (e StorageMessageValidationError) Field() string
Field function returns field value.
func (StorageMessageValidationError) Key ¶ added in v0.0.8
func (e StorageMessageValidationError) Key() bool
Key function returns key value.
func (StorageMessageValidationError) Reason ¶ added in v0.0.8
func (e StorageMessageValidationError) Reason() string
Reason function returns reason value.
type StorageMessage_Content ¶ added in v0.0.8
type StorageMessage_Content struct { ContentType MessageContentType `protobuf:"varint,1,opt,name=contentType,proto3,enum=api.message.v1.MessageContentType" json:"contentType,omitempty"` Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*StorageMessage_Content) Descriptor
deprecated
added in
v0.0.8
func (*StorageMessage_Content) Descriptor() ([]byte, []int)
Deprecated: Use StorageMessage_Content.ProtoReflect.Descriptor instead.
func (*StorageMessage_Content) GetContent ¶ added in v0.0.8
func (x *StorageMessage_Content) GetContent() string
func (*StorageMessage_Content) GetContentType ¶ added in v0.0.8
func (x *StorageMessage_Content) GetContentType() MessageContentType
func (*StorageMessage_Content) ProtoMessage ¶ added in v0.0.8
func (*StorageMessage_Content) ProtoMessage()
func (*StorageMessage_Content) ProtoReflect ¶ added in v0.0.8
func (x *StorageMessage_Content) ProtoReflect() protoreflect.Message
func (*StorageMessage_Content) Reset ¶ added in v0.0.8
func (x *StorageMessage_Content) Reset()
func (*StorageMessage_Content) String ¶ added in v0.0.8
func (x *StorageMessage_Content) String() string
func (*StorageMessage_Content) Validate ¶ added in v0.0.8
func (m *StorageMessage_Content) Validate() error
Validate checks the field values on StorageMessage_Content with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StorageMessage_Content) ValidateAll ¶ added in v0.0.8
func (m *StorageMessage_Content) ValidateAll() error
ValidateAll checks the field values on StorageMessage_Content with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageMessage_ContentMultiError, or nil if none found.
type StorageMessage_ContentMultiError ¶ added in v0.0.8
type StorageMessage_ContentMultiError []error
StorageMessage_ContentMultiError is an error wrapping multiple validation errors returned by StorageMessage_Content.ValidateAll() if the designated constraints aren't met.
func (StorageMessage_ContentMultiError) AllErrors ¶ added in v0.0.8
func (m StorageMessage_ContentMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StorageMessage_ContentMultiError) Error ¶ added in v0.0.8
func (m StorageMessage_ContentMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StorageMessage_ContentValidationError ¶ added in v0.0.8
type StorageMessage_ContentValidationError struct {
// contains filtered or unexported fields
}
StorageMessage_ContentValidationError is the validation error returned by StorageMessage_Content.Validate if the designated constraints aren't met.
func (StorageMessage_ContentValidationError) Cause ¶ added in v0.0.8
func (e StorageMessage_ContentValidationError) Cause() error
Cause function returns cause value.
func (StorageMessage_ContentValidationError) Error ¶ added in v0.0.8
func (e StorageMessage_ContentValidationError) Error() string
Error satisfies the builtin error interface
func (StorageMessage_ContentValidationError) ErrorName ¶ added in v0.0.8
func (e StorageMessage_ContentValidationError) ErrorName() string
ErrorName returns error name.
func (StorageMessage_ContentValidationError) Field ¶ added in v0.0.8
func (e StorageMessage_ContentValidationError) Field() string
Field function returns field value.
func (StorageMessage_ContentValidationError) Key ¶ added in v0.0.8
func (e StorageMessage_ContentValidationError) Key() bool
Key function returns key value.
func (StorageMessage_ContentValidationError) Reason ¶ added in v0.0.8
func (e StorageMessage_ContentValidationError) Reason() string
Reason function returns reason value.
type StorageMessage_Extra ¶ added in v0.0.8
type StorageMessage_Extra struct { CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=createTime,proto3" json:"createTime,omitempty"` // contains filtered or unexported fields }
func (*StorageMessage_Extra) Descriptor
deprecated
added in
v0.0.8
func (*StorageMessage_Extra) Descriptor() ([]byte, []int)
Deprecated: Use StorageMessage_Extra.ProtoReflect.Descriptor instead.
func (*StorageMessage_Extra) GetCreateTime ¶ added in v0.0.8
func (x *StorageMessage_Extra) GetCreateTime() *timestamppb.Timestamp
func (*StorageMessage_Extra) ProtoMessage ¶ added in v0.0.8
func (*StorageMessage_Extra) ProtoMessage()
func (*StorageMessage_Extra) ProtoReflect ¶ added in v0.0.8
func (x *StorageMessage_Extra) ProtoReflect() protoreflect.Message
func (*StorageMessage_Extra) Reset ¶ added in v0.0.8
func (x *StorageMessage_Extra) Reset()
func (*StorageMessage_Extra) String ¶ added in v0.0.8
func (x *StorageMessage_Extra) String() string
func (*StorageMessage_Extra) Validate ¶ added in v0.0.8
func (m *StorageMessage_Extra) Validate() error
Validate checks the field values on StorageMessage_Extra with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StorageMessage_Extra) ValidateAll ¶ added in v0.0.8
func (m *StorageMessage_Extra) ValidateAll() error
ValidateAll checks the field values on StorageMessage_Extra with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageMessage_ExtraMultiError, or nil if none found.
type StorageMessage_ExtraMultiError ¶ added in v0.0.8
type StorageMessage_ExtraMultiError []error
StorageMessage_ExtraMultiError is an error wrapping multiple validation errors returned by StorageMessage_Extra.ValidateAll() if the designated constraints aren't met.
func (StorageMessage_ExtraMultiError) AllErrors ¶ added in v0.0.8
func (m StorageMessage_ExtraMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StorageMessage_ExtraMultiError) Error ¶ added in v0.0.8
func (m StorageMessage_ExtraMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StorageMessage_ExtraValidationError ¶ added in v0.0.8
type StorageMessage_ExtraValidationError struct {
// contains filtered or unexported fields
}
StorageMessage_ExtraValidationError is the validation error returned by StorageMessage_Extra.Validate if the designated constraints aren't met.
func (StorageMessage_ExtraValidationError) Cause ¶ added in v0.0.8
func (e StorageMessage_ExtraValidationError) Cause() error
Cause function returns cause value.
func (StorageMessage_ExtraValidationError) Error ¶ added in v0.0.8
func (e StorageMessage_ExtraValidationError) Error() string
Error satisfies the builtin error interface
func (StorageMessage_ExtraValidationError) ErrorName ¶ added in v0.0.8
func (e StorageMessage_ExtraValidationError) ErrorName() string
ErrorName returns error name.
func (StorageMessage_ExtraValidationError) Field ¶ added in v0.0.8
func (e StorageMessage_ExtraValidationError) Field() string
Field function returns field value.
func (StorageMessage_ExtraValidationError) Key ¶ added in v0.0.8
func (e StorageMessage_ExtraValidationError) Key() bool
Key function returns key value.
func (StorageMessage_ExtraValidationError) Reason ¶ added in v0.0.8
func (e StorageMessage_ExtraValidationError) Reason() string
Reason function returns reason value.
type StorageMessage_Users ¶ added in v0.0.8
type StorageMessage_Users struct { FromID int64 `protobuf:"varint,1,opt,name=fromID,proto3" json:"fromID,omitempty"` ToID int64 `protobuf:"varint,2,opt,name=toID,proto3" json:"toID,omitempty"` SessionID string `protobuf:"bytes,3,opt,name=sessionID,proto3" json:"sessionID,omitempty"` // contains filtered or unexported fields }
func (*StorageMessage_Users) Descriptor
deprecated
added in
v0.0.8
func (*StorageMessage_Users) Descriptor() ([]byte, []int)
Deprecated: Use StorageMessage_Users.ProtoReflect.Descriptor instead.
func (*StorageMessage_Users) GetFromID ¶ added in v0.0.8
func (x *StorageMessage_Users) GetFromID() int64
func (*StorageMessage_Users) GetSessionID ¶ added in v0.0.8
func (x *StorageMessage_Users) GetSessionID() string
func (*StorageMessage_Users) GetToID ¶ added in v0.0.8
func (x *StorageMessage_Users) GetToID() int64
func (*StorageMessage_Users) ProtoMessage ¶ added in v0.0.8
func (*StorageMessage_Users) ProtoMessage()
func (*StorageMessage_Users) ProtoReflect ¶ added in v0.0.8
func (x *StorageMessage_Users) ProtoReflect() protoreflect.Message
func (*StorageMessage_Users) Reset ¶ added in v0.0.8
func (x *StorageMessage_Users) Reset()
func (*StorageMessage_Users) String ¶ added in v0.0.8
func (x *StorageMessage_Users) String() string
func (*StorageMessage_Users) Validate ¶ added in v0.0.8
func (m *StorageMessage_Users) Validate() error
Validate checks the field values on StorageMessage_Users with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StorageMessage_Users) ValidateAll ¶ added in v0.0.8
func (m *StorageMessage_Users) ValidateAll() error
ValidateAll checks the field values on StorageMessage_Users with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageMessage_UsersMultiError, or nil if none found.
type StorageMessage_UsersMultiError ¶ added in v0.0.8
type StorageMessage_UsersMultiError []error
StorageMessage_UsersMultiError is an error wrapping multiple validation errors returned by StorageMessage_Users.ValidateAll() if the designated constraints aren't met.
func (StorageMessage_UsersMultiError) AllErrors ¶ added in v0.0.8
func (m StorageMessage_UsersMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StorageMessage_UsersMultiError) Error ¶ added in v0.0.8
func (m StorageMessage_UsersMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StorageMessage_UsersValidationError ¶ added in v0.0.8
type StorageMessage_UsersValidationError struct {
// contains filtered or unexported fields
}
StorageMessage_UsersValidationError is the validation error returned by StorageMessage_Users.Validate if the designated constraints aren't met.
func (StorageMessage_UsersValidationError) Cause ¶ added in v0.0.8
func (e StorageMessage_UsersValidationError) Cause() error
Cause function returns cause value.
func (StorageMessage_UsersValidationError) Error ¶ added in v0.0.8
func (e StorageMessage_UsersValidationError) Error() string
Error satisfies the builtin error interface
func (StorageMessage_UsersValidationError) ErrorName ¶ added in v0.0.8
func (e StorageMessage_UsersValidationError) ErrorName() string
ErrorName returns error name.
func (StorageMessage_UsersValidationError) Field ¶ added in v0.0.8
func (e StorageMessage_UsersValidationError) Field() string
Field function returns field value.
func (StorageMessage_UsersValidationError) Key ¶ added in v0.0.8
func (e StorageMessage_UsersValidationError) Key() bool
Key function returns key value.
func (StorageMessage_UsersValidationError) Reason ¶ added in v0.0.8
func (e StorageMessage_UsersValidationError) Reason() string
Reason function returns reason value.
type SyncHistoryMessageReq ¶ added in v0.0.9
type SyncHistoryMessageReq struct { Uid int64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` LastMsgId int64 `protobuf:"varint,2,opt,name=last_msg_id,json=lastMsgId,proto3" json:"last_msg_id,omitempty"` Page int32 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"` PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // contains filtered or unexported fields }
func (*SyncHistoryMessageReq) Descriptor
deprecated
added in
v0.0.9
func (*SyncHistoryMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use SyncHistoryMessageReq.ProtoReflect.Descriptor instead.
func (*SyncHistoryMessageReq) GetLastMsgId ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) GetLastMsgId() int64
func (*SyncHistoryMessageReq) GetPage ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) GetPage() int32
func (*SyncHistoryMessageReq) GetPageSize ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) GetPageSize() int32
func (*SyncHistoryMessageReq) GetUid ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) GetUid() int64
func (*SyncHistoryMessageReq) ProtoMessage ¶ added in v0.0.9
func (*SyncHistoryMessageReq) ProtoMessage()
func (*SyncHistoryMessageReq) ProtoReflect ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) ProtoReflect() protoreflect.Message
func (*SyncHistoryMessageReq) Reset ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) Reset()
func (*SyncHistoryMessageReq) String ¶ added in v0.0.9
func (x *SyncHistoryMessageReq) String() string
func (*SyncHistoryMessageReq) Validate ¶ added in v0.0.9
func (m *SyncHistoryMessageReq) Validate() error
Validate checks the field values on SyncHistoryMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*SyncHistoryMessageReq) ValidateAll ¶ added in v0.0.9
func (m *SyncHistoryMessageReq) ValidateAll() error
ValidateAll checks the field values on SyncHistoryMessageReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SyncHistoryMessageReqMultiError, or nil if none found.
type SyncHistoryMessageReqMultiError ¶ added in v0.0.9
type SyncHistoryMessageReqMultiError []error
SyncHistoryMessageReqMultiError is an error wrapping multiple validation errors returned by SyncHistoryMessageReq.ValidateAll() if the designated constraints aren't met.
func (SyncHistoryMessageReqMultiError) AllErrors ¶ added in v0.0.9
func (m SyncHistoryMessageReqMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SyncHistoryMessageReqMultiError) Error ¶ added in v0.0.9
func (m SyncHistoryMessageReqMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SyncHistoryMessageReqValidationError ¶ added in v0.0.9
type SyncHistoryMessageReqValidationError struct {
// contains filtered or unexported fields
}
SyncHistoryMessageReqValidationError is the validation error returned by SyncHistoryMessageReq.Validate if the designated constraints aren't met.
func (SyncHistoryMessageReqValidationError) Cause ¶ added in v0.0.9
func (e SyncHistoryMessageReqValidationError) Cause() error
Cause function returns cause value.
func (SyncHistoryMessageReqValidationError) Error ¶ added in v0.0.9
func (e SyncHistoryMessageReqValidationError) Error() string
Error satisfies the builtin error interface
func (SyncHistoryMessageReqValidationError) ErrorName ¶ added in v0.0.9
func (e SyncHistoryMessageReqValidationError) ErrorName() string
ErrorName returns error name.
func (SyncHistoryMessageReqValidationError) Field ¶ added in v0.0.9
func (e SyncHistoryMessageReqValidationError) Field() string
Field function returns field value.
func (SyncHistoryMessageReqValidationError) Key ¶ added in v0.0.9
func (e SyncHistoryMessageReqValidationError) Key() bool
Key function returns key value.
func (SyncHistoryMessageReqValidationError) Reason ¶ added in v0.0.9
func (e SyncHistoryMessageReqValidationError) Reason() string
Reason function returns reason value.
type SyncHistoryMessageResp ¶ added in v0.0.9
type SyncHistoryMessageResp struct { Error *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` Messages []*Message `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*SyncHistoryMessageResp) Descriptor
deprecated
added in
v0.0.9
func (*SyncHistoryMessageResp) Descriptor() ([]byte, []int)
Deprecated: Use SyncHistoryMessageResp.ProtoReflect.Descriptor instead.
func (*SyncHistoryMessageResp) GetError ¶ added in v0.0.9
func (x *SyncHistoryMessageResp) GetError() *errors.Error
func (*SyncHistoryMessageResp) GetMessages ¶ added in v0.0.9
func (x *SyncHistoryMessageResp) GetMessages() []*Message
func (*SyncHistoryMessageResp) GetTotal ¶ added in v0.0.9
func (x *SyncHistoryMessageResp) GetTotal() int32
func (*SyncHistoryMessageResp) ProtoMessage ¶ added in v0.0.9
func (*SyncHistoryMessageResp) ProtoMessage()
func (*SyncHistoryMessageResp) ProtoReflect ¶ added in v0.0.9
func (x *SyncHistoryMessageResp) ProtoReflect() protoreflect.Message
func (*SyncHistoryMessageResp) Reset ¶ added in v0.0.9
func (x *SyncHistoryMessageResp) Reset()
func (*SyncHistoryMessageResp) String ¶ added in v0.0.9
func (x *SyncHistoryMessageResp) String() string
func (*SyncHistoryMessageResp) Validate ¶ added in v0.0.9
func (m *SyncHistoryMessageResp) Validate() error
Validate checks the field values on SyncHistoryMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*SyncHistoryMessageResp) ValidateAll ¶ added in v0.0.9
func (m *SyncHistoryMessageResp) ValidateAll() error
ValidateAll checks the field values on SyncHistoryMessageResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SyncHistoryMessageRespMultiError, or nil if none found.
type SyncHistoryMessageRespMultiError ¶ added in v0.0.9
type SyncHistoryMessageRespMultiError []error
SyncHistoryMessageRespMultiError is an error wrapping multiple validation errors returned by SyncHistoryMessageResp.ValidateAll() if the designated constraints aren't met.
func (SyncHistoryMessageRespMultiError) AllErrors ¶ added in v0.0.9
func (m SyncHistoryMessageRespMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SyncHistoryMessageRespMultiError) Error ¶ added in v0.0.9
func (m SyncHistoryMessageRespMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SyncHistoryMessageRespValidationError ¶ added in v0.0.9
type SyncHistoryMessageRespValidationError struct {
// contains filtered or unexported fields
}
SyncHistoryMessageRespValidationError is the validation error returned by SyncHistoryMessageResp.Validate if the designated constraints aren't met.
func (SyncHistoryMessageRespValidationError) Cause ¶ added in v0.0.9
func (e SyncHistoryMessageRespValidationError) Cause() error
Cause function returns cause value.
func (SyncHistoryMessageRespValidationError) Error ¶ added in v0.0.9
func (e SyncHistoryMessageRespValidationError) Error() string
Error satisfies the builtin error interface
func (SyncHistoryMessageRespValidationError) ErrorName ¶ added in v0.0.9
func (e SyncHistoryMessageRespValidationError) ErrorName() string
ErrorName returns error name.
func (SyncHistoryMessageRespValidationError) Field ¶ added in v0.0.9
func (e SyncHistoryMessageRespValidationError) Field() string
Field function returns field value.
func (SyncHistoryMessageRespValidationError) Key ¶ added in v0.0.9
func (e SyncHistoryMessageRespValidationError) Key() bool
Key function returns key value.
func (SyncHistoryMessageRespValidationError) Reason ¶ added in v0.0.9
func (e SyncHistoryMessageRespValidationError) Reason() string
Reason function returns reason value.
type UnimplementedHistoryMessageServiceServer ¶ added in v0.0.9
type UnimplementedHistoryMessageServiceServer struct { }
UnimplementedHistoryMessageServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedHistoryMessageServiceServer) QuerySessionHistoryMessage ¶ added in v0.0.9
func (UnimplementedHistoryMessageServiceServer) QuerySessionHistoryMessage(context.Context, *QuerySessionHistoryMessageReq) (*QuerySessionHistoryMessageResp, error)
func (UnimplementedHistoryMessageServiceServer) SyncHistoryMessage ¶ added in v0.0.9
func (UnimplementedHistoryMessageServiceServer) SyncHistoryMessage(context.Context, *SyncHistoryMessageReq) (*SyncHistoryMessageResp, error)
type UnimplementedOfflineMessageServiceServer ¶ added in v0.0.6
type UnimplementedOfflineMessageServiceServer struct { }
UnimplementedOfflineMessageServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedOfflineMessageServiceServer) ConfirmLastMstID ¶ added in v0.0.9
func (UnimplementedOfflineMessageServiceServer) ConfirmLastMstID(context.Context, *ConfirmLastMsgIDReq) (*ConfirmLastMsgIDResp, error)
func (UnimplementedOfflineMessageServiceServer) QueryOfflineMessage ¶ added in v0.0.6
func (UnimplementedOfflineMessageServiceServer) QueryOfflineMessage(context.Context, *QueryOfflineMessageReq) (*QueryOfflineMessageResp, error)
type UnimplementedPushMessageServiceServer ¶ added in v0.0.6
type UnimplementedPushMessageServiceServer struct { }
UnimplementedPushMessageServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedPushMessageServiceServer) PushMessage ¶ added in v0.0.6
func (UnimplementedPushMessageServiceServer) PushMessage(context.Context, *PushMessageReq) (*PushMessageResp, error)
type UnsafeHistoryMessageServiceServer ¶ added in v0.0.9
type UnsafeHistoryMessageServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHistoryMessageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HistoryMessageServiceServer will result in compilation errors.
type UnsafeOfflineMessageServiceServer ¶ added in v0.0.6
type UnsafeOfflineMessageServiceServer interface {
// contains filtered or unexported methods
}
UnsafeOfflineMessageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OfflineMessageServiceServer will result in compilation errors.
type UnsafePushMessageServiceServer ¶ added in v0.0.6
type UnsafePushMessageServiceServer interface {
// contains filtered or unexported methods
}
UnsafePushMessageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PushMessageServiceServer will result in compilation errors.