thrift

package

Go to main page

Versions in this module

v0

v0.4.6

Nov 15, 2024

Changes in this version

type FunctionDescriptor

+ func (f FunctionDescriptor) IsWithoutWrapping() bool

v0.4.5

Nov 14, 2024

v0.4.4

Oct 25, 2024

v0.4.3

Oct 15, 2024

v0.4.2

Sep 24, 2024

v0.4.1

Sep 20, 2024

v0.4.0

Aug 26, 2024

Changes in this version

+ const FilenameAnnotationKey

type Options

+ PutThriftFilenameToAnnotation bool

v0.3.0

Jul 31, 2024

Changes in this version

type BinaryProtocol — js/wasm

+ func (p *BinaryProtocol) SkipNative(fieldType Type, maxDepth int) (err error)

v0.2.9

Jun 17, 2024

v0.2.8

Jun 12, 2024

v0.2.7

Jun 6, 2024

v0.2.6

May 24, 2024

Changes in this version

type BinaryEncoding

+ func (b BinaryEncoding) EncodeEmpty(typ, et, kt Type, buf []byte) ([]byte, error)

v0.2.5

May 8, 2024

v0.2.4

Apr 29, 2024

Changes in this version

+ const NameSpaceAnnotationKey

type BinaryProtocol

+ func (p *BinaryProtocol) ReadAny(typ Type, strAsBinary bool, byteAsInt8 bool) (interface{}, error)

+ func (p *BinaryProtocol) WriteAny(val interface{}, sliceAsSet bool) (Type, error)

type Options

+ PutNameSpaceToAnnotation bool

type Type

+ func GoType2ThriftType(val interface{}) (Type, error)

v0.2.3

Apr 19, 2024

v0.2.2

Apr 19, 2024

v0.2.2-dep3

Apr 18, 2024

v0.2.2-dep2

Apr 18, 2024

v0.2.2-dep

Apr 18, 2024

v0.2.1

Apr 14, 2024

v0.2.0

Jan 7, 2024

v0.2.0-rc

Dec 12, 2023

v0.1.7-rc

Dec 12, 2023

v0.1.6

Nov 21, 2023

v0.1.5

Nov 16, 2023

v0.1.4

Oct 26, 2023

v0.1.3

Aug 28, 2023

Changes in this version

type FieldDescriptor

+ func (f FieldDescriptor) Annotations() []parser.Annotation

type StructDescriptor

+ func (s StructDescriptor) Annotations() []parser.Annotation

v0.1.2

Jul 10, 2023

v0.1.1

Jun 28, 2023

v0.1.0

May 8, 2023

Changes in this version

+ const AnnoKeyDynamicGoApiNone

+ const AnnoKeyDynamicGoDeprecated

+ const MaxSkipDepth

+ const VERSION_1

+ const VERSION_MASK

+ var CtxKeyIsBodyRoot = &ctxIsBodyRoot

+ func FreeBinaryProtocolBuffer(bp *BinaryProtocol)

+ func FreeRequiresBitmap(b *RequiresBitmap)

+ func GetBinaryMessageHeaderAndFooter(methodName string, msgTyp TMessageType, structID FieldID, seqID int32) (header []byte, footer []byte, err error)

+ func RegisterAnnotation(an Annotation, keys ...string)

+ func RegisterAnnotationMapper(scope AnnoScope, mapper AnnotationMapper, keys ...string)

+ func RemoveAnnotationMapper(scope AnnoScope, keys ...string)

+ func TypeSize(t Type) int

+ func UnwrapBinaryMessage(buf []byte) (name string, callType TMessageType, seqID int32, structID FieldID, body []byte, ...)

+ func WrapBinaryBody(body []byte, methodName string, msgTyp TMessageType, structID FieldID, ...) ([]byte, error)

+ type AnnoID uint32

+ func MakeAnnoID(kind AnnoKind, scope AnnoScope, typ AnnoType) AnnoID

+ func (t AnnoID) Kind() AnnoKind

+ func (t AnnoID) Scope() AnnoScope

+ func (t AnnoID) Type() AnnoType

+ type AnnoKind uint8

+ const AnnoKindHttpMappping

+ const AnnoKindKeyMapping

+ const AnnoKindOptionMapping

+ const AnnoKindValueMapping

+ type AnnoScope uint8

+ const AnnoScopeField

+ const AnnoScopeFunction

+ const AnnoScopeService

+ const AnnoScopeStruct

+ type AnnoType uint16

+ type Annotation interface

+ ID func() AnnoID

+ Make func(ctx context.Context, values []parser.Annotation, desc interface{}) (handler interface{}, err error)

+ func FindAnnotation(key string, scope AnnoScope) Annotation

+ type AnnotationMapper interface

+ Map func(ctx context.Context, ann []parser.Annotation, desc interface{}, opt Options) (cur []parser.Annotation, next []parser.Annotation, err error)

+ func FindAnnotationMapper(key string, scope AnnoScope) AnnotationMapper

+ type BinaryEncoding struct

+ func (BinaryEncoding) DecodeBool(b []byte) bool

+ func (BinaryEncoding) DecodeByte(b []byte) byte

+ func (BinaryEncoding) DecodeDouble(b []byte) float64

+ func (BinaryEncoding) DecodeInt16(b []byte) int16

+ func (BinaryEncoding) DecodeInt32(b []byte) int32

+ func (BinaryEncoding) DecodeInt64(b []byte) int64

+ func (BinaryEncoding) EncodeBinary(b []byte, v []byte)

+ func (BinaryEncoding) EncodeBool(b []byte, v bool)

+ func (BinaryEncoding) EncodeByte(b []byte, v byte)

+ func (BinaryEncoding) EncodeDouble(b []byte, v float64)

+ func (BinaryEncoding) EncodeFieldBegin(b []byte, t Type, id FieldID)

+ func (BinaryEncoding) EncodeInt16(b []byte, v int16)

+ func (BinaryEncoding) EncodeInt32(b []byte, v int32)

+ func (BinaryEncoding) EncodeInt64(b []byte, v int64)

+ func (BinaryEncoding) EncodeString(b []byte, v string)

+ func (d BinaryEncoding) DecodeBytes(b []byte) (value []byte)

+ func (d BinaryEncoding) DecodeString(b []byte) (value string)

+ type BinaryProtocol struct

+ Buf []byte

+ Read int

+ func NewBinaryProtocol(buf []byte) *BinaryProtocol

+ func NewBinaryProtocolBuffer() *BinaryProtocol

+ func (p *BinaryProtocol) DecodeText(val string, desc *TypeDescriptor, disallowUnknown bool, base64Binary bool, ...) error

+ func (p *BinaryProtocol) EncodeText(desc *TypeDescriptor, buf *[]byte, byteAsUint8 bool, disallowUnknown bool, ...) error

+ func (p *BinaryProtocol) ModifyI32(pos int, value int32) error

+ func (p *BinaryProtocol) ReadAnyWithDesc(desc *TypeDescriptor, copyString bool, disallowUnknonw bool, useFieldName bool) (interface{}, error)

+ func (p *BinaryProtocol) ReadBinary(copyBytes bool) (value []byte, err error)

+ func (p *BinaryProtocol) ReadBool() (bool, error)

+ func (p *BinaryProtocol) ReadByte() (value byte, err error)

+ func (p *BinaryProtocol) ReadDouble() (value float64, err error)

+ func (p *BinaryProtocol) ReadFieldBegin() (name string, typeID Type, id FieldID, err error)

+ func (p *BinaryProtocol) ReadFieldEnd() error

+ func (p *BinaryProtocol) ReadI16() (value int16, err error)

+ func (p *BinaryProtocol) ReadI32() (value int32, err error)

+ func (p *BinaryProtocol) ReadI64() (value int64, err error)

+ func (p *BinaryProtocol) ReadInt(t Type) (value int, err error)

+ func (p *BinaryProtocol) ReadListBegin() (elemType Type, size int, err error)

+ func (p *BinaryProtocol) ReadListEnd() error

+ func (p *BinaryProtocol) ReadMapBegin() (kType, vType Type, size int, err error)

+ func (p *BinaryProtocol) ReadMapEnd() error

+ func (p *BinaryProtocol) ReadMessageBegin(copyString bool) (name string, typeID TMessageType, seqID int32, err error)

+ func (p *BinaryProtocol) ReadMessageEnd() error

+ func (p *BinaryProtocol) ReadSetBegin() (elemType Type, size int, err error)

+ func (p *BinaryProtocol) ReadSetEnd() error

+ func (p *BinaryProtocol) ReadString(copy bool) (value string, err error)

+ func (p *BinaryProtocol) ReadStringWithDesc(desc *TypeDescriptor, buf *[]byte, byteAsUint8 bool, disallowUnknown bool, ...) error

+ func (p *BinaryProtocol) ReadStructBegin() (name string, err error)

+ func (p *BinaryProtocol) ReadStructEnd() error

+ func (p *BinaryProtocol) Recycle()

+ func (p *BinaryProtocol) Reset()

+ func (p *BinaryProtocol) Skip(fieldType Type, useNative bool) (err error)

+ func (p *BinaryProtocol) SkipGo(fieldType Type, maxDepth int) (err error)

+ func (p *BinaryProtocol) SkipNative(fieldType Type, maxDepth int) (err error)

+ func (p *BinaryProtocol) WriteAnyWithDesc(desc *TypeDescriptor, val interface{}, cast bool, disallowUnknown bool, ...) error

+ func (p *BinaryProtocol) WriteBinary(value []byte) error

+ func (p *BinaryProtocol) WriteBool(value bool) error

+ func (p *BinaryProtocol) WriteByte(value byte) error

+ func (p *BinaryProtocol) WriteDefaultOrEmpty(field *FieldDescriptor) error

+ func (p *BinaryProtocol) WriteDouble(value float64) error

+ func (p *BinaryProtocol) WriteEmpty(desc *TypeDescriptor) error

+ func (p *BinaryProtocol) WriteFieldBegin(name string, typeID Type, id FieldID) error

+ func (p *BinaryProtocol) WriteFieldEnd() error

+ func (p *BinaryProtocol) WriteFieldStop() error

+ func (p *BinaryProtocol) WriteI16(value int16) error

+ func (p *BinaryProtocol) WriteI32(value int32) error

+ func (p *BinaryProtocol) WriteI64(value int64) error

+ func (p *BinaryProtocol) WriteInt(t Type, value int) error

+ func (p *BinaryProtocol) WriteListBegin(elemType Type, size int) error

+ func (p *BinaryProtocol) WriteListBeginWithSizePos(elemType Type, size int) (int, error)

+ func (p *BinaryProtocol) WriteListEnd() error

+ func (p *BinaryProtocol) WriteMapBegin(keyType, valueType Type, size int) error

+ func (p *BinaryProtocol) WriteMapBeginWithSizePos(keyType, valueType Type, size int) (int, error)

+ func (p *BinaryProtocol) WriteMapEnd() error

+ func (p *BinaryProtocol) WriteMessageBegin(name string, typeID TMessageType, seqID int32) error

+ func (p *BinaryProtocol) WriteMessageEnd() error

+ func (p *BinaryProtocol) WriteSetBegin(elemType Type, size int) error

+ func (p *BinaryProtocol) WriteSetEnd() error

+ func (p *BinaryProtocol) WriteString(value string) error

+ func (p *BinaryProtocol) WriteStringWithDesc(val string, desc *TypeDescriptor, disallowUnknown bool, base64Binary bool) error

