message

package
v0.0.0-...-542fe02 Latest Latest
Warning

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

Go to latest
Published: Sep 4, 2023 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MessageActionResponse_StatusMsg_DEFAULT string
View Source
var MessageChatResponse_StatusMsg_DEFAULT string
View Source
var Message_CreateTime_DEFAULT string

Functions

This section is empty.

Types

type Message

type Message struct {
	// 消息id
	ID int64 `thrift:"id,1" form:"id" json:"id" query:"id"`
	// 该消息接收者的id
	ToUserID int64 `thrift:"to_user_id,2" form:"to_user_id" json:"to_user_id" query:"to_user_id"`
	// 该消息发送者的id
	FromUserID int64 `thrift:"from_user_id,3" form:"from_user_id" json:"from_user_id" query:"from_user_id"`
	// 消息内容
	Content string `thrift:"content,4" form:"content" json:"content" query:"content"`
	// 消息创建时间
	CreateTime *string `thrift:"create_time,5,optional" form:"create_time" json:"create_time,omitempty" query:"create_time"`
}

func NewMessage

func NewMessage() *Message

func (*Message) GetContent

func (p *Message) GetContent() (v string)

func (*Message) GetCreateTime

func (p *Message) GetCreateTime() (v string)

func (*Message) GetFromUserID

func (p *Message) GetFromUserID() (v int64)

func (*Message) GetID

func (p *Message) GetID() (v int64)

func (*Message) GetToUserID

func (p *Message) GetToUserID() (v int64)

func (*Message) IsSetCreateTime

func (p *Message) IsSetCreateTime() bool

func (*Message) Read

func (p *Message) Read(iprot thrift.TProtocol) (err error)

func (*Message) ReadField1

func (p *Message) ReadField1(iprot thrift.TProtocol) error

func (*Message) ReadField2

func (p *Message) ReadField2(iprot thrift.TProtocol) error

func (*Message) ReadField3

func (p *Message) ReadField3(iprot thrift.TProtocol) error

func (*Message) ReadField4

func (p *Message) ReadField4(iprot thrift.TProtocol) error

func (*Message) ReadField5

func (p *Message) ReadField5(iprot thrift.TProtocol) error

func (*Message) String

func (p *Message) String() string

func (*Message) Write

func (p *Message) Write(oprot thrift.TProtocol) (err error)

type MessageActionRequest

type MessageActionRequest struct {
	// 用户鉴权token
	Token string `thrift:"token,1" form:"token" json:"token" query:"token"`
	// 对方用户id
	ToUserID int64 `thrift:"to_user_id,2" form:"to_user_id" json:"to_user_id" query:"to_user_id"`
	// 1-发送消息
	ActionType int32 `thrift:"action_type,3" form:"action_type" json:"action_type" query:"action_type"`
	// 消息内容
	Content string `thrift:"content,4" form:"content" json:"content" query:"content"`
}

--------------发送消息--------------

var MessageServiceMessageActionArgs_Req_DEFAULT *MessageActionRequest

func NewMessageActionRequest

func NewMessageActionRequest() *MessageActionRequest

func (*MessageActionRequest) GetActionType

func (p *MessageActionRequest) GetActionType() (v int32)

func (*MessageActionRequest) GetContent

func (p *MessageActionRequest) GetContent() (v string)

func (*MessageActionRequest) GetToUserID

func (p *MessageActionRequest) GetToUserID() (v int64)

func (*MessageActionRequest) GetToken

func (p *MessageActionRequest) GetToken() (v string)

func (*MessageActionRequest) Read

func (p *MessageActionRequest) Read(iprot thrift.TProtocol) (err error)

func (*MessageActionRequest) ReadField1

func (p *MessageActionRequest) ReadField1(iprot thrift.TProtocol) error

func (*MessageActionRequest) ReadField2

func (p *MessageActionRequest) ReadField2(iprot thrift.TProtocol) error

func (*MessageActionRequest) ReadField3

func (p *MessageActionRequest) ReadField3(iprot thrift.TProtocol) error

func (*MessageActionRequest) ReadField4

func (p *MessageActionRequest) ReadField4(iprot thrift.TProtocol) error

func (*MessageActionRequest) String

func (p *MessageActionRequest) String() string

func (*MessageActionRequest) Write

func (p *MessageActionRequest) Write(oprot thrift.TProtocol) (err error)

type MessageActionResponse

type MessageActionResponse struct {
	// 状态码,0-成功,其他值-失败
	StatusCode int32 `thrift:"status_code,1" form:"status_code" json:"status_code" query:"status_code"`
	// 返回状态描述
	StatusMsg *string `thrift:"status_msg,2,optional" form:"status_msg" json:"status_msg,omitempty" query:"status_msg"`
}
var MessageServiceMessageActionResult_Success_DEFAULT *MessageActionResponse

