Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

thrift

package

Go to main page

Versions in this module

v0

v0.1.5

Dec 4, 2019

v0.1.4

Dec 4, 2019

v0.1.3

Dec 4, 2019

v0.1.2

Dec 3, 2019

v0.1.1

Dec 3, 2019

Changes in this version

+ const ALREADY_OPEN

+ const BAD_SEQUENCE_ID

+ const BAD_VERSION

+ const BOOL

+ const BYTE

+ const COMPACT_BINARY

+ const COMPACT_BOOLEAN_FALSE

+ const COMPACT_BOOLEAN_TRUE

+ const COMPACT_BYTE

+ const COMPACT_DOUBLE

+ const COMPACT_I16

+ const COMPACT_I32

+ const COMPACT_I64

+ const COMPACT_LIST

+ const COMPACT_MAP

+ const COMPACT_PROTOCOL_ID

+ const COMPACT_SET

+ const COMPACT_STRUCT

+ const COMPACT_TYPE_BITS

+ const COMPACT_TYPE_MASK

+ const COMPACT_TYPE_SHIFT_AMOUNT

+ const COMPACT_VERSION

+ const COMPACT_VERSION_MASK

+ const DEFAULT_RECURSION_DEPTH

+ const DEPTH_LIMIT

+ const DOUBLE

+ const END_OF_FILE

+ const I08

+ const I16

+ const I32

+ const I64

+ const INTERNAL_ERROR

+ const INVALID_DATA

+ const INVALID_MESSAGE_TYPE_EXCEPTION

+ const LIST

+ const MAP

+ const MISSING_RESULT

+ const NEGATIVE_SIZE

+ const NOT_IMPLEMENTED

+ const NOT_OPEN

+ const PROTOCOL_ERROR

+ const SET

+ const SIZE_LIMIT

+ const STOP

+ const STRING

+ const STRUCT

+ const TIMED_OUT

+ const UNKNOWN_APPLICATION_EXCEPTION

+ const UNKNOWN_METHOD

+ const UNKNOWN_PROTOCOL_EXCEPTION

+ const UNKNOWN_TRANSPORT_EXCEPTION

+ const UTF16

+ const UTF7

+ const UTF8

+ const VERSION_1

+ const VERSION_MASK

+ const VOID

+ const WRONG_METHOD_NAME

+ var JSON_COLON []byte

+ var JSON_COMMA []byte

+ var JSON_FALSE []byte

+ var JSON_INFINITY string

+ var JSON_INFINITY_BYTES []byte

+ var JSON_LBRACE []byte

+ var JSON_LBRACKET []byte

+ var JSON_NAN string

+ var JSON_NAN_BYTES []byte

+ var JSON_NEGATIVE_INFINITY string

+ var JSON_NEGATIVE_INFINITY_BYTES []byte

+ var JSON_NULL []byte

+ var JSON_QUOTE byte

+ var JSON_QUOTE_BYTES []byte

+ var JSON_RBRACE []byte

+ var JSON_RBRACKET []byte

+ var JSON_TRUE []byte

+ func PrependError(prepend string, err error) error

+ func Skip(self TProtocol, fieldType TType, maxDepth int) (err error)

+ func SkipDefaultDepth(prot TProtocol, typeId TType) (err error)

+ type Flusher interface

+ Flush func() (err error)

+ type Numeric interface

+ Byte func() byte

+ Float32 func() float32

+ Float64 func() float64

+ Int func() int

+ Int16 func() int16

+ Int32 func() int32

+ Int64 func() int64

+ String func() string

+ var INFINITY Numeric

+ var NAN Numeric

+ var NEGATIVE_INFINITY Numeric

+ var NUMERIC_NULL Numeric

+ var ZERO Numeric

+ func NewNullNumeric() Numeric

+ func NewNumericFromDouble(dValue float64) Numeric

+ func NewNumericFromI32(iValue int32) Numeric

+ func NewNumericFromI64(iValue int64) Numeric

+ func NewNumericFromJSONString(sValue string, isNull bool) Numeric

+ func NewNumericFromString(sValue string) Numeric

+ type ReadSizeProvider interface

+ RemainingBytes func() (num_bytes uint64)

+ type RichTransport struct

+ func NewTRichTransport(trans TTransport) *RichTransport

+ func (r *RichTransport) ReadByte() (c byte, err error)

+ func (r *RichTransport) RemainingBytes() (num_bytes uint64)

+ func (r *RichTransport) WriteByte(c byte) error

+ func (r *RichTransport) WriteString(s string) (n int, err error)

+ type TApplicationException interface

+ Read func(iprot TProtocol) (TApplicationException, error)

+ TypeId func() int32

+ Write func(oprot TProtocol) error

+ func NewTApplicationException(type_ int32, message string) TApplicationException

+ type TBinaryProtocol struct

+ func NewTBinaryProtocol(t TTransport, strictRead, strictWrite bool) *TBinaryProtocol

+ func NewTBinaryProtocolTransport(t TTransport) *TBinaryProtocol

+ func (p *TBinaryProtocol) Flush() (err error)

+ func (p *TBinaryProtocol) ReadBinary() ([]byte, error)

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

+ func (p *TBinaryProtocol) ReadByte() (int8, error)

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

+ func (p *TBinaryProtocol) ReadFieldBegin() (name string, typeId TType, seqId int16, err error)

+ func (p *TBinaryProtocol) ReadFieldEnd() error

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

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

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

+ func (p *TBinaryProtocol) ReadListBegin() (elemType TType, size int, err error)

+ func (p *TBinaryProtocol) ReadListEnd() error

+ func (p *TBinaryProtocol) ReadMapBegin() (kType, vType TType, size int, err error)

+ func (p *TBinaryProtocol) ReadMapEnd() error

+ func (p *TBinaryProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)

+ func (p *TBinaryProtocol) ReadMessageEnd() error

+ func (p *TBinaryProtocol) ReadSetBegin() (elemType TType, size int, err error)

+ func (p *TBinaryProtocol) ReadSetEnd() error

+ func (p *TBinaryProtocol) ReadString() (value string, err error)

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

+ func (p *TBinaryProtocol) ReadStructEnd() error

+ func (p *TBinaryProtocol) Skip(fieldType TType) (err error)

+ func (p *TBinaryProtocol) Transport() TTransport

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

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

+ func (p *TBinaryProtocol) WriteByte(value int8) error

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

+ func (p *TBinaryProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TBinaryProtocol) WriteFieldEnd() error

+ func (p *TBinaryProtocol) WriteFieldStop() error

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

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

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

+ func (p *TBinaryProtocol) WriteListBegin(elemType TType, size int) error

+ func (p *TBinaryProtocol) WriteListEnd() error

+ func (p *TBinaryProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error

+ func (p *TBinaryProtocol) WriteMapEnd() error

+ func (p *TBinaryProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error

+ func (p *TBinaryProtocol) WriteMessageEnd() error

+ func (p *TBinaryProtocol) WriteSetBegin(elemType TType, size int) error

+ func (p *TBinaryProtocol) WriteSetEnd() error

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

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

+ func (p *TBinaryProtocol) WriteStructEnd() error

+ type TBinaryProtocolFactory struct

+ func NewTBinaryProtocolFactory(strictRead, strictWrite bool) *TBinaryProtocolFactory

+ func NewTBinaryProtocolFactoryDefault() *TBinaryProtocolFactory

+ func (p *TBinaryProtocolFactory) GetProtocol(t TTransport) TProtocol

+ type TCompactProtocol struct

+ func NewTCompactProtocol(trans TTransport) *TCompactProtocol

+ func (p *TCompactProtocol) Flush() (err error)

+ func (p *TCompactProtocol) ReadBinary() (value []byte, err error)

+ func (p *TCompactProtocol) ReadBool() (value bool, err error)

+ func (p *TCompactProtocol) ReadByte() (int8, error)

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

+ func (p *TCompactProtocol) ReadFieldBegin() (name string, typeId TType, id int16, err error)

+ func (p *TCompactProtocol) ReadFieldEnd() error

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

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

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

+ func (p *TCompactProtocol) ReadListBegin() (elemType TType, size int, err error)

+ func (p *TCompactProtocol) ReadListEnd() error

+ func (p *TCompactProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, err error)

+ func (p *TCompactProtocol) ReadMapEnd() error

+ func (p *TCompactProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)

+ func (p *TCompactProtocol) ReadMessageEnd() error

+ func (p *TCompactProtocol) ReadSetBegin() (elemType TType, size int, err error)

+ func (p *TCompactProtocol) ReadSetEnd() error

+ func (p *TCompactProtocol) ReadString() (value string, err error)

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

+ func (p *TCompactProtocol) ReadStructEnd() error

+ func (p *TCompactProtocol) Skip(fieldType TType) (err error)

+ func (p *TCompactProtocol) Transport() TTransport

+ func (p *TCompactProtocol) WriteBinary(bin []byte) error

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

+ func (p *TCompactProtocol) WriteByte(value int8) error

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

+ func (p *TCompactProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TCompactProtocol) WriteFieldEnd() error

+ func (p *TCompactProtocol) WriteFieldStop() error

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

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

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

+ func (p *TCompactProtocol) WriteListBegin(elemType TType, size int) error

+ func (p *TCompactProtocol) WriteListEnd() error

+ func (p *TCompactProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error

+ func (p *TCompactProtocol) WriteMapEnd() error

+ func (p *TCompactProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error

+ func (p *TCompactProtocol) WriteMessageEnd() error

+ func (p *TCompactProtocol) WriteSetBegin(elemType TType, size int) error

+ func (p *TCompactProtocol) WriteSetEnd() error

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

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

+ func (p *TCompactProtocol) WriteStructEnd() error

+ type TCompactProtocolFactory struct

+ func NewTCompactProtocolFactory() *TCompactProtocolFactory

+ func (p *TCompactProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TException interface

+ type TMemoryBuffer struct

+ func NewTMemoryBuffer() *TMemoryBuffer

+ func NewTMemoryBufferLen(size int) *TMemoryBuffer

+ func (p *TMemoryBuffer) Close() error

+ func (p *TMemoryBuffer) Flush() error

+ func (p *TMemoryBuffer) IsOpen() bool

+ func (p *TMemoryBuffer) Open() error

+ func (p *TMemoryBuffer) RemainingBytes() (num_bytes uint64)

+ type TMemoryBufferTransportFactory struct

+ func NewTMemoryBufferTransportFactory(size int) *TMemoryBufferTransportFactory

+ func (p *TMemoryBufferTransportFactory) GetTransport(trans TTransport) TTransport

+ type TMessageType int32

+ const CALL

+ const EXCEPTION

+ const INVALID_TMESSAGE_TYPE

+ const ONEWAY

+ const REPLY

+ type TProcessor interface

+ Process func(in, out TProtocol) (bool, TException)

+ type TProcessorFunction interface

+ Process func(seqId int32, in, out TProtocol) (bool, TException)

+ type TProtocol interface

+ Flush func() (err error)

+ ReadBinary func() (value []byte, err error)

+ ReadBool func() (value bool, err error)

+ ReadByte func() (value int8, err error)

+ ReadDouble func() (value float64, err error)

+ ReadFieldBegin func() (name string, typeId TType, id int16, err error)

+ ReadFieldEnd func() error

+ ReadI16 func() (value int16, err error)

+ ReadI32 func() (value int32, err error)

+ ReadI64 func() (value int64, err error)

+ ReadListBegin func() (elemType TType, size int, err error)

+ ReadListEnd func() error

+ ReadMapBegin func() (keyType TType, valueType TType, size int, err error)

+ ReadMapEnd func() error

+ ReadMessageBegin func() (name string, typeId TMessageType, seqid int32, err error)

+ ReadMessageEnd func() error

+ ReadSetBegin func() (elemType TType, size int, err error)

+ ReadSetEnd func() error

+ ReadString func() (value string, err error)

+ ReadStructBegin func() (name string, err error)

+ ReadStructEnd func() error

+ Skip func(fieldType TType) (err error)

+ Transport func() TTransport

+ WriteBinary func(value []byte) error

+ WriteBool func(value bool) error

+ WriteByte func(value int8) error

+ WriteDouble func(value float64) error

+ WriteFieldBegin func(name string, typeId TType, id int16) error

+ WriteFieldEnd func() error

+ WriteFieldStop func() error

+ WriteI16 func(value int16) error

+ WriteI32 func(value int32) error

+ WriteI64 func(value int64) error

+ WriteListBegin func(elemType TType, size int) error

+ WriteListEnd func() error

+ WriteMapBegin func(keyType TType, valueType TType, size int) error

+ WriteMapEnd func() error

+ WriteMessageBegin func(name string, typeId TMessageType, seqid int32) error

+ WriteMessageEnd func() error

+ WriteSetBegin func(elemType TType, size int) error

+ WriteSetEnd func() error

+ WriteString func(value string) error

+ WriteStructBegin func(name string) error

+ WriteStructEnd func() error

+ type TProtocolException interface

+ TypeId func() int

+ func NewTProtocolException(err error) TProtocolException

+ func NewTProtocolExceptionWithType(errType int, err error) TProtocolException

+ type TProtocolFactory interface

+ GetProtocol func(trans TTransport) TProtocol

+ type TRichTransport interface

+ type TSerializer struct

+ Protocol TProtocol

+ Transport *TMemoryBuffer

+ func NewTSerializer() *TSerializer

+ func (t *TSerializer) Write(msg TStruct) (b []byte, err error)

+ func (t *TSerializer) WriteString(msg TStruct) (s string, err error)

+ type TSimpleJSONProtocol struct

+ func NewTSimpleJSONProtocol(t TTransport) *TSimpleJSONProtocol

+ func (p *TSimpleJSONProtocol) Flush() (err error)

+ func (p *TSimpleJSONProtocol) OutputBool(value bool) error

+ func (p *TSimpleJSONProtocol) OutputElemListBegin(elemType TType, size int) error

+ func (p *TSimpleJSONProtocol) OutputF64(value float64) error

+ func (p *TSimpleJSONProtocol) OutputI64(value int64) error

+ func (p *TSimpleJSONProtocol) OutputListBegin() error

+ func (p *TSimpleJSONProtocol) OutputListEnd() error

+ func (p *TSimpleJSONProtocol) OutputNull() error

+ func (p *TSimpleJSONProtocol) OutputObjectBegin() error

+ func (p *TSimpleJSONProtocol) OutputObjectEnd() error

+ func (p *TSimpleJSONProtocol) OutputPostValue() error

+ func (p *TSimpleJSONProtocol) OutputPreValue() error

+ func (p *TSimpleJSONProtocol) OutputString(s string) error

+ func (p *TSimpleJSONProtocol) OutputStringData(s string) error

+ func (p *TSimpleJSONProtocol) ParseBase64EncodedBody() ([]byte, error)

+ func (p *TSimpleJSONProtocol) ParseElemListBegin() (elemType TType, size int, e error)

+ func (p *TSimpleJSONProtocol) ParseF64() (float64, bool, error)

+ func (p *TSimpleJSONProtocol) ParseI64() (int64, bool, error)

+ func (p *TSimpleJSONProtocol) ParseListBegin() (isNull bool, err error)

+ func (p *TSimpleJSONProtocol) ParseListEnd() error

+ func (p *TSimpleJSONProtocol) ParseObjectEnd() error

+ func (p *TSimpleJSONProtocol) ParseObjectStart() (bool, error)

+ func (p *TSimpleJSONProtocol) ParsePostValue() error

+ func (p *TSimpleJSONProtocol) ParsePreValue() error

+ func (p *TSimpleJSONProtocol) ParseQuotedStringBody() (string, error)

+ func (p *TSimpleJSONProtocol) ParseStringBody() (string, error)

+ func (p *TSimpleJSONProtocol) ReadBinary() ([]byte, error)

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

+ func (p *TSimpleJSONProtocol) ReadByte() (int8, error)

+ func (p *TSimpleJSONProtocol) ReadDouble() (float64, error)

+ func (p *TSimpleJSONProtocol) ReadFieldBegin() (string, TType, int16, error)

+ func (p *TSimpleJSONProtocol) ReadFieldEnd() error

+ func (p *TSimpleJSONProtocol) ReadI16() (int16, error)

+ func (p *TSimpleJSONProtocol) ReadI32() (int32, error)

+ func (p *TSimpleJSONProtocol) ReadI64() (int64, error)

+ func (p *TSimpleJSONProtocol) ReadListBegin() (elemType TType, size int, e error)

+ func (p *TSimpleJSONProtocol) ReadListEnd() error

+ func (p *TSimpleJSONProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, e error)

+ func (p *TSimpleJSONProtocol) ReadMapEnd() error

+ func (p *TSimpleJSONProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)

+ func (p *TSimpleJSONProtocol) ReadMessageEnd() error

+ func (p *TSimpleJSONProtocol) ReadSetBegin() (elemType TType, size int, e error)

+ func (p *TSimpleJSONProtocol) ReadSetEnd() error

+ func (p *TSimpleJSONProtocol) ReadString() (string, error)

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

+ func (p *TSimpleJSONProtocol) ReadStructEnd() error

+ func (p *TSimpleJSONProtocol) Skip(fieldType TType) (err error)

+ func (p *TSimpleJSONProtocol) Transport() TTransport

+ func (p *TSimpleJSONProtocol) WriteBinary(v []byte) error

+ func (p *TSimpleJSONProtocol) WriteBool(b bool) error

+ func (p *TSimpleJSONProtocol) WriteByte(b int8) error

+ func (p *TSimpleJSONProtocol) WriteDouble(v float64) error

+ func (p *TSimpleJSONProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TSimpleJSONProtocol) WriteFieldEnd() error

+ func (p *TSimpleJSONProtocol) WriteFieldStop() error

+ func (p *TSimpleJSONProtocol) WriteI16(v int16) error

+ func (p *TSimpleJSONProtocol) WriteI32(v int32) error

+ func (p *TSimpleJSONProtocol) WriteI64(v int64) error

+ func (p *TSimpleJSONProtocol) WriteListBegin(elemType TType, size int) error

+ func (p *TSimpleJSONProtocol) WriteListEnd() error

+ func (p *TSimpleJSONProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error

+ func (p *TSimpleJSONProtocol) WriteMapEnd() error

+ func (p *TSimpleJSONProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error

+ func (p *TSimpleJSONProtocol) WriteMessageEnd() error

+ func (p *TSimpleJSONProtocol) WriteSetBegin(elemType TType, size int) error

+ func (p *TSimpleJSONProtocol) WriteSetEnd() error

+ func (p *TSimpleJSONProtocol) WriteString(v string) error

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

+ func (p *TSimpleJSONProtocol) WriteStructEnd() error

+ type TSimpleJSONProtocolFactory struct

+ func NewTSimpleJSONProtocolFactory() *TSimpleJSONProtocolFactory

+ func (p *TSimpleJSONProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TStruct interface

+ Read func(p TProtocol) error

+ Write func(p TProtocol) error

+ type TTransport interface

+ IsOpen func() bool

+ Open func() error

+ type TTransportException interface

+ Err func() error

+ TypeId func() int

+ func NewTTransportException(t int, e string) TTransportException

+ func NewTTransportExceptionFromError(e error) TTransportException

+ type TTransportFactory interface

+ GetTransport func(trans TTransport) TTransport

+ func NewTTransportFactory() TTransportFactory

+ type TType byte

+ func (p TType) String() string