+ func (p *BinaryProtocol) WriteStructBegin(name string) error

+ func (p *BinaryProtocol) WriteStructEnd() error

+ func (p BinaryProtocol) Left() int

+ func (p BinaryProtocol) RawBuf() []byte

+ func (p BinaryProtocol) UnwrapBody() (string, TMessageType, int32, FieldID, []byte, error)

+ type DefaultValue struct

+ func (d DefaultValue) GoValue() interface{}

+ func (d DefaultValue) JSONValue() string

+ func (d DefaultValue) ThriftBinary() string

+ type FieldDescriptor struct

+ func (f FieldDescriptor) Alias() string

+ func (f FieldDescriptor) DefaultValue() *DefaultValue

+ func (f FieldDescriptor) HTTPMappings() []HttpMapping

+ func (f FieldDescriptor) ID() FieldID

+ func (f FieldDescriptor) IsRequestBase() bool

+ func (f FieldDescriptor) IsResponseBase() bool

+ func (f FieldDescriptor) Name() string

+ func (f FieldDescriptor) Required() Requireness

+ func (f FieldDescriptor) Type() *TypeDescriptor

+ func (f FieldDescriptor) ValueMapping() ValueMapping

+ func (f FieldDescriptor) ValueMappingType() AnnoType

+ type FieldID uint16

+ type FieldIDMap struct

+ func (fd *FieldIDMap) Set(id FieldID, f *FieldDescriptor)

+ func (fd FieldIDMap) All() (ret []*FieldDescriptor)

+ func (fd FieldIDMap) Get(id FieldID) *FieldDescriptor

+ func (fd FieldIDMap) Size() int

+ type FieldNameMap struct

+ func (ft *FieldNameMap) Build()

+ func (ft *FieldNameMap) Set(key string, field *FieldDescriptor) (exist bool)

+ func (ft FieldNameMap) All() []*FieldDescriptor

+ func (ft FieldNameMap) Get(k string) *FieldDescriptor

+ func (ft FieldNameMap) Size() int

+ type FunctionDescriptor struct

+ func GetFnDescFromFile(filePath, fnName string, opts Options) *FunctionDescriptor

+ func (f FunctionDescriptor) Annotations() map[string][]string

+ func (f FunctionDescriptor) Endpoints() []http.Endpoint

+ func (f FunctionDescriptor) HasRequestBase() bool

+ func (f FunctionDescriptor) Name() string

+ func (f FunctionDescriptor) Oneway() bool

+ func (f FunctionDescriptor) Request() *TypeDescriptor

+ func (f FunctionDescriptor) Response() *TypeDescriptor

+ type HttpMapping interface

+ Encoding func() meta.Encoding

+ Request func(ctx context.Context, req http.RequestGetter, field *FieldDescriptor) (string, error)

+ Response func(ctx context.Context, resp http.ResponseSetter, field *FieldDescriptor, ...) error

+ type KeyMapping interface

+ Map func(ctx context.Context, key string) string

+ type OptionMapping interface

+ Map func(ctx context.Context, opts Options) Options

+ type Options struct

+ EnableThriftBase bool

+ MapFieldWay meta.MapFieldWay

+ ParseEnumAsInt64 bool

+ ParseFieldRandomRate float64

+ ParseFunctionMode meta.ParseFunctionMode

+ ParseServiceMode meta.ParseServiceMode

+ SetOptionalBitmap bool

+ UseDefaultValue bool

+ func NewDefaultOptions() Options

+ func (opts Options) NewDescriptorFromContentWithMethod(ctx context.Context, path, content string, includes map[string]string, ...) (*ServiceDescriptor, error)

+ func (opts Options) NewDescriptorFromPathWithMethod(ctx context.Context, path string, includeDirs []string, methods ...string) (*ServiceDescriptor, error)

+ func (opts Options) NewDescritorFromContent(ctx context.Context, path, content string, includes map[string]string, ...) (*ServiceDescriptor, error)

