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 + func GetSeqID(transBuff []byte) (int32, error) + func ParseContent(path, content string, includes map[string]string, isAbsIncludePath bool) (*parser.Thrift, error) + func ServiceInfo(pcType serviceinfo.PayloadCodec) *serviceinfo.ServiceInfo + func SetBinaryWithBase64(g Generic, enable bool) error + func SetSeqID(seqID int32, transBuff []byte) error + type Args struct + Method string + Request interface{} + func (g *Args) GetFirstArgument() interface{} + func (g *Args) GetOrSetBase() interface{} + func (g *Args) Read(ctx context.Context, method string, in thrift.TProtocol) error + func (g *Args) SetCodec(inner interface{}) + func (g *Args) Write(ctx context.Context, out thrift.TProtocol) error + type Closer interface + Close func() error + type DescriptorProvider interface + Provide func() <-chan *descriptor.ServiceDescriptor + func NewThriftFileProvider(path string, includeDirs ...string) (DescriptorProvider, error) + type Generic interface + Framed func() bool + GetMethod func(req interface{}, method string) (*Method, error) + PayloadCodec func() remote.PayloadCodec + PayloadCodecType func() serviceinfo.PayloadCodec + func BinaryThriftGeneric() Generic + func HTTPPbThriftGeneric(p DescriptorProvider, pbp PbDescriptorProvider) (Generic, error) + func HTTPThriftGeneric(p DescriptorProvider) (Generic, error) + func JSONProtoGeneric(p PbDescriptorProvider) (Generic, error) + func JSONThriftGeneric(p DescriptorProvider) (Generic, error) + func MapThriftGeneric(p DescriptorProvider) (Generic, error) + func MapThriftGenericForJSON(p DescriptorProvider) (Generic, error) + type HTTPRequest = descriptor.HTTPRequest + func FromHTTPPbRequest(req *http.Request) (*HTTPRequest, error) + func FromHTTPRequest(req *http.Request) (*HTTPRequest, error) + type HTTPResponse = descriptor.HTTPResponse + type JSONRequest = string + type Method struct + Name string + Oneway bool + type PbContentProvider struct + func (p *PbContentProvider) Close() error + func (p *PbContentProvider) Provide() <-chan proto.ServiceDescriptor + func (p *PbContentProvider) UpdateIDL(main string, includes map[string]string) error + type PbDescriptorProvider interface + Provide func() <-chan proto.ServiceDescriptor + func NewPbContentProvider(main string, includes map[string]string) (PbDescriptorProvider, error) + type Result struct + Success interface{} + func (r *Result) GetResult() interface{} + func (r *Result) GetSuccess() interface{} + func (r *Result) IsSetSuccess() bool + func (r *Result) Read(ctx context.Context, method string, in thrift.TProtocol) error + func (r *Result) SetCodec(inner interface{}) + func (r *Result) SetSuccess(x interface{}) + func (r *Result) Write(ctx context.Context, out thrift.TProtocol) error + type Service interface + GenericCall func(ctx context.Context, method string, request interface{}) (response interface{}, err error) + type ThriftContentProvider struct + func NewThriftContentProvider(main string, includes map[string]string) (*ThriftContentProvider, error) + func (p *ThriftContentProvider) Close() error + func (p *ThriftContentProvider) Provide() <-chan *descriptor.ServiceDescriptor + func (p *ThriftContentProvider) UpdateIDL(main string, includes map[string]string) error + type ThriftContentWithAbsIncludePathProvider struct + func NewThriftContentWithAbsIncludePathProvider(mainIDLPath string, includes map[string]string) (*ThriftContentWithAbsIncludePathProvider, error) + func (p *ThriftContentWithAbsIncludePathProvider) Close() error + func (p *ThriftContentWithAbsIncludePathProvider) Provide() <-chan *descriptor.ServiceDescriptor + func (p *ThriftContentWithAbsIncludePathProvider) UpdateIDL(mainIDLPath string, includes map[string]string) error + type WithCodec interface + SetCodec func(codec interface{})
Go to main page