v1

package
v0.0.9 Latest Latest
Warning

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

Go to latest
Published: May 29, 2023 License: MIT Imports: 24 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
var File_message_v1_message_proto protoreflect.FileDescriptor
View Source
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)

View Source
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)

View Source
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

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

Cause function returns cause value.

func (ConfirmLastMsgIDReqValidationError) Error added in v0.0.9

Error satisfies the builtin error interface

func (ConfirmLastMsgIDReqValidationError) ErrorName added in v0.0.9

ErrorName returns error name.

func (ConfirmLastMsgIDReqValidationError) Field added in v0.0.9

Field function returns field value.

func (ConfirmLastMsgIDReqValidationError) Key added in v0.0.9

Key function returns key value.

func (ConfirmLastMsgIDReqValidationError) Reason added in v0.0.9

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

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

Cause function returns cause value.

func (ConfirmLastMsgIDRespValidationError) Error added in v0.0.9

Error satisfies the builtin error interface

func (ConfirmLastMsgIDRespValidationError) ErrorName added in v0.0.9

ErrorName returns error name.

func (ConfirmLastMsgIDRespValidationError) Field added in v0.0.9

Field function returns field value.

func (ConfirmLastMsgIDRespValidationError) Key added in v0.0.9

Key function returns key value.

func (ConfirmLastMsgIDRespValidationError) Reason added in v0.0.9

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) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetContent added in v0.0.6

func (x *Message) GetContent() string

func (*Message) GetContentType added in v0.0.6

func (x *Message) GetContentType() MessageContentType

func (*Message) GetCreateTime added in v0.0.6

func (x *Message) GetCreateTime() int64

func (*Message) GetFrom added in v0.0.6

func (x *Message) GetFrom() int64

func (*Message) GetMsgId added in v0.0.6

func (x *Message) GetMsgId() int64

func (*Message) GetSessionId added in v0.0.6

func (x *Message) GetSessionId() string

func (*Message) GetSessionType added in v0.0.6

func (x *Message) GetSessionType() SessionType

func (*Message) GetTo added in v0.0.6

func (x *Message) GetTo() int64

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) Reset added in v0.0.6

func (x *Message) Reset()

func (*Message) String added in v0.0.6

func (x *Message) String() string

func (*Message) Validate added in v0.0.6

func (m *Message) Validate() error

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

func (m *Message) ValidateAll() error

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) Enum

func (MessageContentType) EnumDescriptor deprecated

