Documentation ¶
Index ¶
- Variables
- type RpcService
- type RpcServiceClient
- type RpcServiceFunCallArgs
- func (p *RpcServiceFunCallArgs) GetCallTime() int64
- func (p *RpcServiceFunCallArgs) GetFunCode() string
- func (p *RpcServiceFunCallArgs) GetParamMap() map[string]string
- func (p *RpcServiceFunCallArgs) Read(iprot thrift.TProtocol) error
- func (p *RpcServiceFunCallArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *RpcServiceFunCallArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *RpcServiceFunCallArgs) ReadField3(iprot thrift.TProtocol) error
- func (p *RpcServiceFunCallArgs) String() string
- func (p *RpcServiceFunCallArgs) Write(oprot thrift.TProtocol) error
- type RpcServiceFunCallResult
- func (p *RpcServiceFunCallResult) GetSuccess() []string
- func (p *RpcServiceFunCallResult) IsSetSuccess() bool
- func (p *RpcServiceFunCallResult) Read(iprot thrift.TProtocol) error
- func (p *RpcServiceFunCallResult) ReadField0(iprot thrift.TProtocol) error
- func (p *RpcServiceFunCallResult) String() string
- func (p *RpcServiceFunCallResult) Write(oprot thrift.TProtocol) error
- type RpcServiceProcessor
- func (p *RpcServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *RpcServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *RpcServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *RpcServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Constants ¶
This section is empty.
Variables ¶
View Source
var GoUnusedProtection__ int
View Source
var RpcServiceFunCallResult_Success_DEFAULT []string
Functions ¶
This section is empty.
Types ¶
type RpcService ¶
type RpcServiceClient ¶
type RpcServiceClient struct { Transport thrift.TTransport ProtocolFactory thrift.TProtocolFactory InputProtocol thrift.TProtocol OutputProtocol thrift.TProtocol SeqId int32 }
func NewRpcServiceClientFactory ¶
func NewRpcServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *RpcServiceClient
func NewRpcServiceClientProtocol ¶
func NewRpcServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *RpcServiceClient
type RpcServiceFunCallArgs ¶
type RpcServiceFunCallArgs struct { CallTime int64 `thrift:"callTime,1" db:"callTime" json:"callTime"` FunCode string `thrift:"funCode,2" db:"funCode" json:"funCode"` ParamMap map[string]string `thrift:"paramMap,3" db:"paramMap" json:"paramMap"` }
Attributes:
- CallTime
- FunCode
- ParamMap
func NewRpcServiceFunCallArgs ¶
func NewRpcServiceFunCallArgs() *RpcServiceFunCallArgs
func (*RpcServiceFunCallArgs) GetCallTime ¶
func (p *RpcServiceFunCallArgs) GetCallTime() int64
func (*RpcServiceFunCallArgs) GetFunCode ¶
func (p *RpcServiceFunCallArgs) GetFunCode() string
func (*RpcServiceFunCallArgs) GetParamMap ¶
func (p *RpcServiceFunCallArgs) GetParamMap() map[string]string
func (*RpcServiceFunCallArgs) Read ¶
func (p *RpcServiceFunCallArgs) Read(iprot thrift.TProtocol) error
func (*RpcServiceFunCallArgs) ReadField1 ¶
func (p *RpcServiceFunCallArgs) ReadField1(iprot thrift.TProtocol) error
func (*RpcServiceFunCallArgs) ReadField2 ¶
func (p *RpcServiceFunCallArgs) ReadField2(iprot thrift.TProtocol) error
func (*RpcServiceFunCallArgs) ReadField3 ¶
func (p *RpcServiceFunCallArgs) ReadField3(iprot thrift.TProtocol) error
func (*RpcServiceFunCallArgs) String ¶
func (p *RpcServiceFunCallArgs) String() string
type RpcServiceFunCallResult ¶
type RpcServiceFunCallResult struct {
Success []string `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewRpcServiceFunCallResult ¶
func NewRpcServiceFunCallResult() *RpcServiceFunCallResult
func (*RpcServiceFunCallResult) GetSuccess ¶
func (p *RpcServiceFunCallResult) GetSuccess() []string
func (*RpcServiceFunCallResult) IsSetSuccess ¶
func (p *RpcServiceFunCallResult) IsSetSuccess() bool
func (*RpcServiceFunCallResult) Read ¶
func (p *RpcServiceFunCallResult) Read(iprot thrift.TProtocol) error
func (*RpcServiceFunCallResult) ReadField0 ¶
func (p *RpcServiceFunCallResult) ReadField0(iprot thrift.TProtocol) error
func (*RpcServiceFunCallResult) String ¶
func (p *RpcServiceFunCallResult) String() string
type RpcServiceProcessor ¶
type RpcServiceProcessor struct {
// contains filtered or unexported fields
}
func NewRpcServiceProcessor ¶
func NewRpcServiceProcessor(handler RpcService) *RpcServiceProcessor
func (*RpcServiceProcessor) AddToProcessorMap ¶
func (p *RpcServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*RpcServiceProcessor) GetProcessorFunction ¶
func (p *RpcServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*RpcServiceProcessor) Process ¶
func (p *RpcServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*RpcServiceProcessor) ProcessorMap ¶
func (p *RpcServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Click to show internal directories.
Click to hide internal directories.