Documentation ¶
Index ¶
- Variables
- type IMService
- type IMServiceClient
- type IMServiceProcessor
- func (p *IMServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *IMServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *IMServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *IMServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
- type IMServicePullArgs
- func (p *IMServicePullArgs) BLength() int
- func (p *IMServicePullArgs) DeepEqual(ano *IMServicePullArgs) bool
- func (p *IMServicePullArgs) FastRead(buf []byte) (int, error)
- func (p *IMServicePullArgs) FastReadField2(buf []byte) (int, error)
- func (p *IMServicePullArgs) FastWrite(buf []byte) int
- func (p *IMServicePullArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *IMServicePullArgs) Field2DeepEqual(src *PullRequest) bool
- func (p *IMServicePullArgs) GetFirstArgument() interface{}
- func (p *IMServicePullArgs) GetReq() (v *PullRequest)
- func (p *IMServicePullArgs) InitDefault()
- func (p *IMServicePullArgs) IsSetReq() bool
- func (p *IMServicePullArgs) Read(iprot thrift.TProtocol) (err error)
- func (p *IMServicePullArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *IMServicePullArgs) SetReq(val *PullRequest)
- func (p *IMServicePullArgs) String() string
- func (p *IMServicePullArgs) Write(oprot thrift.TProtocol) (err error)
- type IMServicePullResult
- func (p *IMServicePullResult) BLength() int
- func (p *IMServicePullResult) DeepEqual(ano *IMServicePullResult) bool
- func (p *IMServicePullResult) FastRead(buf []byte) (int, error)
- func (p *IMServicePullResult) FastReadField0(buf []byte) (int, error)
- func (p *IMServicePullResult) FastWrite(buf []byte) int
- func (p *IMServicePullResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *IMServicePullResult) Field0DeepEqual(src *PullResponse) bool
- func (p *IMServicePullResult) GetResult() interface{}
- func (p *IMServicePullResult) GetSuccess() (v *PullResponse)
- func (p *IMServicePullResult) InitDefault()
- func (p *IMServicePullResult) IsSetSuccess() bool
- func (p *IMServicePullResult) Read(iprot thrift.TProtocol) (err error)
- func (p *IMServicePullResult) ReadField0(iprot thrift.TProtocol) error
- func (p *IMServicePullResult) SetSuccess(x interface{})
- func (p *IMServicePullResult) String() string
- func (p *IMServicePullResult) Write(oprot thrift.TProtocol) (err error)
- type IMServiceSendArgs
- func (p *IMServiceSendArgs) BLength() int
- func (p *IMServiceSendArgs) DeepEqual(ano *IMServiceSendArgs) bool
- func (p *IMServiceSendArgs) FastRead(buf []byte) (int, error)
- func (p *IMServiceSendArgs) FastReadField1(buf []byte) (int, error)
- func (p *IMServiceSendArgs) FastWrite(buf []byte) int
- func (p *IMServiceSendArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *IMServiceSendArgs) Field1DeepEqual(src *SendRequest) bool
- func (p *IMServiceSendArgs) GetFirstArgument() interface{}
- func (p *IMServiceSendArgs) GetReq() (v *SendRequest)
- func (p *IMServiceSendArgs) InitDefault()
- func (p *IMServiceSendArgs) IsSetReq() bool
- func (p *IMServiceSendArgs) Read(iprot thrift.TProtocol) (err error)
- func (p *IMServiceSendArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *IMServiceSendArgs) SetReq(val *SendRequest)
- func (p *IMServiceSendArgs) String() string
- func (p *IMServiceSendArgs) Write(oprot thrift.TProtocol) (err error)
- type IMServiceSendResult
- func (p *IMServiceSendResult) BLength() int
- func (p *IMServiceSendResult) DeepEqual(ano *IMServiceSendResult) bool
- func (p *IMServiceSendResult) FastRead(buf []byte) (int, error)
- func (p *IMServiceSendResult) FastReadField0(buf []byte) (int, error)
- func (p *IMServiceSendResult) FastWrite(buf []byte) int
- func (p *IMServiceSendResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *IMServiceSendResult) Field0DeepEqual(src *SendResponse) bool
- func (p *IMServiceSendResult) GetResult() interface{}
- func (p *IMServiceSendResult) GetSuccess() (v *SendResponse)
- func (p *IMServiceSendResult) InitDefault()
- func (p *IMServiceSendResult) IsSetSuccess() bool
- func (p *IMServiceSendResult) Read(iprot thrift.TProtocol) (err error)
- func (p *IMServiceSendResult) ReadField0(iprot thrift.TProtocol) error
- func (p *IMServiceSendResult) SetSuccess(x interface{})
- func (p *IMServiceSendResult) String() string
- func (p *IMServiceSendResult) 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) FastWrite(buf []byte) int
- func (p *Message) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *Message) Field1DeepEqual(src string) bool
- func (p *Message) Field2DeepEqual(src string) bool
- func (p *Message) Field3DeepEqual(src string) bool
- func (p *Message) Field4DeepEqual(src int64) bool
- func (p *Message) GetChat() (v string)
- func (p *Message) GetSendTime() (v int64)
- func (p *Message) GetSender() (v string)
- func (p *Message) GetText() (v string)
- func (p *Message) InitDefault()
- 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) SetChat(val string)
- func (p *Message) SetSendTime(val int64)
- func (p *Message) SetSender(val string)
- func (p *Message) SetText(val string)
- func (p *Message) String() string
- func (p *Message) Write(oprot thrift.TProtocol) (err error)
- type PullRequest
- func (p *PullRequest) BLength() int
- func (p *PullRequest) DeepEqual(ano *PullRequest) bool
- func (p *PullRequest) FastRead(buf []byte) (int, error)
- func (p *PullRequest) FastReadField1(buf []byte) (int, error)
- func (p *PullRequest) FastReadField2(buf []byte) (int, error)
- func (p *PullRequest) FastReadField3(buf []byte) (int, error)
- func (p *PullRequest) FastReadField4(buf []byte) (int, error)
- func (p *PullRequest) FastWrite(buf []byte) int
- func (p *PullRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *PullRequest) Field1DeepEqual(src string) bool
- func (p *PullRequest) Field2DeepEqual(src int64) bool
- func (p *PullRequest) Field3DeepEqual(src int32) bool
- func (p *PullRequest) Field4DeepEqual(src *bool) bool
- func (p *PullRequest) GetChat() (v string)
- func (p *PullRequest) GetCursor() (v int64)
- func (p *PullRequest) GetLimit() (v int32)
- func (p *PullRequest) GetReverse() (v bool)
- func (p *PullRequest) InitDefault()
- func (p *PullRequest) IsSetReverse() bool
- func (p *PullRequest) Read(iprot thrift.TProtocol) (err error)
- func (p *PullRequest) ReadField1(iprot thrift.TProtocol) error
- func (p *PullRequest) ReadField2(iprot thrift.TProtocol) error
- func (p *PullRequest) ReadField3(iprot thrift.TProtocol) error
- func (p *PullRequest) ReadField4(iprot thrift.TProtocol) error
- func (p *PullRequest) SetChat(val string)
- func (p *PullRequest) SetCursor(val int64)
- func (p *PullRequest) SetLimit(val int32)
- func (p *PullRequest) SetReverse(val *bool)
- func (p *PullRequest) String() string
- func (p *PullRequest) Write(oprot thrift.TProtocol) (err error)
- type PullResponse
- func (p *PullResponse) BLength() int
- func (p *PullResponse) DeepEqual(ano *PullResponse) bool
- func (p *PullResponse) FastRead(buf []byte) (int, error)
- func (p *PullResponse) FastReadField1(buf []byte) (int, error)
- func (p *PullResponse) FastReadField2(buf []byte) (int, error)
- func (p *PullResponse) FastReadField3(buf []byte) (int, error)
- func (p *PullResponse) FastReadField4(buf []byte) (int, error)
- func (p *PullResponse) FastReadField5(buf []byte) (int, error)
- func (p *PullResponse) FastWrite(buf []byte) int
- func (p *PullResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *PullResponse) Field1DeepEqual(src int32) bool
- func (p *PullResponse) Field2DeepEqual(src string) bool
- func (p *PullResponse) Field3DeepEqual(src []*Message) bool
- func (p *PullResponse) Field4DeepEqual(src *bool) bool
- func (p *PullResponse) Field5DeepEqual(src *int64) bool
- func (p *PullResponse) GetCode() (v int32)
- func (p *PullResponse) GetHasMore() (v bool)
- func (p *PullResponse) GetMessages() (v []*Message)
- func (p *PullResponse) GetMsg() (v string)
- func (p *PullResponse) GetNextCursor() (v int64)
- func (p *PullResponse) InitDefault()
- func (p *PullResponse) IsSetHasMore() bool
- func (p *PullResponse) IsSetMessages() bool
- func (p *PullResponse) IsSetNextCursor() bool
- func (p *PullResponse) Read(iprot thrift.TProtocol) (err error)
- func (p *PullResponse) ReadField1(iprot thrift.TProtocol) error
- func (p *PullResponse) ReadField2(iprot thrift.TProtocol) error
- func (p *PullResponse) ReadField3(iprot thrift.TProtocol) error
- func (p *PullResponse) ReadField4(iprot thrift.TProtocol) error
- func (p *PullResponse) ReadField5(iprot thrift.TProtocol) error
- func (p *PullResponse) SetCode(val int32)
- func (p *PullResponse) SetHasMore(val *bool)
- func (p *PullResponse) SetMessages(val []*Message)
- func (p *PullResponse) SetMsg(val string)
- func (p *PullResponse) SetNextCursor(val *int64)
- func (p *PullResponse) String() string
- func (p *PullResponse) Write(oprot thrift.TProtocol) (err error)
- type SendRequest
- func (p *SendRequest) BLength() int
- func (p *SendRequest) DeepEqual(ano *SendRequest) bool
- func (p *SendRequest) FastRead(buf []byte) (int, error)
- func (p *SendRequest) FastReadField1(buf []byte) (int, error)
- func (p *SendRequest) FastWrite(buf []byte) int
- func (p *SendRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *SendRequest) Field1DeepEqual(src *Message) bool
- func (p *SendRequest) GetMessage() (v *Message)
- func (p *SendRequest) InitDefault()
- func (p *SendRequest) IsSetMessage() bool
- func (p *SendRequest) Read(iprot thrift.TProtocol) (err error)
- func (p *SendRequest) ReadField1(iprot thrift.TProtocol) error
- func (p *SendRequest) SetMessage(val *Message)
- func (p *SendRequest) String() string
- func (p *SendRequest) Write(oprot thrift.TProtocol) (err error)
- type SendResponse
- func (p *SendResponse) BLength() int
- func (p *SendResponse) DeepEqual(ano *SendResponse) bool
- func (p *SendResponse) FastRead(buf []byte) (int, error)
- func (p *SendResponse) FastReadField1(buf []byte) (int, error)
- func (p *SendResponse) FastReadField2(buf []byte) (int, error)
- func (p *SendResponse) FastWrite(buf []byte) int
- func (p *SendResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
- func (p *SendResponse) Field1DeepEqual(src int32) bool
- func (p *SendResponse) Field2DeepEqual(src string) bool
- func (p *SendResponse) GetCode() (v int32)
- func (p *SendResponse) GetMsg() (v string)
- func (p *SendResponse) InitDefault()
- func (p *SendResponse) Read(iprot thrift.TProtocol) (err error)
- func (p *SendResponse) ReadField1(iprot thrift.TProtocol) error
- func (p *SendResponse) ReadField2(iprot thrift.TProtocol) error
- func (p *SendResponse) SetCode(val int32)
- func (p *SendResponse) SetMsg(val string)
- func (p *SendResponse) String() string
- func (p *SendResponse) Write(oprot thrift.TProtocol) (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var KitexUnusedProtection = struct{}{}
KitexUnusedProtection is used to prevent 'imported and not used' error.
View Source
var PullRequest_Reverse_DEFAULT bool
View Source
var PullResponse_HasMore_DEFAULT bool
View Source
var PullResponse_Messages_DEFAULT []*Message
View Source
var PullResponse_NextCursor_DEFAULT int64
Functions ¶
This section is empty.
Types ¶
type IMService ¶
type IMService interface { Send(ctx context.Context, req *SendRequest) (r *SendResponse, err error) Pull(ctx context.Context, req *PullRequest) (r *PullResponse, err error) }
type IMServiceClient ¶
type IMServiceClient struct {
// contains filtered or unexported fields
}
func NewIMServiceClient ¶
func NewIMServiceClient(c thrift.TClient) *IMServiceClient
func NewIMServiceClientFactory ¶
func NewIMServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *IMServiceClient
func NewIMServiceClientProtocol ¶
func NewIMServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *IMServiceClient
func (*IMServiceClient) Client_ ¶
func (p *IMServiceClient) Client_() thrift.TClient
func (*IMServiceClient) Pull ¶
func (p *IMServiceClient) Pull(ctx context.Context, req *PullRequest) (r *PullResponse, err error)
func (*IMServiceClient) Send ¶
func (p *IMServiceClient) Send(ctx context.Context, req *SendRequest) (r *SendResponse, err error)
type IMServiceProcessor ¶
type IMServiceProcessor struct {
// contains filtered or unexported fields
}
func NewIMServiceProcessor ¶
func NewIMServiceProcessor(handler IMService) *IMServiceProcessor
func (*IMServiceProcessor) AddToProcessorMap ¶
func (p *IMServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*IMServiceProcessor) GetProcessorFunction ¶
func (p *IMServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*IMServiceProcessor) Process ¶
func (p *IMServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*IMServiceProcessor) ProcessorMap ¶
func (p *IMServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
type IMServicePullArgs ¶
type IMServicePullArgs struct {
Req *PullRequest `thrift:"req,2" frugal:"2,default,PullRequest" json:"req"`
}
func NewIMServicePullArgs ¶
func NewIMServicePullArgs() *IMServicePullArgs
func (*IMServicePullArgs) BLength ¶
func (p *IMServicePullArgs) BLength() int
func (*IMServicePullArgs) DeepEqual ¶
func (p *IMServicePullArgs) DeepEqual(ano *IMServicePullArgs) bool
func (*IMServicePullArgs) FastReadField2 ¶
func (p *IMServicePullArgs) FastReadField2(buf []byte) (int, error)
func (*IMServicePullArgs) FastWrite ¶
func (p *IMServicePullArgs) FastWrite(buf []byte) int
for compatibility
func (*IMServicePullArgs) FastWriteNocopy ¶
func (p *IMServicePullArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*IMServicePullArgs) Field2DeepEqual ¶
func (p *IMServicePullArgs) Field2DeepEqual(src *PullRequest) bool
func (*IMServicePullArgs) GetFirstArgument ¶
func (p *IMServicePullArgs) GetFirstArgument() interface{}
func (*IMServicePullArgs) GetReq ¶
func (p *IMServicePullArgs) GetReq() (v *PullRequest)
func (*IMServicePullArgs) InitDefault ¶
func (p *IMServicePullArgs) InitDefault()
func (*IMServicePullArgs) IsSetReq ¶
func (p *IMServicePullArgs) IsSetReq() bool
func (*IMServicePullArgs) Read ¶
func (p *IMServicePullArgs) Read(iprot thrift.TProtocol) (err error)
func (*IMServicePullArgs) ReadField2 ¶
func (p *IMServicePullArgs) ReadField2(iprot thrift.TProtocol) error
func (*IMServicePullArgs) SetReq ¶
func (p *IMServicePullArgs) SetReq(val *PullRequest)
func (*IMServicePullArgs) String ¶
func (p *IMServicePullArgs) String() string
type IMServicePullResult ¶
type IMServicePullResult struct {
Success *PullResponse `thrift:"success,0,optional" frugal:"0,optional,PullResponse" json:"success,omitempty"`
}
func NewIMServicePullResult ¶
func NewIMServicePullResult() *IMServicePullResult
func (*IMServicePullResult) BLength ¶
func (p *IMServicePullResult) BLength() int
func (*IMServicePullResult) DeepEqual ¶
func (p *IMServicePullResult) DeepEqual(ano *IMServicePullResult) bool
func (*IMServicePullResult) FastRead ¶
func (p *IMServicePullResult) FastRead(buf []byte) (int, error)
func (*IMServicePullResult) FastReadField0 ¶
func (p *IMServicePullResult) FastReadField0(buf []byte) (int, error)
func (*IMServicePullResult) FastWrite ¶
func (p *IMServicePullResult) FastWrite(buf []byte) int
for compatibility
func (*IMServicePullResult) FastWriteNocopy ¶
func (p *IMServicePullResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*IMServicePullResult) Field0DeepEqual ¶
func (p *IMServicePullResult) Field0DeepEqual(src *PullResponse) bool
func (*IMServicePullResult) GetResult ¶
func (p *IMServicePullResult) GetResult() interface{}
func (*IMServicePullResult) GetSuccess ¶
func (p *IMServicePullResult) GetSuccess() (v *PullResponse)
func (*IMServicePullResult) InitDefault ¶
func (p *IMServicePullResult) InitDefault()
func (*IMServicePullResult) IsSetSuccess ¶
func (p *IMServicePullResult) IsSetSuccess() bool
func (*IMServicePullResult) Read ¶
func (p *IMServicePullResult) Read(iprot thrift.TProtocol) (err error)
func (*IMServicePullResult) ReadField0 ¶
func (p *IMServicePullResult) ReadField0(iprot thrift.TProtocol) error
func (*IMServicePullResult) SetSuccess ¶
func (p *IMServicePullResult) SetSuccess(x interface{})
func (*IMServicePullResult) String ¶
func (p *IMServicePullResult) String() string
type IMServiceSendArgs ¶
type IMServiceSendArgs struct {
Req *SendRequest `thrift:"req,1" frugal:"1,default,SendRequest" json:"req"`
}
func NewIMServiceSendArgs ¶
func NewIMServiceSendArgs() *IMServiceSendArgs
func (*IMServiceSendArgs) BLength ¶
func (p *IMServiceSendArgs) BLength() int
func (*IMServiceSendArgs) DeepEqual ¶
func (p *IMServiceSendArgs) DeepEqual(ano *IMServiceSendArgs) bool
func (*IMServiceSendArgs) FastReadField1 ¶
func (p *IMServiceSendArgs) FastReadField1(buf []byte) (int, error)
func (*IMServiceSendArgs) FastWrite ¶
func (p *IMServiceSendArgs) FastWrite(buf []byte) int
for compatibility
func (*IMServiceSendArgs) FastWriteNocopy ¶
func (p *IMServiceSendArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*IMServiceSendArgs) Field1DeepEqual ¶
func (p *IMServiceSendArgs) Field1DeepEqual(src *SendRequest) bool
func (*IMServiceSendArgs) GetFirstArgument ¶
func (p *IMServiceSendArgs) GetFirstArgument() interface{}
func (*IMServiceSendArgs) GetReq ¶
func (p *IMServiceSendArgs) GetReq() (v *SendRequest)
func (*IMServiceSendArgs) InitDefault ¶
func (p *IMServiceSendArgs) InitDefault()
func (*IMServiceSendArgs) IsSetReq ¶
func (p *IMServiceSendArgs) IsSetReq() bool
func (*IMServiceSendArgs) Read ¶
func (p *IMServiceSendArgs) Read(iprot thrift.TProtocol) (err error)
func (*IMServiceSendArgs) ReadField1 ¶
func (p *IMServiceSendArgs) ReadField1(iprot thrift.TProtocol) error
func (*IMServiceSendArgs) SetReq ¶
func (p *IMServiceSendArgs) SetReq(val *SendRequest)
func (*IMServiceSendArgs) String ¶
func (p *IMServiceSendArgs) String() string
type IMServiceSendResult ¶
type IMServiceSendResult struct {
Success *SendResponse `thrift:"success,0,optional" frugal:"0,optional,SendResponse" json:"success,omitempty"`
}
func NewIMServiceSendResult ¶
func NewIMServiceSendResult() *IMServiceSendResult
func (*IMServiceSendResult) BLength ¶
func (p *IMServiceSendResult) BLength() int
func (*IMServiceSendResult) DeepEqual ¶
func (p *IMServiceSendResult) DeepEqual(ano *IMServiceSendResult) bool
func (*IMServiceSendResult) FastRead ¶
func (p *IMServiceSendResult) FastRead(buf []byte) (int, error)
func (*IMServiceSendResult) FastReadField0 ¶
func (p *IMServiceSendResult) FastReadField0(buf []byte) (int, error)
func (*IMServiceSendResult) FastWrite ¶
func (p *IMServiceSendResult) FastWrite(buf []byte) int
for compatibility
func (*IMServiceSendResult) FastWriteNocopy ¶
func (p *IMServiceSendResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*IMServiceSendResult) Field0DeepEqual ¶
func (p *IMServiceSendResult) Field0DeepEqual(src *SendResponse) bool
func (*IMServiceSendResult) GetResult ¶
func (p *IMServiceSendResult) GetResult() interface{}
func (*IMServiceSendResult) GetSuccess ¶
func (p *IMServiceSendResult) GetSuccess() (v *SendResponse)
func (*IMServiceSendResult) InitDefault ¶
func (p *IMServiceSendResult) InitDefault()
func (*IMServiceSendResult) IsSetSuccess ¶
func (p *IMServiceSendResult) IsSetSuccess() bool
func (*IMServiceSendResult) Read ¶
func (p *IMServiceSendResult) Read(iprot thrift.TProtocol) (err error)
func (*IMServiceSendResult) ReadField0 ¶
func (p *IMServiceSendResult) ReadField0(iprot thrift.TProtocol) error
func (*IMServiceSendResult) SetSuccess ¶
func (p *IMServiceSendResult) SetSuccess(x interface{})
func (*IMServiceSendResult) String ¶
func (p *IMServiceSendResult) String() string
type Message ¶
type Message struct { Chat string `thrift:"Chat,1" frugal:"1,default,string" json:"Chat"` Text string `thrift:"Text,2" frugal:"2,default,string" json:"Text"` Sender string `thrift:"Sender,3" frugal:"3,default,string" json:"Sender"` SendTime int64 `thrift:"SendTime,4" frugal:"4,default,i64" json:"SendTime"` }
var SendRequest_Message_DEFAULT *Message
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) GetSendTime ¶
func (*Message) InitDefault ¶
func (p *Message) InitDefault()
func (*Message) SetSendTime ¶
type PullRequest ¶
type PullRequest struct { Chat string `thrift:"Chat,1,required" frugal:"1,required,string" json:"Chat"` Cursor int64 `thrift:"Cursor,2,required" frugal:"2,required,i64" json:"Cursor"` Limit int32 `thrift:"Limit,3,required" frugal:"3,required,i32" json:"Limit"` Reverse *bool `thrift:"Reverse,4,optional" frugal:"4,optional,bool" json:"Reverse,omitempty"` }
var IMServicePullArgs_Req_DEFAULT *PullRequest
func NewPullRequest ¶
func NewPullRequest() *PullRequest
func (*PullRequest) BLength ¶
func (p *PullRequest) BLength() int
func (*PullRequest) DeepEqual ¶
func (p *PullRequest) DeepEqual(ano *PullRequest) bool
func (*PullRequest) FastReadField1 ¶
func (p *PullRequest) FastReadField1(buf []byte) (int, error)
func (*PullRequest) FastReadField2 ¶
func (p *PullRequest) FastReadField2(buf []byte) (int, error)
func (*PullRequest) FastReadField3 ¶
func (p *PullRequest) FastReadField3(buf []byte) (int, error)
func (*PullRequest) FastReadField4 ¶
func (p *PullRequest) FastReadField4(buf []byte) (int, error)
func (*PullRequest) FastWriteNocopy ¶
func (p *PullRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*PullRequest) Field1DeepEqual ¶
func (p *PullRequest) Field1DeepEqual(src string) bool
func (*PullRequest) Field2DeepEqual ¶
func (p *PullRequest) Field2DeepEqual(src int64) bool
func (*PullRequest) Field3DeepEqual ¶
func (p *PullRequest) Field3DeepEqual(src int32) bool
func (*PullRequest) Field4DeepEqual ¶
func (p *PullRequest) Field4DeepEqual(src *bool) bool
func (*PullRequest) GetChat ¶
func (p *PullRequest) GetChat() (v string)
func (*PullRequest) GetCursor ¶
func (p *PullRequest) GetCursor() (v int64)
func (*PullRequest) GetLimit ¶
func (p *PullRequest) GetLimit() (v int32)
func (*PullRequest) GetReverse ¶
func (p *PullRequest) GetReverse() (v bool)
func (*PullRequest) InitDefault ¶
func (p *PullRequest) InitDefault()
func (*PullRequest) IsSetReverse ¶
func (p *PullRequest) IsSetReverse() bool
func (*PullRequest) ReadField1 ¶
func (p *PullRequest) ReadField1(iprot thrift.TProtocol) error
func (*PullRequest) ReadField2 ¶
func (p *PullRequest) ReadField2(iprot thrift.TProtocol) error
func (*PullRequest) ReadField3 ¶
func (p *PullRequest) ReadField3(iprot thrift.TProtocol) error
func (*PullRequest) ReadField4 ¶
func (p *PullRequest) ReadField4(iprot thrift.TProtocol) error
func (*PullRequest) SetChat ¶
func (p *PullRequest) SetChat(val string)
func (*PullRequest) SetCursor ¶
func (p *PullRequest) SetCursor(val int64)
func (*PullRequest) SetLimit ¶
func (p *PullRequest) SetLimit(val int32)
func (*PullRequest) SetReverse ¶
func (p *PullRequest) SetReverse(val *bool)
func (*PullRequest) String ¶
func (p *PullRequest) String() string
type PullResponse ¶
type PullResponse struct { Code int32 `thrift:"Code,1,required" frugal:"1,required,i32" json:"Code"` Msg string `thrift:"Msg,2,required" frugal:"2,required,string" json:"Msg"` Messages []*Message `thrift:"Messages,3,optional" frugal:"3,optional,list<Message>" json:"Messages,omitempty"` HasMore *bool `thrift:"HasMore,4,optional" frugal:"4,optional,bool" json:"HasMore,omitempty"` NextCursor *int64 `thrift:"NextCursor,5,optional" frugal:"5,optional,i64" json:"NextCursor,omitempty"` }
var IMServicePullResult_Success_DEFAULT *PullResponse
func NewPullResponse ¶
func NewPullResponse() *PullResponse
func (*PullResponse) BLength ¶
func (p *PullResponse) BLength() int
func (*PullResponse) DeepEqual ¶
func (p *PullResponse) DeepEqual(ano *PullResponse) bool
func (*PullResponse) FastReadField1 ¶
func (p *PullResponse) FastReadField1(buf []byte) (int, error)
func (*PullResponse) FastReadField2 ¶
func (p *PullResponse) FastReadField2(buf []byte) (int, error)
func (*PullResponse) FastReadField3 ¶
func (p *PullResponse) FastReadField3(buf []byte) (int, error)
func (*PullResponse) FastReadField4 ¶
func (p *PullResponse) FastReadField4(buf []byte) (int, error)
func (*PullResponse) FastReadField5 ¶
func (p *PullResponse) FastReadField5(buf []byte) (int, error)
func (*PullResponse) FastWriteNocopy ¶
func (p *PullResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*PullResponse) Field1DeepEqual ¶
func (p *PullResponse) Field1DeepEqual(src int32) bool
func (*PullResponse) Field2DeepEqual ¶
func (p *PullResponse) Field2DeepEqual(src string) bool
func (*PullResponse) Field3DeepEqual ¶
func (p *PullResponse) Field3DeepEqual(src []*Message) bool
func (*PullResponse) Field4DeepEqual ¶
func (p *PullResponse) Field4DeepEqual(src *bool) bool
func (*PullResponse) Field5DeepEqual ¶
func (p *PullResponse) Field5DeepEqual(src *int64) bool
func (*PullResponse) GetCode ¶
func (p *PullResponse) GetCode() (v int32)
func (*PullResponse) GetHasMore ¶
func (p *PullResponse) GetHasMore() (v bool)
func (*PullResponse) GetMessages ¶
func (p *PullResponse) GetMessages() (v []*Message)
func (*PullResponse) GetMsg ¶
func (p *PullResponse) GetMsg() (v string)
func (*PullResponse) GetNextCursor ¶
func (p *PullResponse) GetNextCursor() (v int64)
func (*PullResponse) InitDefault ¶
func (p *PullResponse) InitDefault()
func (*PullResponse) IsSetHasMore ¶
func (p *PullResponse) IsSetHasMore() bool
func (*PullResponse) IsSetMessages ¶
func (p *PullResponse) IsSetMessages() bool
func (*PullResponse) IsSetNextCursor ¶
func (p *PullResponse) IsSetNextCursor() bool
func (*PullResponse) ReadField1 ¶
func (p *PullResponse) ReadField1(iprot thrift.TProtocol) error
func (*PullResponse) ReadField2 ¶
func (p *PullResponse) ReadField2(iprot thrift.TProtocol) error
func (*PullResponse) ReadField3 ¶
func (p *PullResponse) ReadField3(iprot thrift.TProtocol) error
func (*PullResponse) ReadField4 ¶
func (p *PullResponse) ReadField4(iprot thrift.TProtocol) error
func (*PullResponse) ReadField5 ¶
func (p *PullResponse) ReadField5(iprot thrift.TProtocol) error
func (*PullResponse) SetCode ¶
func (p *PullResponse) SetCode(val int32)
func (*PullResponse) SetHasMore ¶
func (p *PullResponse) SetHasMore(val *bool)
func (*PullResponse) SetMessages ¶
func (p *PullResponse) SetMessages(val []*Message)
func (*PullResponse) SetMsg ¶
func (p *PullResponse) SetMsg(val string)
func (*PullResponse) SetNextCursor ¶
func (p *PullResponse) SetNextCursor(val *int64)
func (*PullResponse) String ¶
func (p *PullResponse) String() string
type SendRequest ¶
type SendRequest struct {
Message *Message `thrift:"message,1,required" frugal:"1,required,Message" json:"message"`
}
var IMServiceSendArgs_Req_DEFAULT *SendRequest
func NewSendRequest ¶
func NewSendRequest() *SendRequest
func (*SendRequest) BLength ¶
func (p *SendRequest) BLength() int
func (*SendRequest) DeepEqual ¶
func (p *SendRequest) DeepEqual(ano *SendRequest) bool
func (*SendRequest) FastReadField1 ¶
func (p *SendRequest) FastReadField1(buf []byte) (int, error)
func (*SendRequest) FastWriteNocopy ¶
func (p *SendRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*SendRequest) Field1DeepEqual ¶
func (p *SendRequest) Field1DeepEqual(src *Message) bool
func (*SendRequest) GetMessage ¶
func (p *SendRequest) GetMessage() (v *Message)
func (*SendRequest) InitDefault ¶
func (p *SendRequest) InitDefault()
func (*SendRequest) IsSetMessage ¶
func (p *SendRequest) IsSetMessage() bool
func (*SendRequest) ReadField1 ¶
func (p *SendRequest) ReadField1(iprot thrift.TProtocol) error
func (*SendRequest) SetMessage ¶
func (p *SendRequest) SetMessage(val *Message)
func (*SendRequest) String ¶
func (p *SendRequest) String() string
type SendResponse ¶
type SendResponse struct { Code int32 `thrift:"Code,1,required" frugal:"1,required,i32" json:"Code"` Msg string `thrift:"Msg,2,required" frugal:"2,required,string" json:"Msg"` }
var IMServiceSendResult_Success_DEFAULT *SendResponse
func NewSendResponse ¶
func NewSendResponse() *SendResponse
func (*SendResponse) BLength ¶
func (p *SendResponse) BLength() int
func (*SendResponse) DeepEqual ¶
func (p *SendResponse) DeepEqual(ano *SendResponse) bool
func (*SendResponse) FastReadField1 ¶
func (p *SendResponse) FastReadField1(buf []byte) (int, error)
func (*SendResponse) FastReadField2 ¶
func (p *SendResponse) FastReadField2(buf []byte) (int, error)
func (*SendResponse) FastWriteNocopy ¶
func (p *SendResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int
func (*SendResponse) Field1DeepEqual ¶
func (p *SendResponse) Field1DeepEqual(src int32) bool
func (*SendResponse) Field2DeepEqual ¶
func (p *SendResponse) Field2DeepEqual(src string) bool
func (*SendResponse) GetCode ¶
func (p *SendResponse) GetCode() (v int32)
func (*SendResponse) GetMsg ¶
func (p *SendResponse) GetMsg() (v string)
func (*SendResponse) InitDefault ¶
func (p *SendResponse) InitDefault()
func (*SendResponse) ReadField1 ¶
func (p *SendResponse) ReadField1(iprot thrift.TProtocol) error
func (*SendResponse) ReadField2 ¶
func (p *SendResponse) ReadField2(iprot thrift.TProtocol) error
func (*SendResponse) SetCode ¶
func (p *SendResponse) SetCode(val int32)
func (*SendResponse) SetMsg ¶
func (p *SendResponse) SetMsg(val string)
func (*SendResponse) String ¶
func (p *SendResponse) String() string
Click to show internal directories.
Click to hide internal directories.