func (MessageContentType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageContentType.Descriptor instead.

func (MessageContentType) Number

func (MessageContentType) String

func (x MessageContentType) String() string

func (MessageContentType) Type

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

Cause function returns cause value.

func (PushMessageReqValidationError) Error

Error satisfies the builtin error interface

func (PushMessageReqValidationError) ErrorName

func (e PushMessageReqValidationError) ErrorName() string

ErrorName returns error name.

func (PushMessageReqValidationError) Field

Field function returns field value.

func (PushMessageReqValidationError) Key

Key function returns key value.

func (PushMessageReqValidationError) Reason

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

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

Cause function returns cause value.

func (PushMessageRespValidationError) Error added in v0.0.6

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

Field function returns field value.

func (PushMessageRespValidationError) Key added in v0.0.6

Key function returns key value.

func (PushMessageRespValidationError) Reason added in v0.0.6

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

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

Cause function returns cause value.

func (QueryOfflineMessageReqValidationError) Error

Error satisfies the builtin error interface

func (QueryOfflineMessageReqValidationError) ErrorName

ErrorName returns error name.

func (QueryOfflineMessageReqValidationError) Field

Field function returns field value.

func (QueryOfflineMessageReqValidationError) Key

Key function returns key value.

func (QueryOfflineMessageReqValidationError) Reason

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

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

Cause function returns cause value.

func (QueryOfflineMessageRespValidationError) Error

Error satisfies the builtin error interface

func (QueryOfflineMessageRespValidationError) ErrorName

ErrorName returns error name.

func (QueryOfflineMessageRespValidationError) Field

Field function returns field value.

func (QueryOfflineMessageRespValidationError) Key

Key function returns key value.

func (QueryOfflineMessageRespValidationError) Reason

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 (*QuerySessionHistoryMessageReq) ProtoMessage added in v0.0.9

func (*QuerySessionHistoryMessageReq) ProtoMessage()

func (*QuerySessionHistoryMessageReq) ProtoReflect added in v0.0.9

func (*QuerySessionHistoryMessageReq) Reset added in v0.0.9

func (x *QuerySessionHistoryMessageReq) Reset()

func (*QuerySessionHistoryMessageReq) String added in v0.0.9

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

AllErrors returns a list of validation violation errors.

func (QuerySessionHistoryMessageReqMultiError) Error added in v0.0.9

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

Cause function returns cause value.

func (QuerySessionHistoryMessageReqValidationError) Error added in v0.0.9

Error satisfies the builtin error interface

func (QuerySessionHistoryMessageReqValidationError) ErrorName added in v0.0.9

ErrorName returns error name.

func (QuerySessionHistoryMessageReqValidationError) Field added in v0.0.9

Field function returns field value.

func (QuerySessionHistoryMessageReqValidationError) Key added in v0.0.9

Key function returns key value.

func (QuerySessionHistoryMessageReqValidationError) Reason added in v0.0.9

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 (*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 (*QuerySessionHistoryMessageResp) Reset added in v0.0.9

func (x *QuerySessionHistoryMessageResp) Reset()

func (*QuerySessionHistoryMessageResp) String added in v0.0.9

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

AllErrors returns a list of validation violation errors.

func (QuerySessionHistoryMessageRespMultiError) Error added in v0.0.9

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

Cause function returns cause value.

func (QuerySessionHistoryMessageRespValidationError) Error added in v0.0.9

Error satisfies the builtin error interface

func (QuerySessionHistoryMessageRespValidationError) ErrorName added in v0.0.9

ErrorName returns error name.

func (QuerySessionHistoryMessageRespValidationError) Field added in v0.0.9

Field function returns field value.

func (QuerySessionHistoryMessageRespValidationError) Key added in v0.0.9

Key function returns key value.

func (QuerySessionHistoryMessageRespValidationError) Reason added in v0.0.9

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

Cause function returns cause value.

func (SendMessageReqValidationError) Error

Error satisfies the builtin error interface

func (SendMessageReqValidationError) ErrorName

func (e SendMessageReqValidationError) ErrorName() string

ErrorName returns error name.

func (SendMessageReqValidationError) Field

Field function returns field value.

func (SendMessageReqValidationError) Key

Key function returns key value.

func (SendMessageReqValidationError) Reason

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) 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

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

Cause function returns cause value.

func (StorageMessageValidationError) Error added in v0.0.8

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

Field function returns field value.

func (StorageMessageValidationError) Key added in v0.0.8

Key function returns key value.

func (StorageMessageValidationError) Reason added in v0.0.8

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

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

Cause function returns cause value.

func (StorageMessage_ContentValidationError) Error added in v0.0.8

Error satisfies the builtin error interface

func (StorageMessage_ContentValidationError) ErrorName added in v0.0.8

ErrorName returns error name.

func (StorageMessage_ContentValidationError) Field added in v0.0.8

Field function returns field value.

func (StorageMessage_ContentValidationError) Key added in v0.0.8

Key function returns key value.

func (StorageMessage_ContentValidationError) Reason added in v0.0.8

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

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

Cause function returns cause value.

func (StorageMessage_ExtraValidationError) Error added in v0.0.8

Error satisfies the builtin error interface

func (StorageMessage_ExtraValidationError) ErrorName added in v0.0.8

ErrorName returns error name.

func (StorageMessage_ExtraValidationError) Field added in v0.0.8

Field function returns field value.

func (StorageMessage_ExtraValidationError) Key added in v0.0.8

Key function returns key value.

func (StorageMessage_ExtraValidationError) Reason added in v0.0.8

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

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

Cause function returns cause value.

func (StorageMessage_UsersValidationError) Error added in v0.0.8

Error satisfies the builtin error interface

func (StorageMessage_UsersValidationError) ErrorName added in v0.0.8

ErrorName returns error name.

func (StorageMessage_UsersValidationError) Field added in v0.0.8

Field function returns field value.

func (StorageMessage_UsersValidationError) Key added in v0.0.8

Key function returns key value.

func (StorageMessage_UsersValidationError) Reason added in v0.0.8

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

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

Cause function returns cause value.

func (SyncHistoryMessageReqValidationError) Error added in v0.0.9

Error satisfies the builtin error interface

func (SyncHistoryMessageReqValidationError) ErrorName added in v0.0.9

ErrorName returns error name.

func (SyncHistoryMessageReqValidationError) Field added in v0.0.9

Field function returns field value.

func (SyncHistoryMessageReqValidationError) Key added in v0.0.9

Key function returns key value.

func (SyncHistoryMessageReqValidationError) Reason added in v0.0.9

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

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

Cause function returns cause value.

func (SyncHistoryMessageRespValidationError) Error added in v0.0.9

Error satisfies the builtin error interface

func (SyncHistoryMessageRespValidationError) ErrorName added in v0.0.9

ErrorName returns error name.

func (SyncHistoryMessageRespValidationError) Field added in v0.0.9

Field function returns field value.

func (SyncHistoryMessageRespValidationError) Key added in v0.0.9

Key function returns key value.

func (SyncHistoryMessageRespValidationError) Reason added in v0.0.9

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) SyncHistoryMessage added in v0.0.9

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) QueryOfflineMessage added in v0.0.6

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL