message

package
v0.0.0-...-18974b4 Latest Latest
Warning

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

Go to latest
Published: Mar 5, 2023 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ChatRecordResponse_MessageList_DEFAULT []*MessageInfo
View Source
var ChatRecordResponse_StatusMsg_DEFAULT string
View Source
var KitexUnusedProtection = struct{}{}

KitexUnusedProtection is used to prevent 'imported and not used' error.

View Source
var MessageInfo_CreateTime_DEFAULT int64

Functions

This section is empty.

Types

type ChatRecordRequest

type ChatRecordRequest struct {
	UserId     int64 `thrift:"user_id,1" frugal:"1,default,i64" json:"user_id"`
	ToUserId   int64 `thrift:"to_user_id,2" frugal:"2,default,i64" json:"to_user_id"`
	LatestTime int64 `thrift:"latest_time,3" frugal:"3,default,i64" json:"latest_time"`
}
var MessageServiceGetChatRecordArgs_Request_DEFAULT *ChatRecordRequest

func NewChatRecordRequest

func NewChatRecordRequest() *ChatRecordRequest

func (*ChatRecordRequest) BLength

func (p *ChatRecordRequest) BLength() int

func (*ChatRecordRequest) DeepEqual

func (p *ChatRecordRequest) DeepEqual(ano *ChatRecordRequest) bool

func (*ChatRecordRequest) FastRead

func (p *ChatRecordRequest) FastRead(buf []byte) (int, error)

func (*ChatRecordRequest) FastReadField1

func (p *ChatRecordRequest) FastReadField1(buf []byte) (int, error)

func (*ChatRecordRequest) FastReadField2

func (p *ChatRecordRequest) FastReadField2(buf []byte) (int, error)

func (*ChatRecordRequest) FastReadField3

func (p *ChatRecordRequest) FastReadField3(buf []byte) (int, error)

func (*ChatRecordRequest) FastWrite

func (p *ChatRecordRequest) FastWrite(buf []byte) int

for compatibility

func (*ChatRecordRequest) FastWriteNocopy

func (p *ChatRecordRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ChatRecordRequest) Field1DeepEqual

func (p *ChatRecordRequest) Field1DeepEqual(src int64) bool

func (*ChatRecordRequest) Field2DeepEqual

func (p *ChatRecordRequest) Field2DeepEqual(src int64) bool

func (*ChatRecordRequest) Field3DeepEqual

func (p *ChatRecordRequest) Field3DeepEqual(src int64) bool

func (*ChatRecordRequest) GetLatestTime

func (p *ChatRecordRequest) GetLatestTime() (v int64)

func (*ChatRecordRequest) GetToUserId

func (p *ChatRecordRequest) GetToUserId() (v int64)

func (*ChatRecordRequest) GetUserId

func (p *ChatRecordRequest) GetUserId() (v int64)

func (*ChatRecordRequest) InitDefault

func (p *ChatRecordRequest) InitDefault()

func (*ChatRecordRequest) Read

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

func (*ChatRecordRequest) ReadField1

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

func (*ChatRecordRequest) ReadField2

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

func (*ChatRecordRequest) ReadField3

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

func (*ChatRecordRequest) SetLatestTime

func (p *ChatRecordRequest) SetLatestTime(val int64)

func (*ChatRecordRequest) SetToUserId

func (p *ChatRecordRequest) SetToUserId(val int64)

func (*ChatRecordRequest) SetUserId

func (p *ChatRecordRequest) SetUserId(val int64)

func (*ChatRecordRequest) String

func (p *ChatRecordRequest) String() string

func (*ChatRecordRequest) Write

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

type ChatRecordResponse

type ChatRecordResponse struct {
	StatusCode  int64          `thrift:"status_code,1" frugal:"1,default,i64" json:"status_code"`
	StatusMsg   *string        `thrift:"status_msg,2,optional" frugal:"2,optional,string" json:"status_msg,omitempty"`
	MessageList []*MessageInfo `thrift:"message_list,3,optional" frugal:"3,optional,list<MessageInfo>" json:"message_list,omitempty"`
}
var MessageServiceGetChatRecordResult_Success_DEFAULT *ChatRecordResponse

func NewChatRecordResponse

func NewChatRecordResponse() *ChatRecordResponse

func (*ChatRecordResponse) BLength

func (p *ChatRecordResponse) BLength() int

func (*ChatRecordResponse) DeepEqual

func (p *ChatRecordResponse) DeepEqual(ano *ChatRecordResponse) bool

func (*ChatRecordResponse) FastRead

func (p *ChatRecordResponse) FastRead(buf []byte) (int, error)

func (*ChatRecordResponse) FastReadField1

func (p *ChatRecordResponse) FastReadField1(buf []byte) (int, error)

func (*ChatRecordResponse) FastReadField2

func (p *ChatRecordResponse) FastReadField2(buf []byte) (int, error)

func (*ChatRecordResponse) FastReadField3

func (p *ChatRecordResponse) FastReadField3(buf []byte) (int, error)

func (*ChatRecordResponse) FastWrite

func (p *ChatRecordResponse) FastWrite(buf []byte) int

for compatibility

func (*ChatRecordResponse) FastWriteNocopy

func (p *ChatRecordResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ChatRecordResponse) Field1DeepEqual

func (p *ChatRecordResponse) Field1DeepEqual(src int64) bool

func (*ChatRecordResponse) Field2DeepEqual

func (p *ChatRecordResponse) Field2DeepEqual(src *string) bool

func (*ChatRecordResponse) Field3DeepEqual

func (p *ChatRecordResponse) Field3DeepEqual(src []*MessageInfo) bool

func (*ChatRecordResponse) GetMessageList

func (p *ChatRecordResponse) GetMessageList() (v []*MessageInfo)

func (*ChatRecordResponse) GetStatusCode

func (p *ChatRecordResponse) GetStatusCode() (v int64)

func (*ChatRecordResponse) GetStatusMsg

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

func (*ChatRecordResponse) InitDefault

func (p *ChatRecordResponse) InitDefault()

func (*ChatRecordResponse) IsSetMessageList

func (p *ChatRecordResponse) IsSetMessageList() bool

func (*ChatRecordResponse) IsSetStatusMsg

func (p *ChatRecordResponse) IsSetStatusMsg() bool

func (*ChatRecordResponse) Read

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

func (*ChatRecordResponse) ReadField1

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

func (*ChatRecordResponse) ReadField2

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

func (*ChatRecordResponse) ReadField3

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

func (*ChatRecordResponse) SetMessageList

func (p *ChatRecordResponse) SetMessageList(val []*MessageInfo)

func (*ChatRecordResponse) SetStatusCode

func (p *ChatRecordResponse) SetStatusCode(val int64)

func (*ChatRecordResponse) SetStatusMsg

func (p *ChatRecordResponse) SetStatusMsg(val *string)

func (*ChatRecordResponse) String

func (p *ChatRecordResponse) String() string

func (*ChatRecordResponse) Write

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

type MessageInfo

type MessageInfo struct {
	Id         int64  `thrift:"id,1,required" frugal:"1,required,i64" json:"id"`
	ToUserId   int64  `thrift:"to_user_id,2,required" frugal:"2,required,i64" json:"to_user_id"`
	FromUserId int64  `thrift:"from_user_id,3,required" frugal:"3,required,i64" json:"from_user_id"`
	Content    string `thrift:"content,4,required" frugal:"4,required,string" json:"content"`
	CreateTime *int64 `thrift:"create_time,5,optional" frugal:"5,optional,i64" json:"create_time,omitempty"`
}

func NewMessageInfo

func NewMessageInfo() *MessageInfo

func (*MessageInfo) BLength

func (p *MessageInfo) BLength() int

func (*MessageInfo) DeepEqual

func (p *MessageInfo) DeepEqual(ano *MessageInfo) bool

func (*MessageInfo) FastRead

func (p *MessageInfo) FastRead(buf []byte) (int, error)

func (*MessageInfo) FastReadField1

func (p *MessageInfo) FastReadField1(buf []byte) (int, error)

func (*MessageInfo) FastReadField2

func (p *MessageInfo) FastReadField2(buf []byte) (int, error)

func (*MessageInfo) FastReadField3

func (p *MessageInfo) FastReadField3(buf []byte) (int, error)

func (*MessageInfo) FastReadField4

func (p *MessageInfo) FastReadField4(buf []byte) (int, error)

func (*MessageInfo) FastReadField5

func (p *MessageInfo) FastReadField5(buf []byte) (int, error)

func (*MessageInfo) FastWrite

func (p *MessageInfo) FastWrite(buf []byte) int

for compatibility

func (*MessageInfo) FastWriteNocopy

func (p *MessageInfo) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageInfo) Field1DeepEqual

func (p *MessageInfo) Field1DeepEqual(src int64) bool

func (*MessageInfo) Field2DeepEqual

func (p *MessageInfo) Field2DeepEqual(src int64) bool

func (*MessageInfo) Field3DeepEqual

func (p *MessageInfo) Field3DeepEqual(src int64) bool

func (*MessageInfo) Field4DeepEqual

func (p *MessageInfo) Field4DeepEqual(src string) bool

func (*MessageInfo) Field5DeepEqual

func (p *MessageInfo) Field5DeepEqual(src *int64) bool

func (*MessageInfo) GetContent

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

func (*MessageInfo) GetCreateTime

func (p *MessageInfo) GetCreateTime() (v int64)

func (*MessageInfo) GetFromUserId

func (p *MessageInfo) GetFromUserId() (v int64)

func (*MessageInfo) GetId

func (p *MessageInfo) GetId() (v int64)

func (*MessageInfo) GetToUserId

func (p *MessageInfo) GetToUserId() (v int64)

func (*MessageInfo) InitDefault

func (p *MessageInfo) InitDefault()

func (*MessageInfo) IsSetCreateTime

func (p *MessageInfo) IsSetCreateTime() bool

func (*MessageInfo) Read

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

func (*MessageInfo) ReadField1

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

func (*MessageInfo) ReadField2

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

func (*MessageInfo) ReadField3

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

func (*MessageInfo) ReadField4

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

func (*MessageInfo) ReadField5

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

func (*MessageInfo) SetContent

func (p *MessageInfo) SetContent(val string)

func (*MessageInfo) SetCreateTime

func (p *MessageInfo) SetCreateTime(val *int64)

func (*MessageInfo) SetFromUserId

func (p *MessageInfo) SetFromUserId(val int64)

func (*MessageInfo) SetId

func (p *MessageInfo) SetId(val int64)

func (*MessageInfo) SetToUserId

func (p *MessageInfo) SetToUserId(val int64)

func (*MessageInfo) String

func (p *MessageInfo) String() string

func (*MessageInfo) Write

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

type MessageRequest

type MessageRequest struct {
	UserId     int64  `thrift:"user_id,1" frugal:"1,default,i64" json:"user_id"`
	ToUserId   int64  `thrift:"to_user_id,2" frugal:"2,default,i64" json:"to_user_id"`
	ActionType bool   `thrift:"action_type,3" frugal:"3,default,bool" json:"action_type"`
	Content    string `thrift:"content,4" frugal:"4,default,string" json:"content"`
	SendTime   int64  `thrift:"send_time,5" frugal:"5,default,i64" json:"send_time"`
}
var MessageServiceSendMessageArgs_Request_DEFAULT *MessageRequest

func NewMessageRequest

func NewMessageRequest() *MessageRequest

func (*MessageRequest) BLength

func (p *MessageRequest) BLength() int

func (*MessageRequest) DeepEqual

func (p *MessageRequest) DeepEqual(ano *MessageRequest) bool

func (*MessageRequest) FastRead

func (p *MessageRequest) FastRead(buf []byte) (int, error)

func (*MessageRequest) FastReadField1

func (p *MessageRequest) FastReadField1(buf []byte) (int, error)

func (*MessageRequest) FastReadField2

func (p *MessageRequest) FastReadField2(buf []byte) (int, error)

func (*MessageRequest) FastReadField3

func (p *MessageRequest) FastReadField3(buf []byte) (int, error)

func (*MessageRequest) FastReadField4

func (p *MessageRequest) FastReadField4(buf []byte) (int, error)

func (*MessageRequest) FastReadField5

func (p *MessageRequest) FastReadField5(buf []byte) (int, error)

func (*MessageRequest) FastWrite

func (p *MessageRequest) FastWrite(buf []byte) int

for compatibility

func (*MessageRequest) FastWriteNocopy

func (p *MessageRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageRequest) Field1DeepEqual

func (p *MessageRequest) Field1DeepEqual(src int64) bool

func (*MessageRequest) Field2DeepEqual

func (p *MessageRequest) Field2DeepEqual(src int64) bool

func (*MessageRequest) Field3DeepEqual

func (p *MessageRequest) Field3DeepEqual(src bool) bool

func (*MessageRequest) Field4DeepEqual

func (p *MessageRequest) Field4DeepEqual(src string) bool

func (*MessageRequest) Field5DeepEqual

func (p *MessageRequest) Field5DeepEqual(src int64) bool

func (*MessageRequest) GetActionType

func (p *MessageRequest) GetActionType() (v bool)

func (*MessageRequest) GetContent

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

func (*MessageRequest) GetSendTime

func (p *MessageRequest) GetSendTime() (v int64)

func (*MessageRequest) GetToUserId

func (p *MessageRequest) GetToUserId() (v int64)

func (*MessageRequest) GetUserId

func (p *MessageRequest) GetUserId() (v int64)

func (*MessageRequest) InitDefault

func (p *MessageRequest) InitDefault()

func (*MessageRequest) Read

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

func (*MessageRequest) ReadField1

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

func (*MessageRequest) ReadField2

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

func (*MessageRequest) ReadField3

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

func (*MessageRequest) ReadField4

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

func (*MessageRequest) ReadField5

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

func (*MessageRequest) SetActionType

func (p *MessageRequest) SetActionType(val bool)

func (*MessageRequest) SetContent

func (p *MessageRequest) SetContent(val string)

func (*MessageRequest) SetSendTime

func (p *MessageRequest) SetSendTime(val int64)

func (*MessageRequest) SetToUserId

func (p *MessageRequest) SetToUserId(val int64)

func (*MessageRequest) SetUserId

func (p *MessageRequest) SetUserId(val int64)

func (*MessageRequest) String

func (p *MessageRequest) String() string

func (*MessageRequest) Write

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

type MessageResponse

type MessageResponse struct {
	StatusCode int64  `thrift:"status_code,1" frugal:"1,default,i64" json:"status_code"`
	StatusMsg  string `thrift:"status_msg,2" frugal:"2,default,string" json:"status_msg"`
}
var MessageServiceSendMessageResult_Success_DEFAULT *MessageResponse

func NewMessageResponse

func NewMessageResponse() *MessageResponse

func (*MessageResponse) BLength

func (p *MessageResponse) BLength() int

func (*MessageResponse) DeepEqual

func (p *MessageResponse) DeepEqual(ano *MessageResponse) bool

func (*MessageResponse) FastRead

func (p *MessageResponse) FastRead(buf []byte) (int, error)

func (*MessageResponse) FastReadField1

func (p *MessageResponse) FastReadField1(buf []byte) (int, error)

func (*MessageResponse) FastReadField2

func (p *MessageResponse) FastReadField2(buf []byte) (int, error)

func (*MessageResponse) FastWrite

func (p *MessageResponse) FastWrite(buf []byte) int

for compatibility

func (*MessageResponse) FastWriteNocopy

func (p *MessageResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageResponse) Field1DeepEqual

func (p *MessageResponse) Field1DeepEqual(src int64) bool

func (*MessageResponse) Field2DeepEqual

func (p *MessageResponse) Field2DeepEqual(src string) bool

func (*MessageResponse) GetStatusCode

func (p *MessageResponse) GetStatusCode() (v int64)

func (*MessageResponse) GetStatusMsg

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

func (*MessageResponse) InitDefault

func (p *MessageResponse) InitDefault()

func (*MessageResponse) Read

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

func (*MessageResponse) ReadField1

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

func (*MessageResponse) ReadField2

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

func (*MessageResponse) SetStatusCode

func (p *MessageResponse) SetStatusCode(val int64)

func (*MessageResponse) SetStatusMsg

func (p *MessageResponse) SetStatusMsg(val string)

func (*MessageResponse) String

func (p *MessageResponse) String() string

func (*MessageResponse) Write

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

type MessageService