func NewMessageActionResponse

func NewMessageActionResponse() *MessageActionResponse

func (*MessageActionResponse) GetStatusCode

func (p *MessageActionResponse) GetStatusCode() (v int32)

func (*MessageActionResponse) GetStatusMsg

func (p *MessageActionResponse) GetStatusMsg() (v string)

func (*MessageActionResponse) IsSetStatusMsg

func (p *MessageActionResponse) IsSetStatusMsg() bool

func (*MessageActionResponse) Read

func (p *MessageActionResponse) Read(iprot thrift.TProtocol) (err error)

func (*MessageActionResponse) ReadField1

func (p *MessageActionResponse) ReadField1(iprot thrift.TProtocol) error

func (*MessageActionResponse) ReadField2

func (p *MessageActionResponse) ReadField2(iprot thrift.TProtocol) error

func (*MessageActionResponse) String

func (p *MessageActionResponse) String() string

func (*MessageActionResponse) Write

func (p *MessageActionResponse) Write(oprot thrift.TProtocol) (err error)

type MessageChatRequest

type MessageChatRequest struct {
	// 用户鉴权token
	Token string `thrift:"token,1" form:"token" json:"token" query:"token"`
	// 对方用户id
	ToUserID int64 `thrift:"to_user_id,2" form:"to_user_id" json:"to_user_id" query:"to_user_id"`
	// 上次最新消息的时间(新增字段-apk更新中)
	PreMsgTime int64 `thrift:"pre_msg_time,3" form:"pre_msg_time" json:"pre_msg_time" query:"pre_msg_time"`
}

--------------聊天记录--------------

var MessageServiceMessageChatArgs_Req_DEFAULT *MessageChatRequest

func NewMessageChatRequest

func NewMessageChatRequest() *MessageChatRequest

func (*MessageChatRequest) GetPreMsgTime

func (p *MessageChatRequest) GetPreMsgTime() (v int64)

func (*MessageChatRequest) GetToUserID

func (p *MessageChatRequest) GetToUserID() (v int64)

func (*MessageChatRequest) GetToken

func (p *MessageChatRequest) GetToken() (v string)

func (*MessageChatRequest) Read

func (p *MessageChatRequest) Read(iprot thrift.TProtocol) (err error)

func (*MessageChatRequest) ReadField1

func (p *MessageChatRequest) ReadField1(iprot thrift.TProtocol) error

func (*MessageChatRequest) ReadField2

func (p *MessageChatRequest) ReadField2(iprot thrift.TProtocol) error

func (*MessageChatRequest) ReadField3

func (p *MessageChatRequest) ReadField3(iprot thrift.TProtocol) error

func (*MessageChatRequest) String

func (p *MessageChatRequest) String() string

func (*MessageChatRequest) Write

func (p *MessageChatRequest) Write(oprot thrift.TProtocol) (err error)

type MessageChatResponse

type MessageChatResponse struct {
	// 状态码,0-成功,其他值-失败
	StatusCode int32 `thrift:"status_code,1" form:"status_code" json:"status_code" query:"status_code"`
	// 返回状态描述
	StatusMsg *string `thrift:"status_msg,2,optional" form:"status_msg" json:"status_msg,omitempty" query:"status_msg"`
	// 消息列表
	MessageList []*Message `thrift:"message_list,3" form:"message_list" json:"message_list" query:"message_list"`
}
var MessageServiceMessageChatResult_Success_DEFAULT *MessageChatResponse

func NewMessageChatResponse

func NewMessageChatResponse() *MessageChatResponse

func (*MessageChatResponse) GetMessageList

func (p *MessageChatResponse) GetMessageList() (v []*Message)

func (*MessageChatResponse) GetStatusCode

func (p *MessageChatResponse) GetStatusCode() (v int32)

func (*MessageChatResponse) GetStatusMsg

func (p *MessageChatResponse) GetStatusMsg() (v string)

func (*MessageChatResponse) IsSetStatusMsg

func (p *MessageChatResponse) IsSetStatusMsg() bool

func (*MessageChatResponse) Read

func (p *MessageChatResponse) Read(iprot thrift.TProtocol) (err error)

func (*MessageChatResponse) ReadField1

func (p *MessageChatResponse) ReadField1(iprot thrift.TProtocol) error

func (*MessageChatResponse) ReadField2

func (p *MessageChatResponse) ReadField2(iprot thrift.TProtocol) error

func (*MessageChatResponse) ReadField3

func (p *MessageChatResponse) ReadField3(iprot thrift.TProtocol) error

