v1

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2022 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 OfflineMessageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.message.v1.OfflineMessageService",
	HandlerType: (*OfflineMessageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryOfflineMessage",
			Handler:    _OfflineMessageService_QueryOfflineMessage_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 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 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) 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)
}

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)
	// 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 {
	Response    *response.BaseResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,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) GetFailedUsers added in v0.0.6 

func (x *PushMessageResp) GetFailedUsers() []int64

func (*PushMessageResp) GetResponse added in v0.0.6 

func (x *PushMessageResp) GetResponse() *response.BaseResponse

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 {
	Response *response.BaseResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,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) GetMessages 

func (x *QueryOfflineMessageResp) GetMessages() []*Message

func (*QueryOfflineMessageResp) GetResponse 

func (x *QueryOfflineMessageResp) GetResponse() *response.BaseResponse

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

type UnimplementedOfflineMessageServiceServer struct {
}

UnimplementedOfflineMessageServiceServer must be embedded to have forward compatible implementations.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.