Documentation ¶
Index ¶
- Constants
- func Marshal(obj interface{}) ([]byte, error)
- func RegisterStruct(newFunc interface{}, data []byte)
- func Skip(ctx context.Context, iprot Protocol, typeID TTypeID, maxDepth int) (err error)
- func Unmarshal(data []byte, obj interface{}) error
- type BinaryProtocol
- func (p *BinaryProtocol) Flush(ctx context.Context) (err error)
- func (p *BinaryProtocol) ReadBinary(ctx context.Context) ([]byte, error)
- func (p *BinaryProtocol) ReadBool(ctx context.Context) (bool, error)
- func (p *BinaryProtocol) ReadByte(ctx context.Context) (int8, error)
- func (p *BinaryProtocol) ReadDouble(ctx context.Context) (value float64, err error)
- func (p *BinaryProtocol) ReadFieldBegin(ctx context.Context) (name string, typeID TTypeID, id int16, err error)
- func (p *BinaryProtocol) ReadFieldEnd(ctx context.Context) error
- func (p *BinaryProtocol) ReadI16(ctx context.Context) (value int16, err error)
- func (p *BinaryProtocol) ReadI32(ctx context.Context) (value int32, err error)
- func (p *BinaryProtocol) ReadI64(ctx context.Context) (value int64, err error)
- func (p *BinaryProtocol) ReadListBegin(ctx context.Context) (elemType TTypeID, size int, err error)
- func (p *BinaryProtocol) ReadListEnd(ctx context.Context) error
- func (p *BinaryProtocol) ReadMapBegin(ctx context.Context) (keyType, valueType TTypeID, size int, err error)
- func (p *BinaryProtocol) ReadMapEnd(ctx context.Context) error
- func (p *BinaryProtocol) ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error)
- func (p *BinaryProtocol) ReadMessageEnd(ctx context.Context) error
- func (p *BinaryProtocol) ReadSetBegin(ctx context.Context) (elemType TTypeID, size int, err error)
- func (p *BinaryProtocol) ReadSetEnd(ctx context.Context) error
- func (p *BinaryProtocol) ReadString(ctx context.Context) (string, error)
- func (p *BinaryProtocol) ReadStructBegin(ctx context.Context) (name string, err error)
- func (p *BinaryProtocol) ReadStructEnd(ctx context.Context) error
- func (p *BinaryProtocol) Skip(ctx context.Context, fieldType TTypeID) (err error)
- func (p *BinaryProtocol) WithStrictRead() *BinaryProtocol
- func (p *BinaryProtocol) WithStrictWrite() *BinaryProtocol
- func (p *BinaryProtocol) WriteBinary(ctx context.Context, value []byte) (err error)
- func (p *BinaryProtocol) WriteBool(ctx context.Context, value bool) error
- func (p *BinaryProtocol) WriteByte(ctx context.Context, value int8) error
- func (p *BinaryProtocol) WriteDouble(ctx context.Context, value float64) error
- func (p *BinaryProtocol) WriteFieldBegin(ctx context.Context, name string, typeID TTypeID, id int16) (err error)
- func (p *BinaryProtocol) WriteFieldEnd(ctx context.Context) error
- func (p *BinaryProtocol) WriteFieldStop(ctx context.Context) error
- func (p *BinaryProtocol) WriteI16(ctx context.Context, value int16) error
- func (p *BinaryProtocol) WriteI32(ctx context.Context, value int32) error
- func (p *BinaryProtocol) WriteI64(ctx context.Context, value int64) error
- func (p *BinaryProtocol) WriteListBegin(ctx context.Context, elemType TTypeID, size int) (err error)
- func (p *BinaryProtocol) WriteListEnd(ctx context.Context) error
- func (p *BinaryProtocol) WriteMapBegin(ctx context.Context, keyType, valueType TTypeID, size int) (err error)
- func (p *BinaryProtocol) WriteMapEnd(ctx context.Context) error
- func (p *BinaryProtocol) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) (err error)
- func (p *BinaryProtocol) WriteMessageEnd(ctx context.Context) error
- func (p *BinaryProtocol) WriteSetBegin(ctx context.Context, elemType TTypeID, size int) (err error)
- func (p *BinaryProtocol) WriteSetEnd(ctx context.Context) error
- func (p *BinaryProtocol) WriteString(ctx context.Context, value string) (err error)
- func (p *BinaryProtocol) WriteStructBegin(ctx context.Context, name string) error
- func (p *BinaryProtocol) WriteStructEnd(ctx context.Context) error
- type DebugProtocol
- func (p *DebugProtocol) Flush(ctx context.Context) (err error)
- func (p *DebugProtocol) ReadBinary(ctx context.Context) (value []byte, err error)
- func (p *DebugProtocol) ReadBool(ctx context.Context) (value bool, err error)
- func (p *DebugProtocol) ReadByte(ctx context.Context) (value int8, err error)
- func (p *DebugProtocol) ReadDouble(ctx context.Context) (value float64, err error)
- func (p *DebugProtocol) ReadFieldBegin(ctx context.Context) (name string, typeID TTypeID, id int16, err error)
- func (p *DebugProtocol) ReadFieldEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) ReadI16(ctx context.Context) (value int16, err error)
- func (p *DebugProtocol) ReadI32(ctx context.Context) (value int32, err error)
- func (p *DebugProtocol) ReadI64(ctx context.Context) (value int64, err error)
- func (p *DebugProtocol) ReadListBegin(ctx context.Context) (elemType TTypeID, size int, err error)
- func (p *DebugProtocol) ReadListEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) ReadMapBegin(ctx context.Context) (keyType, valueType TTypeID, size int, err error)
- func (p *DebugProtocol) ReadMapEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error)
- func (p *DebugProtocol) ReadMessageEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) ReadSetBegin(ctx context.Context) (elemType TTypeID, size int, err error)
- func (p *DebugProtocol) ReadSetEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) ReadString(ctx context.Context) (value string, err error)
- func (p *DebugProtocol) ReadStructBegin(ctx context.Context) (name string, err error)
- func (p *DebugProtocol) ReadStructEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) Skip(ctx context.Context, fieldType TTypeID) (err error)
- func (p *DebugProtocol) WithLogFunc(f func(format string, a ...interface{})) *DebugProtocol
- func (p *DebugProtocol) WriteBinary(ctx context.Context, value []byte) (err error)
- func (p *DebugProtocol) WriteBool(ctx context.Context, value bool) (err error)
- func (p *DebugProtocol) WriteByte(ctx context.Context, value int8) (err error)
- func (p *DebugProtocol) WriteDouble(ctx context.Context, value float64) (err error)
- func (p *DebugProtocol) WriteFieldBegin(ctx context.Context, name string, typeID TTypeID, id int16) (err error)
- func (p *DebugProtocol) WriteFieldEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) WriteFieldStop(ctx context.Context) (err error)
- func (p *DebugProtocol) WriteI16(ctx context.Context, value int16) (err error)
- func (p *DebugProtocol) WriteI32(ctx context.Context, value int32) (err error)
- func (p *DebugProtocol) WriteI64(ctx context.Context, value int64) (err error)
- func (p *DebugProtocol) WriteListBegin(ctx context.Context, elemType TTypeID, size int) (err error)
- func (p *DebugProtocol) WriteListEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) WriteMapBegin(ctx context.Context, keyType, valueType TTypeID, size int) (err error)
- func (p *DebugProtocol) WriteMapEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) (err error)
- func (p *DebugProtocol) WriteMessageEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) WriteSetBegin(ctx context.Context, elemType TTypeID, size int) (err error)
- func (p *DebugProtocol) WriteSetEnd(ctx context.Context) (err error)
- func (p *DebugProtocol) WriteString(ctx context.Context, value string) (err error)
- func (p *DebugProtocol) WriteStructBegin(ctx context.Context, name string) (err error)
- func (p *DebugProtocol) WriteStructEnd(ctx context.Context) (err error)
- type FieldMeta
- type MemoryTransport
- type Protocol
- type RichTransport
- type Struct
- type StructMeta
- type TMessageType
- type TRequiredness
- type TTypeID
- type Transport
- type TypeMeta
Constants ¶
const ( VersionMask = 0xffff0000 Version1 = 0x80010000 DefaultMaxDepth = 64 )
Protcol magic numbers.
Variables ¶
This section is empty.
Functions ¶
func RegisterStruct ¶
func RegisterStruct(newFunc interface{}, data []byte)
RegisterStruct associates a constructor of a thrift struct type with some meta data to describes its meta data.
Types ¶
type BinaryProtocol ¶
type BinaryProtocol struct {
// contains filtered or unexported fields
}
BinaryProtocol implements the binary protocol of thrift.
func NewBinaryProtocol ¶
func NewBinaryProtocol(t Transport) *BinaryProtocol
NewBinaryProtocol return a BinaryProtocol over the given transport.
func (*BinaryProtocol) Flush ¶
func (p *BinaryProtocol) Flush(ctx context.Context) (err error)
Flush .
func (*BinaryProtocol) ReadBinary ¶
func (p *BinaryProtocol) ReadBinary(ctx context.Context) ([]byte, error)
ReadBinary .
func (*BinaryProtocol) ReadBool ¶
func (p *BinaryProtocol) ReadBool(ctx context.Context) (bool, error)
ReadBool .
func (*BinaryProtocol) ReadByte ¶
func (p *BinaryProtocol) ReadByte(ctx context.Context) (int8, error)
ReadByte .
func (*BinaryProtocol) ReadDouble ¶
func (p *BinaryProtocol) ReadDouble(ctx context.Context) (value float64, err error)
ReadDouble .
func (*BinaryProtocol) ReadFieldBegin ¶
func (p *BinaryProtocol) ReadFieldBegin(ctx context.Context) (name string, typeID TTypeID, id int16, err error)
ReadFieldBegin .
func (*BinaryProtocol) ReadFieldEnd ¶
func (p *BinaryProtocol) ReadFieldEnd(ctx context.Context) error
ReadFieldEnd .
func (*BinaryProtocol) ReadI16 ¶
func (p *BinaryProtocol) ReadI16(ctx context.Context) (value int16, err error)
ReadI16 .
func (*BinaryProtocol) ReadI32 ¶
func (p *BinaryProtocol) ReadI32(ctx context.Context) (value int32, err error)
ReadI32 .
func (*BinaryProtocol) ReadI64 ¶
func (p *BinaryProtocol) ReadI64(ctx context.Context) (value int64, err error)
ReadI64 .
func (*BinaryProtocol) ReadListBegin ¶
ReadListBegin .
func (*BinaryProtocol) ReadListEnd ¶
func (p *BinaryProtocol) ReadListEnd(ctx context.Context) error
ReadListEnd .
func (*BinaryProtocol) ReadMapBegin ¶
func (p *BinaryProtocol) ReadMapBegin(ctx context.Context) (keyType, valueType TTypeID, size int, err error)
ReadMapBegin .
func (*BinaryProtocol) ReadMapEnd ¶
func (p *BinaryProtocol) ReadMapEnd(ctx context.Context) error
ReadMapEnd .
func (*BinaryProtocol) ReadMessageBegin ¶
func (p *BinaryProtocol) ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error)
ReadMessageBegin .
func (*BinaryProtocol) ReadMessageEnd ¶
func (p *BinaryProtocol) ReadMessageEnd(ctx context.Context) error
ReadMessageEnd .
func (*BinaryProtocol) ReadSetBegin ¶
ReadSetBegin .
func (*BinaryProtocol) ReadSetEnd ¶
func (p *BinaryProtocol) ReadSetEnd(ctx context.Context) error
ReadSetEnd .
func (*BinaryProtocol) ReadString ¶
func (p *BinaryProtocol) ReadString(ctx context.Context) (string, error)
ReadString .
func (*BinaryProtocol) ReadStructBegin ¶
func (p *BinaryProtocol) ReadStructBegin(ctx context.Context) (name string, err error)
ReadStructBegin .
func (*BinaryProtocol) ReadStructEnd ¶
func (p *BinaryProtocol) ReadStructEnd(ctx context.Context) error
ReadStructEnd .
func (*BinaryProtocol) Skip ¶
func (p *BinaryProtocol) Skip(ctx context.Context, fieldType TTypeID) (err error)
Skip .
func (*BinaryProtocol) WithStrictRead ¶
func (p *BinaryProtocol) WithStrictRead() *BinaryProtocol
WithStrictRead forces the BinaryProtocol to do strict read.
func (*BinaryProtocol) WithStrictWrite ¶
func (p *BinaryProtocol) WithStrictWrite() *BinaryProtocol
WithStrictWrite forces the BinaryProtocol to do strict write.
func (*BinaryProtocol) WriteBinary ¶
func (p *BinaryProtocol) WriteBinary(ctx context.Context, value []byte) (err error)
WriteBinary .
func (*BinaryProtocol) WriteBool ¶
func (p *BinaryProtocol) WriteBool(ctx context.Context, value bool) error
WriteBool .
func (*BinaryProtocol) WriteByte ¶
func (p *BinaryProtocol) WriteByte(ctx context.Context, value int8) error
WriteByte .
func (*BinaryProtocol) WriteDouble ¶
func (p *BinaryProtocol) WriteDouble(ctx context.Context, value float64) error
WriteDouble .
func (*BinaryProtocol) WriteFieldBegin ¶
func (p *BinaryProtocol) WriteFieldBegin(ctx context.Context, name string, typeID TTypeID, id int16) (err error)
WriteFieldBegin .
func (*BinaryProtocol) WriteFieldEnd ¶
func (p *BinaryProtocol) WriteFieldEnd(ctx context.Context) error
WriteFieldEnd .
func (*BinaryProtocol) WriteFieldStop ¶
func (p *BinaryProtocol) WriteFieldStop(ctx context.Context) error
WriteFieldStop .
func (*BinaryProtocol) WriteI16 ¶
func (p *BinaryProtocol) WriteI16(ctx context.Context, value int16) error
WriteI16 .
func (*BinaryProtocol) WriteI32 ¶
func (p *BinaryProtocol) WriteI32(ctx context.Context, value int32) error
WriteI32 .
func (*BinaryProtocol) WriteI64 ¶
func (p *BinaryProtocol) WriteI64(ctx context.Context, value int64) error
WriteI64 .
func (*BinaryProtocol) WriteListBegin ¶
func (p *BinaryProtocol) WriteListBegin(ctx context.Context, elemType TTypeID, size int) (err error)
WriteListBegin .
func (*BinaryProtocol) WriteListEnd ¶
func (p *BinaryProtocol) WriteListEnd(ctx context.Context) error
WriteListEnd .
func (*BinaryProtocol) WriteMapBegin ¶
func (p *BinaryProtocol) WriteMapBegin(ctx context.Context, keyType, valueType TTypeID, size int) (err error)
WriteMapBegin .
func (*BinaryProtocol) WriteMapEnd ¶
func (p *BinaryProtocol) WriteMapEnd(ctx context.Context) error
WriteMapEnd .
func (*BinaryProtocol) WriteMessageBegin ¶
func (p *BinaryProtocol) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) (err error)
WriteMessageBegin .
func (*BinaryProtocol) WriteMessageEnd ¶
func (p *BinaryProtocol) WriteMessageEnd(ctx context.Context) error
WriteMessageEnd .
func (*BinaryProtocol) WriteSetBegin ¶
WriteSetBegin .
func (*BinaryProtocol) WriteSetEnd ¶
func (p *BinaryProtocol) WriteSetEnd(ctx context.Context) error
WriteSetEnd .
func (*BinaryProtocol) WriteString ¶
func (p *BinaryProtocol) WriteString(ctx context.Context, value string) (err error)
WriteString .
func (*BinaryProtocol) WriteStructBegin ¶
func (p *BinaryProtocol) WriteStructBegin(ctx context.Context, name string) error
WriteStructBegin .
func (*BinaryProtocol) WriteStructEnd ¶
func (p *BinaryProtocol) WriteStructEnd(ctx context.Context) error
WriteStructEnd .
type DebugProtocol ¶
type DebugProtocol struct {
// contains filtered or unexported fields
}
DebugProtocol wraps another Protocol and writes a log every time every time its method is being invoked. The default logging function writes to the standard output.
func NewDebugProtocol ¶
func NewDebugProtocol(impl Protocol) *DebugProtocol
NewDebugProtocol creates a DebugProtocol wrapping the given Protocol.
func (*DebugProtocol) Flush ¶
func (p *DebugProtocol) Flush(ctx context.Context) (err error)
Flush .
func (*DebugProtocol) ReadBinary ¶
func (p *DebugProtocol) ReadBinary(ctx context.Context) (value []byte, err error)
ReadBinary .
func (*DebugProtocol) ReadBool ¶
func (p *DebugProtocol) ReadBool(ctx context.Context) (value bool, err error)
ReadBool .
func (*DebugProtocol) ReadByte ¶
func (p *DebugProtocol) ReadByte(ctx context.Context) (value int8, err error)
ReadByte .
func (*DebugProtocol) ReadDouble ¶
func (p *DebugProtocol) ReadDouble(ctx context.Context) (value float64, err error)
ReadDouble .
func (*DebugProtocol) ReadFieldBegin ¶
func (p *DebugProtocol) ReadFieldBegin(ctx context.Context) (name string, typeID TTypeID, id int16, err error)
ReadFieldBegin .
func (*DebugProtocol) ReadFieldEnd ¶
func (p *DebugProtocol) ReadFieldEnd(ctx context.Context) (err error)
ReadFieldEnd .
func (*DebugProtocol) ReadI16 ¶
func (p *DebugProtocol) ReadI16(ctx context.Context) (value int16, err error)
ReadI16 .
func (*DebugProtocol) ReadI32 ¶
func (p *DebugProtocol) ReadI32(ctx context.Context) (value int32, err error)
ReadI32 .
func (*DebugProtocol) ReadI64 ¶
func (p *DebugProtocol) ReadI64(ctx context.Context) (value int64, err error)
ReadI64 .
func (*DebugProtocol) ReadListBegin ¶
ReadListBegin .
func (*DebugProtocol) ReadListEnd ¶
func (p *DebugProtocol) ReadListEnd(ctx context.Context) (err error)
ReadListEnd .
func (*DebugProtocol) ReadMapBegin ¶
func (p *DebugProtocol) ReadMapBegin(ctx context.Context) (keyType, valueType TTypeID, size int, err error)
ReadMapBegin .
func (*DebugProtocol) ReadMapEnd ¶
func (p *DebugProtocol) ReadMapEnd(ctx context.Context) (err error)
ReadMapEnd .
func (*DebugProtocol) ReadMessageBegin ¶
func (p *DebugProtocol) ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error)
ReadMessageBegin .
func (*DebugProtocol) ReadMessageEnd ¶
func (p *DebugProtocol) ReadMessageEnd(ctx context.Context) (err error)
ReadMessageEnd .
func (*DebugProtocol) ReadSetBegin ¶
ReadSetBegin .
func (*DebugProtocol) ReadSetEnd ¶
func (p *DebugProtocol) ReadSetEnd(ctx context.Context) (err error)
ReadSetEnd .
func (*DebugProtocol) ReadString ¶
func (p *DebugProtocol) ReadString(ctx context.Context) (value string, err error)
ReadString .
func (*DebugProtocol) ReadStructBegin ¶
func (p *DebugProtocol) ReadStructBegin(ctx context.Context) (name string, err error)
ReadStructBegin .
func (*DebugProtocol) ReadStructEnd ¶
func (p *DebugProtocol) ReadStructEnd(ctx context.Context) (err error)
ReadStructEnd .
func (*DebugProtocol) Skip ¶
func (p *DebugProtocol) Skip(ctx context.Context, fieldType TTypeID) (err error)
Skip .
func (*DebugProtocol) WithLogFunc ¶
func (p *DebugProtocol) WithLogFunc(f func(format string, a ...interface{})) *DebugProtocol
WithLogFunc sets the logging function of the DebugProtocol.
func (*DebugProtocol) WriteBinary ¶
func (p *DebugProtocol) WriteBinary(ctx context.Context, value []byte) (err error)
WriteBinary .
func (*DebugProtocol) WriteBool ¶
func (p *DebugProtocol) WriteBool(ctx context.Context, value bool) (err error)
WriteBool .
func (*DebugProtocol) WriteByte ¶
func (p *DebugProtocol) WriteByte(ctx context.Context, value int8) (err error)
WriteByte .
func (*DebugProtocol) WriteDouble ¶
func (p *DebugProtocol) WriteDouble(ctx context.Context, value float64) (err error)
WriteDouble .
func (*DebugProtocol) WriteFieldBegin ¶
func (p *DebugProtocol) WriteFieldBegin(ctx context.Context, name string, typeID TTypeID, id int16) (err error)
WriteFieldBegin .
func (*DebugProtocol) WriteFieldEnd ¶
func (p *DebugProtocol) WriteFieldEnd(ctx context.Context) (err error)
WriteFieldEnd .
func (*DebugProtocol) WriteFieldStop ¶
func (p *DebugProtocol) WriteFieldStop(ctx context.Context) (err error)
WriteFieldStop .
func (*DebugProtocol) WriteI16 ¶
func (p *DebugProtocol) WriteI16(ctx context.Context, value int16) (err error)
WriteI16 .
func (*DebugProtocol) WriteI32 ¶
func (p *DebugProtocol) WriteI32(ctx context.Context, value int32) (err error)
WriteI32 .
func (*DebugProtocol) WriteI64 ¶
func (p *DebugProtocol) WriteI64(ctx context.Context, value int64) (err error)
WriteI64 .
func (*DebugProtocol) WriteListBegin ¶
WriteListBegin .
func (*DebugProtocol) WriteListEnd ¶
func (p *DebugProtocol) WriteListEnd(ctx context.Context) (err error)
WriteListEnd .
func (*DebugProtocol) WriteMapBegin ¶
func (p *DebugProtocol) WriteMapBegin(ctx context.Context, keyType, valueType TTypeID, size int) (err error)
WriteMapBegin .
func (*DebugProtocol) WriteMapEnd ¶
func (p *DebugProtocol) WriteMapEnd(ctx context.Context) (err error)
WriteMapEnd .
func (*DebugProtocol) WriteMessageBegin ¶
func (p *DebugProtocol) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) (err error)
WriteMessageBegin .
func (*DebugProtocol) WriteMessageEnd ¶
func (p *DebugProtocol) WriteMessageEnd(ctx context.Context) (err error)
WriteMessageEnd .
func (*DebugProtocol) WriteSetBegin ¶
WriteSetBegin .
func (*DebugProtocol) WriteSetEnd ¶
func (p *DebugProtocol) WriteSetEnd(ctx context.Context) (err error)
WriteSetEnd .
func (*DebugProtocol) WriteString ¶
func (p *DebugProtocol) WriteString(ctx context.Context, value string) (err error)
WriteString .
func (*DebugProtocol) WriteStructBegin ¶
func (p *DebugProtocol) WriteStructBegin(ctx context.Context, name string) (err error)
WriteStructBegin .
func (*DebugProtocol) WriteStructEnd ¶
func (p *DebugProtocol) WriteStructEnd(ctx context.Context) (err error)
WriteStructEnd .
type FieldMeta ¶
type FieldMeta struct { FieldID int16 `thrift:"field_id,1,required" json:"field_id"` Name string `thrift:"name,2,required" json:"name"` Requiredness TRequiredness `thrift:"requiredness,3,required" json:"requiredness"` FieldType *TypeMeta `thrift:"field_type,4,required" json:"field_type"` }
func NewFieldMeta ¶
func NewFieldMeta() *FieldMeta
func (*FieldMeta) GetFieldID ¶
func (*FieldMeta) GetFieldType ¶
func (*FieldMeta) GetRequiredness ¶
func (p *FieldMeta) GetRequiredness() (v TRequiredness)
func (*FieldMeta) IsSetFieldType ¶
type MemoryTransport ¶
MemoryTransport is a transport that manages data in memory. The zero value for MemoryTransport is ready to use.
type Protocol ¶
type Protocol interface { ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error) ReadMessageEnd(ctx context.Context) error ReadBool(ctx context.Context) (value bool, err error) ReadByte(ctx context.Context) (value int8, err error) ReadI16(ctx context.Context) (value int16, err error) ReadI32(ctx context.Context) (value int32, err error) ReadI64(ctx context.Context) (value int64, err error) ReadDouble(ctx context.Context) (value float64, err error) ReadString(ctx context.Context) (value string, err error) ReadBinary(ctx context.Context) (value []byte, err error) ReadMapBegin(ctx context.Context) (keyType, valueType TTypeID, size int, err error) ReadMapEnd(ctx context.Context) error ReadListBegin(ctx context.Context) (elemType TTypeID, size int, err error) ReadListEnd(ctx context.Context) error ReadSetBegin(ctx context.Context) (elemType TTypeID, size int, err error) ReadSetEnd(ctx context.Context) error ReadStructBegin(ctx context.Context) (name string, err error) ReadStructEnd(ctx context.Context) error ReadFieldBegin(ctx context.Context) (name string, typeID TTypeID, id int16, err error) ReadFieldEnd(ctx context.Context) error Skip(ctx context.Context, fieldType TTypeID) (err error) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) error WriteMessageEnd(ctx context.Context) error WriteBool(ctx context.Context, value bool) error WriteByte(ctx context.Context, value int8) error WriteI16(ctx context.Context, value int16) error WriteI32(ctx context.Context, value int32) error WriteI64(ctx context.Context, value int64) error WriteDouble(ctx context.Context, value float64) error WriteString(ctx context.Context, value string) error WriteBinary(ctx context.Context, value []byte) error WriteMapBegin(ctx context.Context, keyType, valueType TTypeID, size int) error WriteMapEnd(ctx context.Context) error WriteListBegin(ctx context.Context, elemType TTypeID, size int) error WriteListEnd(ctx context.Context) error WriteSetBegin(ctx context.Context, elemType TTypeID, size int) error WriteSetEnd(ctx context.Context) error WriteStructBegin(ctx context.Context, name string) error WriteStructEnd(ctx context.Context) error WriteFieldBegin(ctx context.Context, name string, typeID TTypeID, id int16) error WriteFieldEnd(ctx context.Context) error WriteFieldStop(ctx context.Context) error Flush(ctx context.Context) (err error) }
Protocol is an abstraction for input and output protocols in thrift.
type RichTransport ¶
type RichTransport = interface { Transport io.ByteReader io.ByteWriter io.StringWriter }
RichTransport is a super set of Transport.
func MakeRichTransport ¶
func MakeRichTransport(t Transport) RichTransport
MakeRichTransport wraps a Transport into a RichTransport.
type Struct ¶
type Struct interface { Read(ctx context.Context, iprot Protocol) (err error) Write(ctx context.Context, oprot Protocol) (err error) }
Struct .
type StructMeta ¶
type StructMeta struct { Name string `thrift:"name,1,required" json:"name"` Category string `thrift:"category,2,required" json:"category"` Fields []*FieldMeta `thrift:"fields,3,required" json:"fields"` }
func NewStructMeta ¶
func NewStructMeta() *StructMeta
func (*StructMeta) GetCategory ¶
func (p *StructMeta) GetCategory() (v string)
func (*StructMeta) GetFields ¶
func (p *StructMeta) GetFields() (v []*FieldMeta)
func (*StructMeta) GetName ¶
func (p *StructMeta) GetName() (v string)
func (*StructMeta) String ¶
func (p *StructMeta) String() string
type TMessageType ¶
type TMessageType int64
const ( TMessageType_INVALID_MESSAGE_TYPE TMessageType = 0 TMessageType_CALL TMessageType = 1 TMessageType_REPLY TMessageType = 2 TMessageType_EXCEPTION TMessageType = 3 TMessageType_ONEWAY TMessageType = 4 )
func TMessageTypeFromString ¶
func TMessageTypeFromString(s string) (TMessageType, error)
func TMessageTypePtr ¶
func TMessageTypePtr(v TMessageType) *TMessageType
func (*TMessageType) Scan ¶
func (p *TMessageType) Scan(value interface{}) (err error)
func (TMessageType) String ¶
func (p TMessageType) String() string
type TRequiredness ¶
type TRequiredness int64
const ( TRequiredness_DEFAULT TRequiredness = 0 TRequiredness_REQUIRED TRequiredness = 1 TRequiredness_OPTIONAL TRequiredness = 2 )
func TRequirednessFromString ¶
func TRequirednessFromString(s string) (TRequiredness, error)
func TRequirednessPtr ¶
func TRequirednessPtr(v TRequiredness) *TRequiredness
func (*TRequiredness) Scan ¶
func (p *TRequiredness) Scan(value interface{}) (err error)
func (TRequiredness) String ¶
func (p TRequiredness) String() string
type TTypeID ¶
type TTypeID int64
const ( TTypeID_STOP TTypeID = 0 TTypeID_VOID TTypeID = 1 TTypeID_BOOL TTypeID = 2 TTypeID_BYTE TTypeID = 3 TTypeID_DOUBLE TTypeID = 4 TTypeID_I16 TTypeID = 6 TTypeID_I32 TTypeID = 8 TTypeID_I64 TTypeID = 10 TTypeID_STRING TTypeID = 11 TTypeID_STRUCT TTypeID = 12 TTypeID_MAP TTypeID = 13 TTypeID_SET TTypeID = 14 TTypeID_LIST TTypeID = 15 TTypeID_UTF8 TTypeID = 16 TTypeID_UTF16 TTypeID = 17 )
func TTypeIDFromString ¶
func TTypeIDPtr ¶
type Transport ¶
type Transport = interface { io.ReadWriteCloser Flush(ctx context.Context) (err error) Open() error IsOpen() bool }
Transport is an abstraction layer for the data transfer in thrift.
type TypeMeta ¶
type TypeMeta struct { TypeID TTypeID `thrift:"type_id,1,required" json:"type_id"` KeyType *TypeMeta `thrift:"key_type,2,optional" json:"key_type,omitempty"` ValueType *TypeMeta `thrift:"value_type,3,optional" json:"value_type,omitempty"` }
var FieldMeta_FieldType_DEFAULT *TypeMeta
var TypeMeta_KeyType_DEFAULT *TypeMeta
var TypeMeta_ValueType_DEFAULT *TypeMeta
func NewTypeMeta ¶
func NewTypeMeta() *TypeMeta