Documentation ¶
Index ¶
- Variables
- type ActionRequest
- func (p *ActionRequest) BLength() int
- func (p *ActionRequest) DeepEqual(ano *ActionRequest) bool
- func (p *ActionRequest) FastRead(buf []byte) (int, error)
- func (p *ActionRequest) FastReadField1(buf []byte) (int, error)
- func (p *ActionRequest) FastReadField2(buf []byte) (int, error)
- func (p *ActionRequest) FastReadField3(buf []byte) (int, error)
- func (p *ActionRequest) FastReadField4(buf []byte) (int, error)
- func (p *ActionRequest) FastWrite(buf []byte) int
- func (p *ActionRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *ActionRequest) Field1DeepEqual(src string) bool
- func (p *ActionRequest) Field2DeepEqual(src int64) bool
- func (p *ActionRequest) Field3DeepEqual(src int32) bool
- func (p *ActionRequest) Field4DeepEqual(src string) bool
- func (p *ActionRequest) GetActionType() (v int32)
- func (p *ActionRequest) GetContent() (v string)
- func (p *ActionRequest) GetToUserId() (v int64)
- func (p *ActionRequest) GetToken() (v string)
- func (p *ActionRequest) InitDefault()
- func (p *ActionRequest) Read(iprot thrift.TProtocol) (err error)
- func (p *ActionRequest) ReadField1(iprot thrift.TProtocol) error
- func (p *ActionRequest) ReadField2(iprot thrift.TProtocol) error
- func (p *ActionRequest) ReadField3(iprot thrift.TProtocol) error
- func (p *ActionRequest) ReadField4(iprot thrift.TProtocol) error
- func (p *ActionRequest) SetActionType(val int32)
- func (p *ActionRequest) SetContent(val string)
- func (p *ActionRequest) SetToUserId(val int64)
- func (p *ActionRequest) SetToken(val string)
- func (p *ActionRequest) String() string
- func (p *ActionRequest) Write(oprot thrift.TProtocol) (err error)
- type ActionResponse
- func (p *ActionResponse) BLength() int
- func (p *ActionResponse) DeepEqual(ano *ActionResponse) bool
- func (p *ActionResponse) FastRead(buf []byte) (int, error)
- func (p *ActionResponse) FastReadField1(buf []byte) (int, error)
- func (p *ActionResponse) FastReadField2(buf []byte) (int, error)
- func (p *ActionResponse) FastWrite(buf []byte) int
- func (p *ActionResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *ActionResponse) Field1DeepEqual(src int32) bool
- func (p *ActionResponse) Field2DeepEqual(src *string) bool
- func (p *ActionResponse) GetStatusCode() (v int32)
- func (p *ActionResponse) GetStatusMsg() (v string)
- func (p *ActionResponse) InitDefault()
- func (p *ActionResponse) IsSetStatusMsg() bool
- func (p *ActionResponse) Read(iprot thrift.TProtocol) (err error)
- func (p *ActionResponse) ReadField1(iprot thrift.TProtocol) error
- func (p *ActionResponse) ReadField2(iprot thrift.TProtocol) error
- func (p *ActionResponse) SetStatusCode(val int32)
- func (p *ActionResponse) SetStatusMsg(val *string)
- func (p *ActionResponse) String() string
- func (p *ActionResponse) Write(oprot thrift.TProtocol) (err error)
- type ChatRequest
- func (p *ChatRequest) BLength() int
- func (p *ChatRequest) DeepEqual(ano *ChatRequest) bool
- func (p *ChatRequest) FastRead(buf []byte) (int, error)
- func (p *ChatRequest) FastReadField1(buf []byte) (int, error)
- func (p *ChatRequest) FastReadField2(buf []byte) (int, error)
- func (p *ChatRequest) FastReadField3(buf []byte) (int, error)
- func (p *ChatRequest) FastWrite(buf []byte) int
- func (p *ChatRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *ChatRequest) Field1DeepEqual(src string) bool
- func (p *ChatRequest) Field2DeepEqual(src int64) bool
- func (p *ChatRequest) Field3DeepEqual(src int64) bool
- func (p *ChatRequest) GetPreMsgTime() (v int64)
- func (p *ChatRequest) GetToUserId() (v int64)
- func (p *ChatRequest) GetToken() (v string)
- func (p *ChatRequest) InitDefault()
- func (p *ChatRequest) Read(iprot thrift.TProtocol) (err error)
- func (p *ChatRequest) ReadField1(iprot thrift.TProtocol) error
- func (p *ChatRequest) ReadField2(iprot thrift.TProtocol) error
- func (p *ChatRequest) ReadField3(iprot thrift.TProtocol) error
- func (p *ChatRequest) SetPreMsgTime(val int64)
- func (p *ChatRequest) SetToUserId(val int64)
- func (p *ChatRequest) SetToken(val string)
- func (p *ChatRequest) String() string
- func (p *ChatRequest) Write(oprot thrift.TProtocol) (err error)
- type ChatResponse
- func (p *ChatResponse) BLength() int
- func (p *ChatResponse) DeepEqual(ano *ChatResponse) bool
- func (p *ChatResponse) FastRead(buf []byte) (int, error)
- func (p *ChatResponse) FastReadField1(buf []byte) (int, error)
- func (p *ChatResponse) FastReadField2(buf []byte) (int, error)
- func (p *ChatResponse) FastReadField3(buf []byte) (int, error)
- func (p *ChatResponse) FastWrite(buf []byte) int
- func (p *ChatResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *ChatResponse) Field1DeepEqual(src int32) bool
- func (p *ChatResponse) Field2DeepEqual(src *string) bool
- func (p *ChatResponse) Field3DeepEqual(src []*Message) bool
- func (p *ChatResponse) GetMessageList() (v []*Message)
- func (p *ChatResponse) GetStatusCode() (v int32)
- func (p *ChatResponse) GetStatusMsg() (v string)
- func (p *ChatResponse) InitDefault()
- func (p *ChatResponse) IsSetStatusMsg() bool
- func (p *ChatResponse) Read(iprot thrift.TProtocol) (err error)
- func (p *ChatResponse) ReadField1(iprot thrift.TProtocol) error
- func (p *ChatResponse) ReadField2(iprot thrift.TProtocol) error
- func (p *ChatResponse) ReadField3(iprot thrift.TProtocol) error
- func (p *ChatResponse) SetMessageList(val []*Message)
- func (p *ChatResponse) SetStatusCode(val int32)
- func (p *ChatResponse) SetStatusMsg(val *string)
- func (p *ChatResponse) String() string
- func (p *ChatResponse) Write(oprot thrift.TProtocol) (err error)
- type Message
- func (p *Message) BLength() int
- func (p *Message) DeepEqual(ano *Message) bool
- func (p *Message) FastRead(buf []byte) (int, error)
- func (p *Message) FastReadField1(buf []byte) (int, error)
- func (p *Message) FastReadField2(buf []byte) (int, error)
- func (p *Message) FastReadField3(buf []byte) (int, error)
- func (p *Message) FastReadField4(buf []byte) (int, error)
- func (p *Message) FastReadField5(buf []byte) (int, error)
- func (p *Message) FastWrite(buf []byte) int
- func (p *Message) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *Message) Field1DeepEqual(src int64) bool
- func (p *Message) Field2DeepEqual(src int64) bool
- func (p *Message) Field3DeepEqual(src int64) bool
- func (p *Message) Field4DeepEqual(src string) bool
- func (p *Message) Field5DeepEqual(src *int64) bool
- func (p *Message) GetContent() (v string)
- func (p *Message) GetCreateTime() (v int64)
- func (p *Message) GetFromUserId() (v int64)
- func (p *Message) GetId() (v int64)
- func (p *Message) GetToUserId() (v int64)
- func (p *Message) InitDefault()
- func (p *Message) IsSetCreateTime() bool
- func (p *Message) Read(iprot thrift.TProtocol) (err error)
- func (p *Message) ReadField1(iprot thrift.TProtocol) error
- func (p *Message) ReadField2(iprot thrift.TProtocol) error
- func (p *Message) ReadField3(iprot thrift.TProtocol) error
- func (p *Message) ReadField4(iprot thrift.TProtocol) error
- func (p *Message) ReadField5(iprot thrift.TProtocol) error
- func (p *Message) SetContent(val string)
- func (p *Message) SetCreateTime(val *int64)
- func (p *Message) SetFromUserId(val int64)
- func (p *Message) SetId(val int64)
- func (p *Message) SetToUserId(val int64)
- func (p *Message) String() string
- func (p *Message) Write(oprot thrift.TProtocol) (err error)
- type MessageService
- type MessageServiceClient
- func NewMessageServiceClient(c thrift.TClient) *MessageServiceClient
- func NewMessageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MessageServiceClient
- func NewMessageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MessageServiceClient
- type MessageServiceMessageActionArgs
- func (p *MessageServiceMessageActionArgs) BLength() int
- func (p *MessageServiceMessageActionArgs) DeepEqual(ano *MessageServiceMessageActionArgs) bool
- func (p *MessageServiceMessageActionArgs) FastRead(buf []byte) (int, error)
- func (p *MessageServiceMessageActionArgs) FastReadField1(buf []byte) (int, error)
- func (p *MessageServiceMessageActionArgs) FastWrite(buf []byte) int
- func (p *MessageServiceMessageActionArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *MessageServiceMessageActionArgs) Field1DeepEqual(src *ActionRequest) bool
- func (p *MessageServiceMessageActionArgs) GetFirstArgument() interface{}
- func (p *MessageServiceMessageActionArgs) GetReq() (v *ActionRequest)
- func (p *MessageServiceMessageActionArgs) InitDefault()
- func (p *MessageServiceMessageActionArgs) IsSetReq() bool
- func (p *MessageServiceMessageActionArgs) Read(iprot thrift.TProtocol) (err error)
- func (p *MessageServiceMessageActionArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *MessageServiceMessageActionArgs) SetReq(val *ActionRequest)
- func (p *MessageServiceMessageActionArgs) String() string
- func (p *MessageServiceMessageActionArgs) Write(oprot thrift.TProtocol) (err error)
- type MessageServiceMessageActionResult
- func (p *MessageServiceMessageActionResult) BLength() int
- func (p *MessageServiceMessageActionResult) DeepEqual(ano *MessageServiceMessageActionResult) bool
- func (p *MessageServiceMessageActionResult) FastRead(buf []byte) (int, error)
- func (p *MessageServiceMessageActionResult) FastReadField0(buf []byte) (int, error)
- func (p *MessageServiceMessageActionResult) FastWrite(buf []byte) int
- func (p *MessageServiceMessageActionResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *MessageServiceMessageActionResult) Field0DeepEqual(src *ActionResponse) bool
- func (p *MessageServiceMessageActionResult) GetResult() interface{}
- func (p *MessageServiceMessageActionResult) GetSuccess() (v *ActionResponse)
- func (p *MessageServiceMessageActionResult) InitDefault()
- func (p *MessageServiceMessageActionResult) IsSetSuccess() bool
- func (p *MessageServiceMessageActionResult) Read(iprot thrift.TProtocol) (err error)
- func (p *MessageServiceMessageActionResult) ReadField0(iprot thrift.TProtocol) error
- func (p *MessageServiceMessageActionResult) SetSuccess(x interface{})
- func (p *MessageServiceMessageActionResult) String() string
- func (p *MessageServiceMessageActionResult) Write(oprot thrift.TProtocol) (err error)
- type MessageServiceMessageChatArgs
- func (p *MessageServiceMessageChatArgs) BLength() int
- func (p *MessageServiceMessageChatArgs) DeepEqual(ano *MessageServiceMessageChatArgs) bool
- func (p *MessageServiceMessageChatArgs) FastRead(buf []byte) (int, error)
- func (p *MessageServiceMessageChatArgs) FastReadField1(buf []byte) (int, error)
- func (p *MessageServiceMessageChatArgs) FastWrite(buf []byte) int
- func (p *MessageServiceMessageChatArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *MessageServiceMessageChatArgs) Field1DeepEqual(src *ChatRequest) bool
- func (p *MessageServiceMessageChatArgs) GetFirstArgument() interface{}
- func (p *MessageServiceMessageChatArgs) GetReq() (v *ChatRequest)
- func (p *MessageServiceMessageChatArgs) InitDefault()
- func (p *MessageServiceMessageChatArgs) IsSetReq() bool
- func (p *MessageServiceMessageChatArgs) Read(iprot thrift.TProtocol) (err error)
- func (p *MessageServiceMessageChatArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *MessageServiceMessageChatArgs) SetReq(val *ChatRequest)
- func (p *MessageServiceMessageChatArgs) String() string
- func (p *MessageServiceMessageChatArgs) Write(oprot thrift.TProtocol) (err error)
- type MessageServiceMessageChatResult
- func (p *MessageServiceMessageChatResult) BLength() int
- func (p *MessageServiceMessageChatResult) DeepEqual(ano *MessageServiceMessageChatResult) bool
- func (p *MessageServiceMessageChatResult) FastRead(buf []byte) (int, error)
- func (p *MessageServiceMessageChatResult) FastReadField0(buf []byte) (int, error)
- func (p *MessageServiceMessageChatResult) FastWrite(buf []byte) int
- func (p *MessageServiceMessageChatResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *MessageServiceMessageChatResult) Field0DeepEqual(src *ChatResponse) bool
- func (p *MessageServiceMessageChatResult) GetResult() interface{}
- func (p *MessageServiceMessageChatResult) GetSuccess() (v *ChatResponse)
- func (p *MessageServiceMessageChatResult) InitDefault()
- func (p *MessageServiceMessageChatResult) IsSetSuccess() bool
- func (p *MessageServiceMessageChatResult) Read(iprot thrift.TProtocol) (err error)
- func (p *MessageServiceMessageChatResult) ReadField0(iprot thrift.TProtocol) error
- func (p *MessageServiceMessageChatResult) SetSuccess(x interface{})
- func (p *MessageServiceMessageChatResult) String() string
- func (p *MessageServiceMessageChatResult) Write(oprot thrift.TProtocol) (err error)
- type MessageServiceProcessor
- func (p *MessageServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *MessageServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *MessageServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *MessageServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Constants ¶
This section is empty.
Variables ¶
View Source
var ActionResponse_StatusMsg_DEFAULT string
View Source
var ChatResponse_StatusMsg_DEFAULT string
View Source
var KitexUnusedProtection = struct{}{}
KitexUnusedProtection is used to prevent 'imported and not used' error.
View Source
var Message_CreateTime_DEFAULT int64
Functions ¶
This section is empty.
Types ¶
type ActionRequest ¶
type ActionRequest struct { Token string `thrift:"token,1,required" frugal:"1,required,string" json:"token"` ToUserId int64 `thrift:"to_user_id,2,required" frugal:"2,required,i64" json:"to_user_id"` ActionType int32 `thrift:"action_type,3,required" frugal:"3,required,i32" json:"action_type"` Content string `thrift:"content,4,required" frugal:"4,required,string" json:"content"` }
var MessageServiceMessageActionArgs_Req_DEFAULT *ActionRequest
func NewActionRequest ¶
func NewActionRequest() *ActionRequest
func (*ActionRequest) BLength ¶
func (p *ActionRequest) BLength() int
func (*ActionRequest) DeepEqual ¶
func (p *ActionRequest) DeepEqual(ano *ActionRequest) bool
func (*ActionRequest) FastReadField1 ¶
func (p *ActionRequest) FastReadField1(buf []byte) (int, error)
func (*ActionRequest) FastReadField2 ¶
func (p *ActionRequest) FastReadField2(buf []byte) (int, error)
func (*ActionRequest) FastReadField3 ¶
func (p *ActionRequest) FastReadField3(buf []byte) (int, error)
func (*ActionRequest) FastReadField4 ¶
func (p *ActionRequest) FastReadField4(buf []byte) (int, error)
func (*ActionRequest) FastWrite ¶
func (p *ActionRequest) FastWrite(buf []byte) int
for compatibility
func (*ActionRequest) FastWriteNocopy ¶
func (p *ActionRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*ActionRequest) Field1DeepEqual ¶
func (p *ActionRequest) Field1DeepEqual(src string) bool
func (*ActionRequest) Field2DeepEqual ¶
func (p *ActionRequest) Field2DeepEqual(src int64) bool
func (*ActionRequest) Field3DeepEqual ¶
func (p *ActionRequest) Field3DeepEqual(src int32) bool
func (*ActionRequest) Field4DeepEqual ¶
func (p *ActionRequest) Field4DeepEqual(src string) bool
func (*ActionRequest) GetActionType ¶
func (p *ActionRequest) GetActionType() (v int32)
func (*ActionRequest) GetContent ¶
func (p *ActionRequest) GetContent() (v string)
func (*ActionRequest) GetToUserId ¶
func (p *ActionRequest) GetToUserId() (v int64)
func (*ActionRequest) GetToken ¶
func (p *ActionRequest) GetToken() (v string)
func (*ActionRequest) InitDefault ¶
func (p *ActionRequest) InitDefault()
func (*ActionRequest) ReadField1 ¶
func (p *ActionRequest) ReadField1(iprot thrift.TProtocol) error
func (*ActionRequest) ReadField2 ¶
func (p *ActionRequest) ReadField2(iprot thrift.TProtocol) error
func (*ActionRequest) ReadField3 ¶
func (p *ActionRequest) ReadField3(iprot thrift.TProtocol) error
func (*ActionRequest) ReadField4 ¶
func (p *ActionRequest) ReadField4(iprot thrift.TProtocol) error
func (*ActionRequest) SetActionType ¶
func (p *ActionRequest) SetActionType(val int32)
func (*ActionRequest) SetContent ¶
func (p *ActionRequest) SetContent(val string)
func (*ActionRequest) SetToUserId ¶
func (p *ActionRequest) SetToUserId(val int64)
func (*ActionRequest) SetToken ¶
func (p *ActionRequest) SetToken(val string)
func (*ActionRequest) String ¶
func (p *ActionRequest) String() string
type ActionResponse ¶
type ActionResponse struct { StatusCode int32 `thrift:"status_code,1,required" frugal:"1,required,i32" json:"status_code"` StatusMsg *string `thrift:"status_msg,2,optional" frugal:"2,optional,string" json:"status_msg,omitempty"` }
var MessageServiceMessageActionResult_Success_DEFAULT *ActionResponse
func NewActionResponse ¶
func NewActionResponse() *ActionResponse
func (*ActionResponse) BLength ¶
func (p *ActionResponse) BLength() int
func (*ActionResponse) DeepEqual ¶
func (p *ActionResponse) DeepEqual(ano *ActionResponse) bool
func (*ActionResponse) FastReadField1 ¶
func (p *ActionResponse) FastReadField1(buf []byte) (int, error)
func (*ActionResponse) FastReadField2 ¶
func (p *ActionResponse) FastReadField2(buf []byte) (int, error)
func (*ActionResponse) FastWrite ¶
func (p *ActionResponse) FastWrite(buf []byte) int
for compatibility
func (*ActionResponse) FastWriteNocopy ¶
func (p *ActionResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*ActionResponse) Field1DeepEqual ¶
func (p *ActionResponse) Field1DeepEqual(src int32) bool
func (*ActionResponse) Field2DeepEqual ¶
func (p *ActionResponse) Field2DeepEqual(src *string) bool
func (*ActionResponse) GetStatusCode ¶
func (p *ActionResponse) GetStatusCode() (v int32)
func (*ActionResponse) GetStatusMsg ¶
func (p *ActionResponse) GetStatusMsg() (v string)
func (*ActionResponse) InitDefault ¶
func (p *ActionResponse) InitDefault()
func (*ActionResponse) IsSetStatusMsg ¶
func (p *ActionResponse) IsSetStatusMsg() bool
func (*ActionResponse) ReadField1 ¶
func (p *ActionResponse) ReadField1(iprot thrift.TProtocol) error
func (*ActionResponse) ReadField2 ¶
func (p *ActionResponse) ReadField2(iprot thrift.TProtocol) error
func (*ActionResponse) SetStatusCode ¶
func (p *ActionResponse) SetStatusCode(val int32)
func (*ActionResponse) SetStatusMsg ¶
func (p *ActionResponse) SetStatusMsg(val *string)
func (*ActionResponse) String ¶
func (p *ActionResponse) String() string
type ChatRequest ¶
type ChatRequest struct { Token string `thrift:"token,1,required" frugal:"1,required,string" json:"token"` ToUserId int64 `thrift:"to_user_id,2,required" frugal:"2,required,i64" json:"to_user_id"` PreMsgTime int64 `thrift:"pre_msg_time,3,required" frugal:"3,required,i64" json:"pre_msg_time"` }
var MessageServiceMessageChatArgs_Req_DEFAULT *ChatRequest
func NewChatRequest ¶
func NewChatRequest() *ChatRequest
func (*ChatRequest) BLength ¶
func (p *ChatRequest) BLength() int
func (*ChatRequest) DeepEqual ¶
func (p *ChatRequest) DeepEqual(ano *ChatRequest) bool
func (*ChatRequest) FastReadField1 ¶
func (p *ChatRequest) FastReadField1(buf []byte) (int, error)
func (*ChatRequest) FastReadField2 ¶
func (p *ChatRequest) FastReadField2(buf []byte) (int, error)
func (*ChatRequest) FastReadField3 ¶
func (p *ChatRequest) FastReadField3(buf []byte) (int, error)
func (*ChatRequest) FastWriteNocopy ¶
func (p *ChatRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*ChatRequest) Field1DeepEqual ¶
func (p *ChatRequest) Field1DeepEqual(src string) bool
func (*ChatRequest) Field2DeepEqual ¶
func (p *ChatRequest) Field2DeepEqual(src int64) bool
func (*ChatRequest) Field3DeepEqual ¶
func (p *ChatRequest) Field3DeepEqual(src int64) bool
func (*ChatRequest) GetPreMsgTime ¶
func (p *ChatRequest) GetPreMsgTime() (v int64)
func (*ChatRequest) GetToUserId ¶
func (p *ChatRequest) GetToUserId() (v int64)
func (*ChatRequest) GetToken ¶
func (p *ChatRequest) GetToken() (v string)
func (*ChatRequest) InitDefault ¶
func (p *ChatRequest) InitDefault()
func (*ChatRequest) ReadField1 ¶
func (p *ChatRequest) ReadField1(iprot thrift.TProtocol) error
func (*ChatRequest) ReadField2 ¶
func (p *ChatRequest) ReadField2(iprot thrift.TProtocol) error
func (*ChatRequest) ReadField3 ¶
func (p *ChatRequest) ReadField3(iprot thrift.TProtocol) error
func (*ChatRequest) SetPreMsgTime ¶
func (p *ChatRequest) SetPreMsgTime(val int64)
func (*ChatRequest) SetToUserId ¶
func (p *ChatRequest) SetToUserId(val int64)
func (*ChatRequest) SetToken ¶
func (p *ChatRequest) SetToken(val string)
func (*ChatRequest) String ¶
func (p *ChatRequest) String() string
type ChatResponse ¶
type ChatResponse struct { StatusCode int32 `thrift:"status_code,1,required" frugal:"1,required,i32" json:"status_code"` StatusMsg *string `thrift:"status_msg,2,optional" frugal:"2,optional,string" json:"status_msg,omitempty"` MessageList []*Message `thrift:"message_list,3,required" frugal:"3,required,list<Message>" json:"message_list"` }
var MessageServiceMessageChatResult_Success_DEFAULT *ChatResponse
func NewChatResponse ¶
func NewChatResponse() *ChatResponse
func (*ChatResponse) BLength ¶
func (p *ChatResponse) BLength() int
func (*ChatResponse) DeepEqual ¶
func (p *ChatResponse) DeepEqual(ano *ChatResponse) bool
func (*ChatResponse) FastReadField1 ¶
func (p *ChatResponse) FastReadField1(buf []byte) (int, error)
func (*ChatResponse) FastReadField2 ¶
func (p *ChatResponse) FastReadField2(buf []byte) (int, error)
func (*ChatResponse) FastReadField3 ¶
func (p *ChatResponse) FastReadField3(buf []byte) (int, error)
func (*ChatResponse) FastWriteNocopy ¶
func (p *ChatResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*ChatResponse) Field1DeepEqual ¶
func (p *ChatResponse) Field1DeepEqual(src int32) bool
func (*ChatResponse) Field2DeepEqual ¶
func (p *ChatResponse) Field2DeepEqual(src *string) bool
func (*ChatResponse) Field3DeepEqual ¶
func (p *ChatResponse) Field3DeepEqual(src []*Message) bool
func (*ChatResponse) GetMessageList ¶
func (p *ChatResponse) GetMessageList() (v []*Message)
func (*ChatResponse) GetStatusCode ¶
func (p *ChatResponse) GetStatusCode() (v int32)
func (*ChatResponse) GetStatusMsg ¶
func (p *ChatResponse) GetStatusMsg() (v string)
func (*ChatResponse) InitDefault ¶
func (p *ChatResponse) InitDefault()
func (*ChatResponse) IsSetStatusMsg ¶
func (p *ChatResponse) IsSetStatusMsg() bool
func (*ChatResponse) ReadField1 ¶
func (p *ChatResponse) ReadField1(iprot thrift.TProtocol) error
func (*ChatResponse) ReadField2 ¶
func (p *ChatResponse) ReadField2(iprot thrift.TProtocol) error
func (*ChatResponse) ReadField3 ¶
func (p *ChatResponse) ReadField3(iprot thrift.TProtocol) error
func (*ChatResponse) SetMessageList ¶
func (p *ChatResponse) SetMessageList(val []*Message)
func (*ChatResponse) SetStatusCode ¶
func (p *ChatResponse) SetStatusCode(val int32)
func (*ChatResponse) SetStatusMsg ¶
func (p *ChatResponse) SetStatusMsg(val *string)
func (*ChatResponse) String ¶
func (p *ChatResponse) String() string
type Message ¶
type Message 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 NewMessage ¶
func NewMessage() *Message
func (*Message) FastWriteNocopy ¶
func (p *Message) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*Message) Field1DeepEqual ¶
func (*Message) Field2DeepEqual ¶
func (*Message) Field3DeepEqual ¶
func (*Message) Field4DeepEqual ¶
func (*Message) Field5DeepEqual ¶
func (*Message) GetContent ¶
func (*Message) GetCreateTime ¶
func (*Message) GetFromUserId ¶
func (*Message) GetToUserId ¶
func (*Message) InitDefault ¶
func (p *Message) InitDefault()
func (*Message) IsSetCreateTime ¶
func (*Message) SetContent ¶
func (*Message) SetCreateTime ¶
func (*Message) SetFromUserId ¶
func (*Message) SetToUserId ¶
type MessageService ¶
type MessageService interface { MessageChat(ctx context.Context, req *ChatRequest) (r *ChatResponse, err error) MessageAction(ctx context.Context, req *ActionRequest) (r *ActionResponse, err error) }
type MessageServiceClient ¶
type MessageServiceClient struct {
// contains filtered or unexported fields
}
func NewMessageServiceClient ¶
func NewMessageServiceClient(c thrift.TClient) *MessageServiceClient
func NewMessageServiceClientFactory ¶
func NewMessageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *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 (p *MessageServiceClient) MessageAction(ctx context.Context, req *ActionRequest) (r *ActionResponse, err error)
func (*MessageServiceClient) MessageChat ¶
func (p *MessageServiceClient) MessageChat(ctx context.Context, req *ChatRequest) (r *ChatResponse, err error)
type MessageServiceMessageActionArgs ¶
type MessageServiceMessageActionArgs struct {
Req *ActionRequest `thrift:"req,1" frugal:"1,default,ActionRequest" json:"req"`
}
func NewMessageServiceMessageActionArgs ¶
func NewMessageServiceMessageActionArgs() *MessageServiceMessageActionArgs
func (*MessageServiceMessageActionArgs) BLength ¶
func (p *MessageServiceMessageActionArgs) BLength() int
func (*MessageServiceMessageActionArgs) DeepEqual ¶
func (p *MessageServiceMessageActionArgs) DeepEqual(ano *MessageServiceMessageActionArgs) bool
func (*MessageServiceMessageActionArgs) FastRead ¶
func (p *MessageServiceMessageActionArgs) FastRead(buf []byte) (int, error)
func (*MessageServiceMessageActionArgs) FastReadField1 ¶
func (p *MessageServiceMessageActionArgs) FastReadField1(buf []byte) (int, error)
func (*MessageServiceMessageActionArgs) FastWrite ¶
func (p *MessageServiceMessageActionArgs) FastWrite(buf []byte) int
for compatibility
func (*MessageServiceMessageActionArgs) FastWriteNocopy ¶
func (p *MessageServiceMessageActionArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*MessageServiceMessageActionArgs) Field1DeepEqual ¶
func (p *MessageServiceMessageActionArgs) Field1DeepEqual(src *ActionRequest) bool
func (*MessageServiceMessageActionArgs) GetFirstArgument ¶
func (p *MessageServiceMessageActionArgs) GetFirstArgument() interface{}
func (*MessageServiceMessageActionArgs) GetReq ¶
func (p *MessageServiceMessageActionArgs) GetReq() (v *ActionRequest)
func (*MessageServiceMessageActionArgs) InitDefault ¶
func (p *MessageServiceMessageActionArgs) InitDefault()
func (*MessageServiceMessageActionArgs) IsSetReq ¶
func (p *MessageServiceMessageActionArgs) IsSetReq() bool
func (*MessageServiceMessageActionArgs) Read ¶
func (p *MessageServiceMessageActionArgs) Read(iprot thrift.TProtocol) (err error)
func (*MessageServiceMessageActionArgs) ReadField1 ¶
func (p *MessageServiceMessageActionArgs) ReadField1(iprot thrift.TProtocol) error
func (*MessageServiceMessageActionArgs) SetReq ¶
func (p *MessageServiceMessageActionArgs) SetReq(val *ActionRequest)
func (*MessageServiceMessageActionArgs) String ¶
func (p *MessageServiceMessageActionArgs) String() string
type MessageServiceMessageActionResult ¶
type MessageServiceMessageActionResult struct {
Success *ActionResponse `thrift:"success,0,optional" frugal:"0,optional,ActionResponse" json:"success,omitempty"`
}
func NewMessageServiceMessageActionResult ¶
func NewMessageServiceMessageActionResult() *MessageServiceMessageActionResult
func (*MessageServiceMessageActionResult) BLength ¶
func (p *MessageServiceMessageActionResult) BLength() int
func (*MessageServiceMessageActionResult) DeepEqual ¶
func (p *MessageServiceMessageActionResult) DeepEqual(ano *MessageServiceMessageActionResult) bool
func (*MessageServiceMessageActionResult) FastRead ¶
func (p *MessageServiceMessageActionResult) FastRead(buf []byte) (int, error)
func (*MessageServiceMessageActionResult) FastReadField0 ¶
func (p *MessageServiceMessageActionResult) FastReadField0(buf []byte) (int, error)
func (*MessageServiceMessageActionResult) FastWrite ¶
func (p *MessageServiceMessageActionResult) FastWrite(buf []byte) int
for compatibility
func (*MessageServiceMessageActionResult) FastWriteNocopy ¶
func (p *MessageServiceMessageActionResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*MessageServiceMessageActionResult) Field0DeepEqual ¶
func (p *MessageServiceMessageActionResult) Field0DeepEqual(src *ActionResponse) bool
func (*MessageServiceMessageActionResult) GetResult ¶
func (p *MessageServiceMessageActionResult) GetResult() interface{}
func (*MessageServiceMessageActionResult) GetSuccess ¶
func (p *MessageServiceMessageActionResult) GetSuccess() (v *ActionResponse)
func (*MessageServiceMessageActionResult) InitDefault ¶
func (p *MessageServiceMessageActionResult) InitDefault()
func (*MessageServiceMessageActionResult) IsSetSuccess ¶
func (p *MessageServiceMessageActionResult) IsSetSuccess() bool
func (*MessageServiceMessageActionResult) Read ¶
func (p *MessageServiceMessageActionResult) Read(iprot thrift.TProtocol) (err error)
func (*MessageServiceMessageActionResult) ReadField0 ¶
func (p *MessageServiceMessageActionResult) ReadField0(iprot thrift.TProtocol) error
func (*MessageServiceMessageActionResult) SetSuccess ¶
func (p *MessageServiceMessageActionResult) SetSuccess(x interface{})
func (*MessageServiceMessageActionResult) String ¶
func (p *MessageServiceMessageActionResult) String() string
type MessageServiceMessageChatArgs ¶
type MessageServiceMessageChatArgs struct {
Req *ChatRequest `thrift:"req,1" frugal:"1,default,ChatRequest" json:"req"`
}
func NewMessageServiceMessageChatArgs ¶
func NewMessageServiceMessageChatArgs() *MessageServiceMessageChatArgs
func (*MessageServiceMessageChatArgs) BLength ¶
func (p *MessageServiceMessageChatArgs) BLength() int
func (*MessageServiceMessageChatArgs) DeepEqual ¶
func (p *MessageServiceMessageChatArgs) DeepEqual(ano *MessageServiceMessageChatArgs) bool
func (*MessageServiceMessageChatArgs) FastRead ¶
func (p *MessageServiceMessageChatArgs) FastRead(buf []byte) (int, error)
func (*MessageServiceMessageChatArgs) FastReadField1 ¶
func (p *MessageServiceMessageChatArgs) FastReadField1(buf []byte) (int, error)
func (*MessageServiceMessageChatArgs) FastWrite ¶
func (p *MessageServiceMessageChatArgs) FastWrite(buf []byte) int
for compatibility
func (*MessageServiceMessageChatArgs) FastWriteNocopy ¶
func (p *MessageServiceMessageChatArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*MessageServiceMessageChatArgs) Field1DeepEqual ¶
func (p *MessageServiceMessageChatArgs) Field1DeepEqual(src *ChatRequest) bool
func (*MessageServiceMessageChatArgs) GetFirstArgument ¶
func (p *MessageServiceMessageChatArgs) GetFirstArgument() interface{}
func (*MessageServiceMessageChatArgs) GetReq ¶
func (p *MessageServiceMessageChatArgs) GetReq() (v *ChatRequest)
func (*MessageServiceMessageChatArgs) InitDefault ¶
func (p *MessageServiceMessageChatArgs) InitDefault()
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) SetReq ¶
func (p *MessageServiceMessageChatArgs) SetReq(val *ChatRequest)
func (*MessageServiceMessageChatArgs) String ¶
func (p *MessageServiceMessageChatArgs) String() string
type MessageServiceMessageChatResult ¶
type MessageServiceMessageChatResult struct {
Success *ChatResponse `thrift:"success,0,optional" frugal:"0,optional,ChatResponse" json:"success,omitempty"`
}
func NewMessageServiceMessageChatResult ¶
func NewMessageServiceMessageChatResult() *MessageServiceMessageChatResult
func (*MessageServiceMessageChatResult) BLength ¶
func (p *MessageServiceMessageChatResult) BLength() int
func (*MessageServiceMessageChatResult) DeepEqual ¶
func (p *MessageServiceMessageChatResult) DeepEqual(ano *MessageServiceMessageChatResult) bool
func (*MessageServiceMessageChatResult) FastRead ¶
func (p *MessageServiceMessageChatResult) FastRead(buf []byte) (int, error)
func (*MessageServiceMessageChatResult) FastReadField0 ¶
func (p *MessageServiceMessageChatResult) FastReadField0(buf []byte) (int, error)
func (*MessageServiceMessageChatResult) FastWrite ¶
func (p *MessageServiceMessageChatResult) FastWrite(buf []byte) int
for compatibility
func (*MessageServiceMessageChatResult) FastWriteNocopy ¶
func (p *MessageServiceMessageChatResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*MessageServiceMessageChatResult) Field0DeepEqual ¶
func (p *MessageServiceMessageChatResult) Field0DeepEqual(src *ChatResponse) bool
func (*MessageServiceMessageChatResult) GetResult ¶
func (p *MessageServiceMessageChatResult) GetResult() interface{}
func (*MessageServiceMessageChatResult) GetSuccess ¶
func (p *MessageServiceMessageChatResult) GetSuccess() (v *ChatResponse)
func (*MessageServiceMessageChatResult) InitDefault ¶
func (p *MessageServiceMessageChatResult) InitDefault()
func (*MessageServiceMessageChatResult) IsSetSuccess ¶
func (p *MessageServiceMessageChatResult) IsSetSuccess() bool
func (*MessageServiceMessageChatResult) Read ¶
func (p *MessageServiceMessageChatResult) Read(iprot thrift.TProtocol) (err error)
func (*MessageServiceMessageChatResult) ReadField0 ¶
func (p *MessageServiceMessageChatResult) ReadField0(iprot thrift.TProtocol) error
func (*MessageServiceMessageChatResult) SetSuccess ¶
func (p *MessageServiceMessageChatResult) SetSuccess(x interface{})
func (*MessageServiceMessageChatResult) String ¶
func (p *MessageServiceMessageChatResult) String() string
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 ¶
func (p *MessageServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Click to show internal directories.
Click to hide internal directories.