Versions in this module Expand all Collapse all v0 v0.6.1 Jul 31, 2023 v0.0.4 Jul 31, 2023 Changes in this version + var BaseResp_Extra_DEFAULT map[string]string + var Base_Extra_DEFAULT map[string]string + func Parse(tree *parser.Thrift, mode ParseMode) (*descriptor.ServiceDescriptor, error) + func SetDefaultParseMode(m ParseMode) + type Base struct + Addr string + Caller string + Client string + Extra map[string]string + LogID string + TrafficEnv *TrafficEnv + func NewBase() *Base + func (p *Base) GetAddr() string + func (p *Base) GetCaller() string + func (p *Base) GetClient() string + func (p *Base) GetExtra() map[string]string + func (p *Base) GetLogID() string + func (p *Base) GetTrafficEnv() *TrafficEnv + func (p *Base) IsSetExtra() bool + func (p *Base) IsSetTrafficEnv() bool + func (p *Base) Read(iprot thrift.TProtocol) (err error) + func (p *Base) ReadField1(iprot thrift.TProtocol) error + func (p *Base) ReadField2(iprot thrift.TProtocol) error + func (p *Base) ReadField3(iprot thrift.TProtocol) error + func (p *Base) ReadField4(iprot thrift.TProtocol) error + func (p *Base) ReadField5(iprot thrift.TProtocol) error + func (p *Base) ReadField6(iprot thrift.TProtocol) error + func (p *Base) SetAddr(val string) + func (p *Base) SetCaller(val string) + func (p *Base) SetClient(val string) + func (p *Base) SetExtra(val map[string]string) + func (p *Base) SetLogID(val string) + func (p *Base) SetTrafficEnv(val *TrafficEnv) + func (p *Base) String() string + func (p *Base) Write(oprot thrift.TProtocol) (err error) + type BaseResp struct + Extra map[string]string + StatusCode int32 + StatusMessage string + func NewBaseResp() *BaseResp + func (p *BaseResp) GetExtra() map[string]string + func (p *BaseResp) GetStatusCode() int32 + func (p *BaseResp) GetStatusMessage() string + func (p *BaseResp) IsSetExtra() bool + func (p *BaseResp) Read(iprot thrift.TProtocol) (err error) + func (p *BaseResp) ReadField1(iprot thrift.TProtocol) error + func (p *BaseResp) ReadField2(iprot thrift.TProtocol) error + func (p *BaseResp) ReadField3(iprot thrift.TProtocol) error + func (p *BaseResp) SetExtra(val map[string]string) + func (p *BaseResp) SetStatusCode(val int32) + func (p *BaseResp) SetStatusMessage(val string) + func (p *BaseResp) String() string + func (p *BaseResp) Write(oprot thrift.TProtocol) (err error) + type MessageReader interface + Read func(ctx context.Context, method string, in thrift.TProtocol) (interface{}, error) + type MessageWriter interface + Write func(ctx context.Context, out thrift.TProtocol, msg interface{}, requestBase *Base) error + type ParseMode int + const CombineServices + const FirstServiceOnly + const LastServiceOnly + func DefaultParseMode() ParseMode + type ReadHTTPPbResponse struct + func NewReadHTTPPbResponse(svc *descriptor.ServiceDescriptor, pbSvc proto.ServiceDescriptor) *ReadHTTPPbResponse + func (r *ReadHTTPPbResponse) Read(ctx context.Context, method string, in thrift.TProtocol) (interface{}, error) + type ReadHTTPResponse struct + func NewReadHTTPResponse(svc *descriptor.ServiceDescriptor) *ReadHTTPResponse + func (r *ReadHTTPResponse) Read(ctx context.Context, method string, in thrift.TProtocol) (interface{}, error) + func (r *ReadHTTPResponse) SetBase64Binary(enable bool) + type ReadJSON struct + func NewReadJSON(svc *descriptor.ServiceDescriptor, isClient bool) *ReadJSON + func (m *ReadJSON) Read(ctx context.Context, method string, in thrift.TProtocol) (interface{}, error) + func (m *ReadJSON) SetBinaryWithBase64(enable bool) + type ReadStruct struct + func NewReadStruct(svc *descriptor.ServiceDescriptor, isClient bool) *ReadStruct + func NewReadStructForJSON(svc *descriptor.ServiceDescriptor, isClient bool) *ReadStruct + func (m *ReadStruct) Read(ctx context.Context, method string, in thrift.TProtocol) (interface{}, error) + type TrafficEnv struct + Env string + Open bool + var Base_TrafficEnv_DEFAULT *TrafficEnv + func NewTrafficEnv() *TrafficEnv + func (p *TrafficEnv) GetEnv() string + func (p *TrafficEnv) GetOpen() bool + func (p *TrafficEnv) Read(iprot thrift.TProtocol) (err error) + func (p *TrafficEnv) ReadField1(iprot thrift.TProtocol) error + func (p *TrafficEnv) ReadField2(iprot thrift.TProtocol) error + func (p *TrafficEnv) SetEnv(val string) + func (p *TrafficEnv) SetOpen(val bool) + func (p *TrafficEnv) String() string + func (p *TrafficEnv) Write(oprot thrift.TProtocol) (err error) + type WriteHTTPPbRequest struct + func NewWriteHTTPPbRequest(svc *descriptor.ServiceDescriptor, pbSvc *desc.ServiceDescriptor) *WriteHTTPPbRequest + func (w *WriteHTTPPbRequest) Write(ctx context.Context, out thrift.TProtocol, msg interface{}, requestBase *Base) error + type WriteHTTPRequest struct + func NewWriteHTTPRequest(svc *descriptor.ServiceDescriptor) *WriteHTTPRequest + func (w *WriteHTTPRequest) SetBinaryWithBase64(enable bool) + func (w *WriteHTTPRequest) Write(ctx context.Context, out thrift.TProtocol, msg interface{}, requestBase *Base) error + type WriteJSON struct + func NewWriteJSON(svc *descriptor.ServiceDescriptor, method string, isClient bool) (*WriteJSON, error) + func (m *WriteJSON) SetBase64Binary(enable bool) + func (m *WriteJSON) Write(ctx context.Context, out thrift.TProtocol, msg interface{}, requestBase *Base) error + type WriteStruct struct + func NewWriteStruct(svc *descriptor.ServiceDescriptor, method string, isClient bool) (*WriteStruct, error) + func (m *WriteStruct) Write(ctx context.Context, out thrift.TProtocol, msg interface{}, requestBase *Base) error
Go to main page