type MessageService interface {
	SendMessage(ctx context.Context, request *MessageRequest) (r *MessageResponse, err error)

	GetChatRecord(ctx context.Context, request *ChatRecordRequest) (r *ChatRecordResponse, 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) GetChatRecord

func (p *MessageServiceClient) GetChatRecord(ctx context.Context, request *ChatRecordRequest) (r *ChatRecordResponse, err error)

func (*MessageServiceClient) SendMessage

func (p *MessageServiceClient) SendMessage(ctx context.Context, request *MessageRequest) (r *MessageResponse, err error)

type MessageServiceGetChatRecordArgs

type MessageServiceGetChatRecordArgs struct {
	Request *ChatRecordRequest `thrift:"request,1" frugal:"1,default,ChatRecordRequest" json:"request"`
}

func NewMessageServiceGetChatRecordArgs

func NewMessageServiceGetChatRecordArgs() *MessageServiceGetChatRecordArgs

func (*MessageServiceGetChatRecordArgs) BLength

func (p *MessageServiceGetChatRecordArgs) BLength() int

func (*MessageServiceGetChatRecordArgs) DeepEqual

func (*MessageServiceGetChatRecordArgs) FastRead

func (p *MessageServiceGetChatRecordArgs) FastRead(buf []byte) (int, error)

func (*MessageServiceGetChatRecordArgs) FastReadField1

func (p *MessageServiceGetChatRecordArgs) FastReadField1(buf []byte) (int, error)

func (*MessageServiceGetChatRecordArgs) FastWrite

func (p *MessageServiceGetChatRecordArgs) FastWrite(buf []byte) int

for compatibility

func (*MessageServiceGetChatRecordArgs) FastWriteNocopy

func (p *MessageServiceGetChatRecordArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageServiceGetChatRecordArgs) Field1DeepEqual

func (p *MessageServiceGetChatRecordArgs) Field1DeepEqual(src *ChatRecordRequest) bool

func (*MessageServiceGetChatRecordArgs) GetFirstArgument

func (p *MessageServiceGetChatRecordArgs) GetFirstArgument() interface{}

func (*MessageServiceGetChatRecordArgs) GetRequest

func (*MessageServiceGetChatRecordArgs) InitDefault

func (p *MessageServiceGetChatRecordArgs) InitDefault()

func (*MessageServiceGetChatRecordArgs) IsSetRequest

func (p *MessageServiceGetChatRecordArgs) IsSetRequest() bool

func (*MessageServiceGetChatRecordArgs) Read

func (*MessageServiceGetChatRecordArgs) ReadField1

func (*MessageServiceGetChatRecordArgs) SetRequest

func (*MessageServiceGetChatRecordArgs) String

func (*MessageServiceGetChatRecordArgs) Write

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

type MessageServiceGetChatRecordResult

type MessageServiceGetChatRecordResult struct {
	Success *ChatRecordResponse `thrift:"success,0,optional" frugal:"0,optional,ChatRecordResponse" json:"success,omitempty"`
}

func NewMessageServiceGetChatRecordResult

func NewMessageServiceGetChatRecordResult() *MessageServiceGetChatRecordResult

func (*MessageServiceGetChatRecordResult) BLength

func (*MessageServiceGetChatRecordResult) DeepEqual

func (*MessageServiceGetChatRecordResult) FastRead

func (p *MessageServiceGetChatRecordResult) FastRead(buf []byte) (int, error)

func (*MessageServiceGetChatRecordResult) FastReadField0

func (p *MessageServiceGetChatRecordResult) FastReadField0(buf []byte) (int, error)

func (*MessageServiceGetChatRecordResult) FastWrite

func (p *MessageServiceGetChatRecordResult) FastWrite(buf []byte) int

for compatibility

func (*MessageServiceGetChatRecordResult) FastWriteNocopy

func (p *MessageServiceGetChatRecordResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageServiceGetChatRecordResult) Field0DeepEqual

func (*MessageServiceGetChatRecordResult) GetResult

func (p *MessageServiceGetChatRecordResult) GetResult() interface{}

func (*MessageServiceGetChatRecordResult) GetSuccess

func (*MessageServiceGetChatRecordResult) InitDefault

func (p *MessageServiceGetChatRecordResult) InitDefault()

func (*MessageServiceGetChatRecordResult) IsSetSuccess

func (p *MessageServiceGetChatRecordResult) IsSetSuccess() bool

func (*MessageServiceGetChatRecordResult) Read

func (*MessageServiceGetChatRecordResult) ReadField0

func (*MessageServiceGetChatRecordResult) SetSuccess

func (p *MessageServiceGetChatRecordResult) SetSuccess(x interface{})

func (*MessageServiceGetChatRecordResult) String

func (*MessageServiceGetChatRecordResult) Write

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

type MessageServiceSendMessageArgs

type MessageServiceSendMessageArgs struct {
	Request *MessageRequest `thrift:"request,1" frugal:"1,default,MessageRequest" json:"request"`
}

func NewMessageServiceSendMessageArgs

func NewMessageServiceSendMessageArgs() *MessageServiceSendMessageArgs

func (*MessageServiceSendMessageArgs) BLength

func (p *MessageServiceSendMessageArgs) BLength() int

func (*MessageServiceSendMessageArgs) DeepEqual

func (*MessageServiceSendMessageArgs) FastRead

func (p *MessageServiceSendMessageArgs) FastRead(buf []byte) (int, error)

func (*MessageServiceSendMessageArgs) FastReadField1

func (p *MessageServiceSendMessageArgs) FastReadField1(buf []byte) (int, error)

func (*MessageServiceSendMessageArgs) FastWrite

func (p *MessageServiceSendMessageArgs) FastWrite(buf []byte) int

for compatibility

func (*MessageServiceSendMessageArgs) FastWriteNocopy

func (p *MessageServiceSendMessageArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageServiceSendMessageArgs) Field1DeepEqual

func (p *MessageServiceSendMessageArgs) Field1DeepEqual(src *MessageRequest) bool

func (*MessageServiceSendMessageArgs) GetFirstArgument

func (p *MessageServiceSendMessageArgs) GetFirstArgument() interface{}

func (*MessageServiceSendMessageArgs) GetRequest

func (p *MessageServiceSendMessageArgs) GetRequest() (v *MessageRequest)

func (*MessageServiceSendMessageArgs) InitDefault

func (p *MessageServiceSendMessageArgs) InitDefault()

func (*MessageServiceSendMessageArgs) IsSetRequest

func (p *MessageServiceSendMessageArgs) IsSetRequest() bool

func (*MessageServiceSendMessageArgs) Read

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

func (*MessageServiceSendMessageArgs) ReadField1

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

func (*MessageServiceSendMessageArgs) SetRequest

func (p *MessageServiceSendMessageArgs) SetRequest(val *MessageRequest)

func (*MessageServiceSendMessageArgs) String

func (*MessageServiceSendMessageArgs) Write

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

type MessageServiceSendMessageResult

type MessageServiceSendMessageResult struct {
	Success *MessageResponse `thrift:"success,0,optional" frugal:"0,optional,MessageResponse" json:"success,omitempty"`
}

func NewMessageServiceSendMessageResult

func NewMessageServiceSendMessageResult() *MessageServiceSendMessageResult

func (*MessageServiceSendMessageResult) BLength

func (p *MessageServiceSendMessageResult) BLength() int

func (*MessageServiceSendMessageResult) DeepEqual

func (*MessageServiceSendMessageResult) FastRead

func (p *MessageServiceSendMessageResult) FastRead(buf []byte) (int, error)

func (*MessageServiceSendMessageResult) FastReadField0

func (p *MessageServiceSendMessageResult) FastReadField0(buf []byte) (int, error)

func (*MessageServiceSendMessageResult) FastWrite

func (p *MessageServiceSendMessageResult) FastWrite(buf []byte) int

for compatibility

func (*MessageServiceSendMessageResult) FastWriteNocopy

func (p *MessageServiceSendMessageResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*MessageServiceSendMessageResult) Field0DeepEqual

func (p *MessageServiceSendMessageResult) Field0DeepEqual(src *MessageResponse) bool

func (*MessageServiceSendMessageResult) GetResult

func (p *MessageServiceSendMessageResult) GetResult() interface{}

func (*MessageServiceSendMessageResult) GetSuccess

func (p *MessageServiceSendMessageResult) GetSuccess() (v *MessageResponse)

func (*MessageServiceSendMessageResult) InitDefault

func (p *MessageServiceSendMessageResult) InitDefault()

func (*MessageServiceSendMessageResult) IsSetSuccess

func (p *MessageServiceSendMessageResult) IsSetSuccess() bool

func (*MessageServiceSendMessageResult) Read

func (*MessageServiceSendMessageResult) ReadField0

func (*MessageServiceSendMessageResult) SetSuccess

func (p *MessageServiceSendMessageResult) SetSuccess(x interface{})

func (*MessageServiceSendMessageResult) String

func (*MessageServiceSendMessageResult) Write

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

Directories

Path Synopsis
Code generated by Kitex v0.4.4.
Code generated by Kitex v0.4.4.

Jump to

Keyboard shortcuts

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