func (*MessageChatResponse) String

func (p *MessageChatResponse) String() string

func (*MessageChatResponse) Write

func (p *MessageChatResponse) Write(oprot thrift.TProtocol) (err error)

type MessageService

type MessageService interface {
	// 发送消息
	MessageAction(ctx context.Context, req *MessageActionRequest) (r *MessageActionResponse, err error)
	// 获取聊天记录
	MessageChat(ctx context.Context, req *MessageChatRequest) (r *MessageChatResponse, err error)
}

type MessageServiceClient

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

func NewMessageServiceClient

func NewMessageServiceClient(c thrift.TClient) *MessageServiceClient

func NewMessageServiceClientProtocol

func NewMessageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MessageServiceClient

func (*MessageServiceClient) Client_

func (p *MessageServiceClient) Client_() thrift.TClient

func (*MessageServiceClient) MessageAction

func (*MessageServiceClient) MessageChat

type MessageServiceMessageActionArgs

type MessageServiceMessageActionArgs struct {
	Req *MessageActionRequest `thrift:"req,1"`
}

func NewMessageServiceMessageActionArgs

func NewMessageServiceMessageActionArgs() *MessageServiceMessageActionArgs

func (*MessageServiceMessageActionArgs) GetReq

func (*MessageServiceMessageActionArgs) IsSetReq

func (p *MessageServiceMessageActionArgs) IsSetReq() bool

func (*MessageServiceMessageActionArgs) Read

func (*MessageServiceMessageActionArgs) ReadField1

func (*MessageServiceMessageActionArgs) String

func (*MessageServiceMessageActionArgs) Write

func (p *MessageServiceMessageActionArgs) Write(oprot thrift.TProtocol) (err error)

type MessageServiceMessageActionResult

type MessageServiceMessageActionResult struct {
	Success *MessageActionResponse `thrift:"success,0,optional"`
}

func NewMessageServiceMessageActionResult

func NewMessageServiceMessageActionResult() *MessageServiceMessageActionResult

func (*MessageServiceMessageActionResult) GetSuccess

func (*MessageServiceMessageActionResult) IsSetSuccess

func (p *MessageServiceMessageActionResult) IsSetSuccess() bool

func (*MessageServiceMessageActionResult) Read

func (*MessageServiceMessageActionResult) ReadField0

func (*MessageServiceMessageActionResult) String

func (*MessageServiceMessageActionResult) Write

type MessageServiceMessageChatArgs

type MessageServiceMessageChatArgs struct {
	Req *MessageChatRequest `thrift:"req,1"`
}

func NewMessageServiceMessageChatArgs

func NewMessageServiceMessageChatArgs() *MessageServiceMessageChatArgs

func (*MessageServiceMessageChatArgs) GetReq

func (*MessageServiceMessageChatArgs) IsSetReq

func (p *MessageServiceMessageChatArgs) IsSetReq() bool

func (*MessageServiceMessageChatArgs) Read

func (p *MessageServiceMessageChatArgs) Read(iprot thrift.TProtocol) (err error)

func (*MessageServiceMessageChatArgs) ReadField1

func (p *MessageServiceMessageChatArgs) ReadField1(iprot thrift.TProtocol) error

func (*MessageServiceMessageChatArgs) String

func (*MessageServiceMessageChatArgs) Write

func (p *MessageServiceMessageChatArgs) Write(oprot thrift.TProtocol) (err error)

type MessageServiceMessageChatResult

type MessageServiceMessageChatResult struct {
	Success *MessageChatResponse `thrift:"success,0,optional"`
}

func NewMessageServiceMessageChatResult

func NewMessageServiceMessageChatResult() *MessageServiceMessageChatResult

func (*MessageServiceMessageChatResult) GetSuccess

func (*MessageServiceMessageChatResult) IsSetSuccess

func (p *MessageServiceMessageChatResult) IsSetSuccess() bool

func (*MessageServiceMessageChatResult) Read

func (*MessageServiceMessageChatResult) ReadField0

func (*MessageServiceMessageChatResult) String

func (*MessageServiceMessageChatResult) Write

func (p *MessageServiceMessageChatResult) Write(oprot thrift.TProtocol) (err error)

type MessageServiceProcessor

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

func NewMessageServiceProcessor

func NewMessageServiceProcessor(handler MessageService) *MessageServiceProcessor

func (*MessageServiceProcessor) AddToProcessorMap

func (p *MessageServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*MessageServiceProcessor) GetProcessorFunction

func (p *MessageServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*MessageServiceProcessor) Process

func (p *MessageServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*MessageServiceProcessor) ProcessorMap

Jump to

Keyboard shortcuts

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