v1

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2022 License: MIT Imports: 23 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 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        string             `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To          string             `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` // to user id or group id
	SessionType v1.SessionType     ``                                                          /* 132-byte string literal not displayed */
	SessionId   int64              `protobuf:"varint,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() string

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

func (*Message) GetSessionType added in v0.0.6 

func (x *Message) GetSessionType() v1.SessionType

func (*Message) GetTo added in v0.0.6 

func (x *Message) GetTo() string

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 []string `protobuf:"bytes,2,rep,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() []string

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 []string               `protobuf:"bytes,2,rep,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() []string

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 {
	UserId    string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,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) GetUserId 

func (x *QueryOfflineMessageReq) GetUserId() string

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        string             `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To          string             `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	SessionType v1.SessionType     `` /* 132-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() string

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() v1.SessionType

func (*SendMessageReq) GetTo added in v0.0.6 

func (x *SendMessageReq) GetTo() string

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 SendMessageResp 

type SendMessageResp struct {
	SessionId int64 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	MsgId     int64 `protobuf:"varint,3,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	// contains filtered or unexported fields
}

SendMessageResp is response body for sendMessage

func (*SendMessageResp) Descriptor deprecated 

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

Deprecated: Use SendMessageResp.ProtoReflect.Descriptor instead.

func (*SendMessageResp) GetMsgId added in v0.0.6 

func (x *SendMessageResp) GetMsgId() int64

func (*SendMessageResp) GetSessionId added in v0.0.3 

func (x *SendMessageResp) GetSessionId() int64

func (*SendMessageResp) ProtoMessage 

func (*SendMessageResp) ProtoMessage()

func (*SendMessageResp) ProtoReflect 

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

func (*SendMessageResp) Reset 

func (x *SendMessageResp) Reset()

func (*SendMessageResp) String 

func (x *SendMessageResp) String() string

func (*SendMessageResp) Validate 

func (m *SendMessageResp) Validate() error

Validate checks the field values on SendMessageResp 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 (*SendMessageResp) ValidateAll 

func (m *SendMessageResp) ValidateAll() error

ValidateAll checks the field values on SendMessageResp 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 SendMessageRespMultiError, or nil if none found.

type SendMessageRespMultiError 

type SendMessageRespMultiError []error

SendMessageRespMultiError is an error wrapping multiple validation errors returned by SendMessageResp.ValidateAll() if the designated constraints aren't met.

func (SendMessageRespMultiError) AllErrors 

func (m SendMessageRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SendMessageRespMultiError) Error 

func (m SendMessageRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SendMessageRespValidationError 

type SendMessageRespValidationError struct {
	// contains filtered or unexported fields
}

SendMessageRespValidationError is the validation error returned by SendMessageResp.Validate if the designated constraints aren't met.

func (SendMessageRespValidationError) Cause 

func (e SendMessageRespValidationError) Cause() error

Cause function returns cause value.

func (SendMessageRespValidationError) Error 

func (e SendMessageRespValidationError) Error() string

Error satisfies the builtin error interface

func (SendMessageRespValidationError) ErrorName 

func (e SendMessageRespValidationError) ErrorName() string

ErrorName returns error name.

func (SendMessageRespValidationError) Field 

func (e SendMessageRespValidationError) Field() string

Field function returns field value.

func (SendMessageRespValidationError) Key 

func (e SendMessageRespValidationError) Key() bool

Key function returns key value.

func (SendMessageRespValidationError) Reason 

func (e SendMessageRespValidationError) 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.