+ func (opts Options) NewDescritorFromPath(ctx context.Context, path string, includeDirs ...string) (*ServiceDescriptor, error)

+ type ParseTarget uint8

+ const Exception

+ const Request

+ const Response

+ type Requireness uint8

+ const DefaultRequireness

+ const OptionalRequireness

+ const RequiredRequireness

+ type RequiresBitmap []uint64

+ func NewRequiresBitmap() *RequiresBitmap

+ func (b *RequiresBitmap) Set(id FieldID, val Requireness)

+ func (b RequiresBitmap) CheckRequires(desc *StructDescriptor, writeDefault bool, ...) error

+ func (b RequiresBitmap) CopyTo(to *RequiresBitmap)

+ func (b RequiresBitmap) HandleRequires(desc *StructDescriptor, writeRquired bool, writeDefault bool, ...) error

+ func (b RequiresBitmap) IsSet(id FieldID) bool

+ type ServiceDescriptor struct

+ func NewDescritorFromContent(ctx context.Context, path, content string, includes map[string]string, ...) (*ServiceDescriptor, error)

+ func NewDescritorFromPath(ctx context.Context, path string, includeDirs ...string) (*ServiceDescriptor, error)

+ func (s *ServiceDescriptor) LookupFunctionByMethod(method string) (*FunctionDescriptor, error)

+ func (s ServiceDescriptor) Annotations() map[string][]string

+ func (s ServiceDescriptor) Functions() map[string]*FunctionDescriptor

+ func (s ServiceDescriptor) Name() string

+ type StructDescriptor struct

+ func (s StructDescriptor) FieldById(id FieldID) *FieldDescriptor

+ func (s StructDescriptor) FieldByKey(k string) (field *FieldDescriptor)

+ func (s StructDescriptor) Fields() []*FieldDescriptor

+ func (s StructDescriptor) GetRequestBase() *FieldDescriptor

+ func (s StructDescriptor) GetResponseBase() *FieldDescriptor

+ func (s StructDescriptor) HttpMappingFields() []*FieldDescriptor

+ func (s StructDescriptor) Len() int

+ func (s StructDescriptor) Name() string

+ func (s StructDescriptor) Requires() RequiresBitmap

+ type TMessageType int32

+ const CALL

+ const EXCEPTION

+ const INVALID_TMESSAGE_TYPE

+ const ONEWAY

+ const REPLY

+ type Type byte

+ const BOOL

+ const BYTE

+ const DOUBLE

+ const ERROR

+ const I08

+ const I16

+ const I32

+ const I64

+ const LIST

+ const MAP

+ const SET

+ const STOP

+ const STRING

+ const STRUCT

+ const UTF16

+ const UTF8

+ const VOID

+ func FromThriftTType(t thrift.TType) Type

+ func (p Type) IsComplex() bool

+ func (p Type) IsInt() bool

+ func (p Type) String() string

+ func (p Type) ToThriftTType() thrift.TType

+ func (p Type) Valid() bool

+ type TypeDescriptor struct

+ func FnRequest(fn *FunctionDescriptor) *TypeDescriptor

+ func FnResponse(fn *FunctionDescriptor) *TypeDescriptor

+ func FnWholeResponse(fn *FunctionDescriptor) *TypeDescriptor

+ func (d TypeDescriptor) Elem() *TypeDescriptor

+ func (d TypeDescriptor) IsBinary() bool

+ func (d TypeDescriptor) Key() *TypeDescriptor

+ func (d TypeDescriptor) Name() string

+ func (d TypeDescriptor) Struct() *StructDescriptor

+ func (d TypeDescriptor) Type() Type

+ type ValueMapping interface

+ Read func(ctx context.Context, p *BinaryProtocol, field *FieldDescriptor, out *[]byte) error

+ Write func(ctx context.Context, p *BinaryProtocol, field *FieldDescriptor, in []byte) error

v0.1.0-rc

May 8, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL