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

v1

v1.34.3

Apr 24, 2024

v1.34.2

Feb 16, 2024

v1.34.1

Dec 11, 2023

v1.34.0

Oct 13, 2023

v1.33.0

Mar 20, 2023

v1.32.1

Aug 23, 2022

v1.32.0

Jul 12, 2022

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_MAX_LENGTH

+ 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 MULTIPLEXED_SEPARATOR

+ const NEGATIVE_SIZE

+ const NOT_IMPLEMENTED

+ const NOT_OPEN

+ const PROTOCOL_ERROR

+ const SET

+ const SIZE_LIMIT

+ const STOP

+ const STRING

+ const STRUCT

+ const THRIFT_JSON_PROTOCOL_VERSION

+ 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 ANONYMOUS_FIELD *field

+ var DefaultHttpClient *http.Client = http.DefaultClient

+ 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 BoolPtr(v bool) *bool

+ func ByteSlicePtr(v []byte) *[]byte

+ func Float32Ptr(v float32) *float32

+ func Float64Ptr(v float64) *float64

+ func Int32Ptr(v int32) *int32

+ func Int64Ptr(v int64) *int64

+ func IntPtr(v int) *int

+ func NewStoredMessageProtocol(protocol TProtocol, name string, typeId TMessageType, seqid int32) *storedMessageProtocol

+ func NewThriftHandlerFunc(processor TProcessor, inPfactory, outPfactory TProtocolFactory) func(w http.ResponseWriter, r *http.Request)

+ 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)

+ func StringPtr(v string) *string

+ func Uint32Ptr(v uint32) *uint32

+ func Uint64Ptr(v uint64) *uint64

+ 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 StreamTransport struct

+ func NewStreamTransport(r io.Reader, w io.Writer) *StreamTransport

+ func NewStreamTransportR(r io.Reader) *StreamTransport

+ func NewStreamTransportRW(rw io.ReadWriter) *StreamTransport

+ func NewStreamTransportW(w io.Writer) *StreamTransport

+ func (p *StreamTransport) Close() error

+ func (p *StreamTransport) Flush() error

+ func (p *StreamTransport) IsOpen() bool

+ func (p *StreamTransport) Open() error

+ func (p *StreamTransport) Read(c []byte) (n int, err error)

+ func (p *StreamTransport) ReadByte() (c byte, err error)

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

+ func (p *StreamTransport) Write(c []byte) (n int, err error)

+ func (p *StreamTransport) WriteByte(c byte) (err error)

+ func (p *StreamTransport) WriteString(s string) (n int, err error)

+ type StreamTransportFactory struct

+ Reader io.Reader

+ Writer io.Writer

+ func NewStreamTransportFactory(reader io.Reader, writer io.Writer, isReadWriter bool) *StreamTransportFactory

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

+ 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 TBufferedTransport struct

+ func NewTBufferedTransport(trans TTransport, bufferSize int) *TBufferedTransport

+ func (p *TBufferedTransport) Close() (err error)

+ func (p *TBufferedTransport) Flush() error

+ func (p *TBufferedTransport) IsOpen() bool

+ func (p *TBufferedTransport) Open() (err error)

+ func (p *TBufferedTransport) Read(b []byte) (int, error)

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

+ func (p *TBufferedTransport) Write(b []byte) (int, error)

+ type TBufferedTransportFactory struct

+ func NewTBufferedTransportFactory(bufferSize int) *TBufferedTransportFactory

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

+ 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 TDebugProtocol struct

+ Delegate TProtocol

+ LogPrefix string

+ func (tdp *TDebugProtocol) Flush() (err error)

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

+ func (tdp *TDebugProtocol) ReadBool() (value bool, err error)

+ func (tdp *TDebugProtocol) ReadByte() (value int8, err error)

+ func (tdp *TDebugProtocol) ReadDouble() (value float64, err error)

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

+ func (tdp *TDebugProtocol) ReadFieldEnd() (err error)

+ func (tdp *TDebugProtocol) ReadI16() (value int16, err error)

+ func (tdp *TDebugProtocol) ReadI32() (value int32, err error)

+ func (tdp *TDebugProtocol) ReadI64() (value int64, err error)

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

+ func (tdp *TDebugProtocol) ReadListEnd() (err error)

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

+ func (tdp *TDebugProtocol) ReadMapEnd() (err error)

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

+ func (tdp *TDebugProtocol) ReadMessageEnd() (err error)

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

+ func (tdp *TDebugProtocol) ReadSetEnd() (err error)

+ func (tdp *TDebugProtocol) ReadString() (value string, err error)

+ func (tdp *TDebugProtocol) ReadStructBegin() (name string, err error)

+ func (tdp *TDebugProtocol) ReadStructEnd() (err error)

+ func (tdp *TDebugProtocol) Skip(fieldType TType) (err error)

+ func (tdp *TDebugProtocol) Transport() TTransport

+ func (tdp *TDebugProtocol) WriteBinary(value []byte) error

+ func (tdp *TDebugProtocol) WriteBool(value bool) error

+ func (tdp *TDebugProtocol) WriteByte(value int8) error

+ func (tdp *TDebugProtocol) WriteDouble(value float64) error

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

+ func (tdp *TDebugProtocol) WriteFieldEnd() error

+ func (tdp *TDebugProtocol) WriteFieldStop() error

+ func (tdp *TDebugProtocol) WriteI16(value int16) error

+ func (tdp *TDebugProtocol) WriteI32(value int32) error

+ func (tdp *TDebugProtocol) WriteI64(value int64) error

+ func (tdp *TDebugProtocol) WriteListBegin(elemType TType, size int) error

+ func (tdp *TDebugProtocol) WriteListEnd() error

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

+ func (tdp *TDebugProtocol) WriteMapEnd() error

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

+ func (tdp *TDebugProtocol) WriteMessageEnd() error

+ func (tdp *TDebugProtocol) WriteSetBegin(elemType TType, size int) error

+ func (tdp *TDebugProtocol) WriteSetEnd() error

+ func (tdp *TDebugProtocol) WriteString(value string) error

+ func (tdp *TDebugProtocol) WriteStructBegin(name string) error

+ func (tdp *TDebugProtocol) WriteStructEnd() error

+ type TDebugProtocolFactory struct

+ LogPrefix string

+ Underlying TProtocolFactory

+ func NewTDebugProtocolFactory(underlying TProtocolFactory, logPrefix string) *TDebugProtocolFactory

+ func (t *TDebugProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TDeserializer struct

+ Protocol TProtocol

+ Transport TTransport

+ func NewTDeserializer() *TDeserializer

+ func (t *TDeserializer) Read(msg TStruct, b []byte) (err error)

+ func (t *TDeserializer) ReadString(msg TStruct, s string) (err error)

+ type TException interface

+ type TFramedTransport struct

+ func NewTFramedTransport(transport TTransport) *TFramedTransport

+ func NewTFramedTransportMaxLength(transport TTransport, maxLength uint32) *TFramedTransport

+ func (p *TFramedTransport) Close() error

+ func (p *TFramedTransport) Flush() error

+ func (p *TFramedTransport) IsOpen() bool

+ func (p *TFramedTransport) Open() error

+ func (p *TFramedTransport) Read(buf []byte) (l int, err error)

+ func (p *TFramedTransport) ReadByte() (c byte, err error)

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

+ func (p *TFramedTransport) Write(buf []byte) (int, error)

+ func (p *TFramedTransport) WriteByte(c byte) error

+ func (p *TFramedTransport) WriteString(s string) (n int, err error)

+ type THttpClient struct

+ func (p *THttpClient) Close() error

+ func (p *THttpClient) DelHeader(key string)

+ func (p *THttpClient) Flush() error

+ func (p *THttpClient) GetHeader(key string) string

+ func (p *THttpClient) IsOpen() bool

+ func (p *THttpClient) Open() error

+ func (p *THttpClient) Read(buf []byte) (int, error)

+ func (p *THttpClient) ReadByte() (c byte, err error)

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

+ func (p *THttpClient) SetHeader(key string, value string)

+ func (p *THttpClient) Write(buf []byte) (int, error)

+ func (p *THttpClient) WriteByte(c byte) error

+ func (p *THttpClient) WriteString(s string) (n int, err error)

+ type THttpClientOptions struct

+ Client *http.Client

+ type THttpClientTransportFactory struct

+ func NewTHttpClientTransportFactory(url string) *THttpClientTransportFactory

+ func NewTHttpClientTransportFactoryWithOptions(url string, options THttpClientOptions) *THttpClientTransportFactory

+ func NewTHttpPostClientTransportFactory(url string) *THttpClientTransportFactory

+ func NewTHttpPostClientTransportFactoryWithOptions(url string, options THttpClientOptions) *THttpClientTransportFactory

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

+ type TJSONProtocol struct

+ func NewTJSONProtocol(t TTransport) *TJSONProtocol

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

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

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

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

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

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

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

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

+ func (p *TJSONProtocol) ReadFieldEnd() error

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

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

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

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

+ func (p *TJSONProtocol) ReadListEnd() error

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

+ func (p *TJSONProtocol) ReadMapEnd() error

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

+ func (p *TJSONProtocol) ReadMessageEnd() error

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

+ func (p *TJSONProtocol) ReadSetEnd() error

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

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

+ func (p *TJSONProtocol) ReadStructEnd() error

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

+ func (p *TJSONProtocol) StringToTypeId(fieldType string) (TType, error)

+ func (p *TJSONProtocol) Transport() TTransport

+ func (p *TJSONProtocol) TypeIdToString(fieldType TType) (string, error)

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

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

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

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

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

+ func (p *TJSONProtocol) WriteFieldEnd() error

+ func (p *TJSONProtocol) WriteFieldStop() error

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

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

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

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

+ func (p *TJSONProtocol) WriteListEnd() error

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

+ func (p *TJSONProtocol) WriteMapEnd() error

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

+ func (p *TJSONProtocol) WriteMessageEnd() error

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

+ func (p *TJSONProtocol) WriteSetEnd() error

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

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

+ func (p *TJSONProtocol) WriteStructEnd() error

+ type TJSONProtocolFactory struct

+ func NewTJSONProtocolFactory() *TJSONProtocolFactory

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

+ 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 TMultiplexedProcessor struct

+ DefaultProcessor TProcessor

+ func NewTMultiplexedProcessor() *TMultiplexedProcessor

+ func (t *TMultiplexedProcessor) Process(in, out TProtocol) (bool, TException)

+ func (t *TMultiplexedProcessor) RegisterDefault(processor TProcessor)

+ func (t *TMultiplexedProcessor) RegisterProcessor(name string, processor TProcessor)

+ type TMultiplexedProtocol struct

+ func NewTMultiplexedProtocol(protocol TProtocol, serviceName string) *TMultiplexedProtocol

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

+ type TProcessor interface

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

+ type TProcessorFactory interface

+ GetProcessor func(trans TTransport) TProcessor

+ func NewTProcessorFactory(p TProcessor) TProcessorFactory

+ type TProcessorFunction interface

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

+ type TProcessorFunctionFactory interface

+ GetProcessorFunction func(trans TTransport) TProcessorFunction

+ func NewTProcessorFunctionFactory(p TProcessorFunction) TProcessorFunctionFactory

+ 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 TSSLServerSocket struct

+ func NewTSSLServerSocket(listenAddr string, cfg *tls.Config) (*TSSLServerSocket, error)

+ func NewTSSLServerSocketTimeout(listenAddr string, cfg *tls.Config, clientTimeout time.Duration) (*TSSLServerSocket, error)

+ func (p *TSSLServerSocket) Accept() (TTransport, error)

+ func (p *TSSLServerSocket) Addr() net.Addr

+ func (p *TSSLServerSocket) Close() error

+ func (p *TSSLServerSocket) Interrupt() error

+ func (p *TSSLServerSocket) IsListening() bool

+ func (p *TSSLServerSocket) Listen() error

+ func (p *TSSLServerSocket) Open() error

+ type TSSLSocket struct

+ func NewTSSLSocket(hostPort string, cfg *tls.Config) (*TSSLSocket, error)

+ func NewTSSLSocketFromAddrTimeout(addr net.Addr, cfg *tls.Config, timeout time.Duration) *TSSLSocket

+ func NewTSSLSocketFromConnTimeout(conn net.Conn, cfg *tls.Config, timeout time.Duration) *TSSLSocket

+ func NewTSSLSocketTimeout(hostPort string, cfg *tls.Config, timeout time.Duration) (*TSSLSocket, error)

+ func (p *TSSLSocket) Close() error

+ func (p *TSSLSocket) Conn() net.Conn

+ func (p *TSSLSocket) Flush() error

+ func (p *TSSLSocket) Interrupt() error

+ func (p *TSSLSocket) IsOpen() bool

+ func (p *TSSLSocket) Open() error

+ func (p *TSSLSocket) Read(buf []byte) (int, error)

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

+ func (p *TSSLSocket) SetTimeout(timeout time.Duration) error

+ func (p *TSSLSocket) Write(buf []byte) (int, error)

+ 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 TServer interface

+ InputProtocolFactory func() TProtocolFactory

+ InputTransportFactory func() TTransportFactory

+ OutputProtocolFactory func() TProtocolFactory

+ OutputTransportFactory func() TTransportFactory

+ ProcessorFactory func() TProcessorFactory

+ Serve func() error

+ ServerTransport func() TServerTransport

+ Stop func() error

+ type TServerSocket struct

+ func NewTServerSocket(listenAddr string) (*TServerSocket, error)

+ func NewTServerSocketTimeout(listenAddr string, clientTimeout time.Duration) (*TServerSocket, error)

+ func (p *TServerSocket) Accept() (TTransport, error)

+ func (p *TServerSocket) Addr() net.Addr

+ func (p *TServerSocket) Close() error

+ func (p *TServerSocket) Interrupt() error

+ func (p *TServerSocket) IsListening() bool

+ func (p *TServerSocket) Listen() error

+ func (p *TServerSocket) Open() error

+ type TServerTransport interface

+ Accept func() (TTransport, error)

+ Close func() error

+ Interrupt func() error

+ Listen func() 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 TSimpleServer struct

+ func NewTSimpleServer2(processor TProcessor, serverTransport TServerTransport) *TSimpleServer

+ func NewTSimpleServer4(processor TProcessor, serverTransport TServerTransport, ...) *TSimpleServer

+ func NewTSimpleServer6(processor TProcessor, serverTransport TServerTransport, ...) *TSimpleServer

+ func NewTSimpleServerFactory2(processorFactory TProcessorFactory, serverTransport TServerTransport) *TSimpleServer

+ func NewTSimpleServerFactory4(processorFactory TProcessorFactory, serverTransport TServerTransport, ...) *TSimpleServer

+ func NewTSimpleServerFactory6(processorFactory TProcessorFactory, serverTransport TServerTransport, ...) *TSimpleServer

+ func (p *TSimpleServer) AcceptLoop() error

+ func (p *TSimpleServer) InputProtocolFactory() TProtocolFactory

+ func (p *TSimpleServer) InputTransportFactory() TTransportFactory

+ func (p *TSimpleServer) Listen() error

+ func (p *TSimpleServer) OutputProtocolFactory() TProtocolFactory

+ func (p *TSimpleServer) OutputTransportFactory() TTransportFactory

+ func (p *TSimpleServer) ProcessorFactory() TProcessorFactory

+ func (p *TSimpleServer) Serve() error

+ func (p *TSimpleServer) ServerTransport() TServerTransport

+ func (p *TSimpleServer) Stop() error

+ type TSocket struct

+ func NewTSocket(hostPort string) (*TSocket, error)

+ func NewTSocketFromAddrTimeout(addr net.Addr, timeout time.Duration) *TSocket

+ func NewTSocketFromConnTimeout(conn net.Conn, timeout time.Duration) *TSocket

+ func NewTSocketTimeout(hostPort string, timeout time.Duration) (*TSocket, error)

+ func (p *TSocket) Addr() net.Addr

+ func (p *TSocket) Close() error

+ func (p *TSocket) Conn() net.Conn

+ func (p *TSocket) Flush() error

+ func (p *TSocket) Interrupt() error

+ func (p *TSocket) IsOpen() bool

+ func (p *TSocket) Open() error

+ func (p *TSocket) Read(buf []byte) (int, error)

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

+ func (p *TSocket) SetTimeout(timeout time.Duration) error

+ func (p *TSocket) Write(buf []byte) (int, error)

+ type TStruct interface

+ Read func(p TProtocol) error

+ Write func(p TProtocol) error

+ type TTransport interface

+ IsOpen func() bool

+ Open func() error

+ func NewTHttpClient(urlstr string) (TTransport, error)

+ func NewTHttpClientWithOptions(urlstr string, options THttpClientOptions) (TTransport, error)

+ func NewTHttpPostClient(urlstr string) (TTransport, error)

+ func NewTHttpPostClientWithOptions(urlstr string, options THttpClientOptions) (TTransport, 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 NewTFramedTransportFactory(factory TTransportFactory) TTransportFactory

+ func NewTFramedTransportFactoryMaxLength(factory TTransportFactory, maxLength uint32) TTransportFactory

+ func NewTTransportFactory() TTransportFactory

+ type TType byte

+ func (p TType) String() string

+ type TZlibTransport struct

+ func NewTZlibTransport(trans TTransport, level int) (*TZlibTransport, error)

+ func (z *TZlibTransport) Close() error

+ func (z *TZlibTransport) Flush() error

+ func (z *TZlibTransport) IsOpen() bool

+ func (z *TZlibTransport) Open() error

+ func (z *TZlibTransport) Read(p []byte) (int, error)

+ func (z *TZlibTransport) RemainingBytes() uint64

+ func (z *TZlibTransport) Write(p []byte) (int, error)

+ type TZlibTransportFactory struct

+ func NewTZlibTransportFactory(level int) *TZlibTransportFactory

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