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

deprecated

v1.17.0

Aug 28, 2023

v1.16.0

May 22, 2023

v1.16.0-rc.1

May 4, 2023

v1.15.1

May 2, 2023

v1.15.0

Apr 28, 2023

v1.15.0-rc.2

Mar 23, 2023

v1.15.0-rc.1

Mar 2, 2023

v1.14.0

Feb 27, 2023

v1.13.0

Feb 7, 2023

v1.12.0

Jan 29, 2023

v1.11.2

Dec 5, 2022

v1.11.1

Oct 19, 2022

v1.11.0

Oct 12, 2022

v1.10.0

Sep 12, 2022

v1.9.0

Aug 2, 2022

v1.8.0

Jul 8, 2022

v1.7.0

Apr 28, 2022

v1.6.3

Apr 7, 2022

v1.6.2

Apr 6, 2022

v1.6.1

Mar 28, 2022

v1.6.0

Mar 23, 2022

v1.5.0

Mar 16, 2022

v1.4.1

Feb 16, 2022

v1.4.0

Feb 11, 2022

v1.3.0

Dec 10, 2021

v1.2.0

Nov 12, 2021

v1.1.0

Oct 27, 2021

v1.0.1

Oct 1, 2021

v1.0.0

Sep 20, 2021

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_CONNECT_TIMEOUT

+ const DEFAULT_MAX_FRAME_SIZE

+ const DEFAULT_MAX_LENGTH

+ const DEFAULT_MAX_MESSAGE_SIZE

+ const DEFAULT_RECURSION_DEPTH

+ const DEFAULT_SOCKET_TIMEOUT

+ const DEFAULT_TBINARY_STRICT_READ

+ const DEFAULT_TBINARY_STRICT_WRITE

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

+ const INVALID_TRANSFORM

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

+ const THeaderHeaderMagic

+ const THeaderHeaderMask

+ const THeaderMaxFrameSize

+ const TIMED_OUT

+ const UNKNOWN_APPLICATION_EXCEPTION

+ const UNKNOWN_METHOD

+ const UNKNOWN_PROTOCOL_EXCEPTION

+ const UNKNOWN_TRANSPORT_EXCEPTION

+ const UNSUPPORTED_CLIENT_TYPE

+ const UTF16

+ const UTF7

+ const UTF8

+ const VERSION_1

+ const VERSION_MASK

+ const VOID

+ const WRONG_METHOD_NAME

+ var DefaultHttpClient *http.Client = http.DefaultClient

+ var ErrAbandonRequest = errors.New("request abandoned")

+ 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

+ var ServerConnectivityCheckInterval = time.Millisecond * 5

+ func AddReadTHeaderToContext(ctx context.Context, headers THeaderMap) context.Context

+ func BoolPtr(v bool) *bool

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

+ func Float32Ptr(v float32) *float32

+ func Float64Ptr(v float64) *float64

+ func GetHeader(ctx context.Context, key string) (value string, ok bool)

+ func GetReadHeaderList(ctx context.Context) []string

+ func GetWriteHeaderList(ctx context.Context) []string

+ func Int16Ptr(v int16) *int16

+ func Int32Ptr(v int32) *int32

+ func Int64Ptr(v int64) *int64

+ func Int8Ptr(v int8) *int8

+ 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 NewTransformWriter(baseWriter io.Writer, transforms []THeaderTransformID) (io.WriteCloser, error)

+ func NopLogger(msg string)

+ func PrependError(prepend string, err error) error

+ func PropagateTConfiguration(impl interface{}, cfg *TConfiguration)

+ func SetHeader(ctx context.Context, key, value string) context.Context

+ func SetReadHeaderList(ctx context.Context, keys []string) context.Context

+ func SetResponseHelper(ctx context.Context, helper TResponseHelper) context.Context

+ func SetWriteHeaderList(ctx context.Context, keys []string) context.Context

+ func Skip(ctx context.Context, self TProtocol, fieldType TType, maxDepth int) (err error)

+ func SkipDefaultDepth(ctx context.Context, prot TProtocol, typeId TType) (err error)

+ func StringPtr(v string) *string

+ func Uint32Ptr(v uint32) *uint32

+ func Uint64Ptr(v uint64) *uint64

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

+ type ClientMiddleware func(TClient) TClient

+ type ContextFlusher interface

+ Flush func(ctx context.Context) (err error)

+ type Flusher interface

+ Flush func() (err error)

+ type Logger func(msg string)

+ func StdLogger(logger *log.Logger) Logger

+ func TestLogger(tb testing.TB) Logger

+ 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 ProcessorMiddleware func(name string, next TProcessorFunction) TProcessorFunction

+ type ReadSizeProvider interface

+ RemainingBytes func() (num_bytes uint64)

+ type ResponseMeta struct

+ Headers THeaderMap

+ 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(ctx context.Context) 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) SetTConfiguration(conf *TConfiguration)

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

+ type TApplicationException interface

+ Read func(ctx context.Context, iprot TProtocol) error

+ TypeId func() int32

+ Write func(ctx context.Context, oprot TProtocol) error

+ func NewTApplicationException(type_ int32, message string) TApplicationException

+ type TBinaryProtocol struct

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

+ func NewTBinaryProtocolConf(t TTransport, conf *TConfiguration) *TBinaryProtocol

+ func NewTBinaryProtocolTransport(t TTransport) *TBinaryProtocol

+ func (p *TBinaryProtocol) Flush(ctx context.Context) (err error)

+ func (p *TBinaryProtocol) ReadBinary(ctx context.Context) ([]byte, error)

+ func (p *TBinaryProtocol) ReadBool(ctx context.Context) (bool, error)

+ func (p *TBinaryProtocol) ReadByte(ctx context.Context) (int8, error)

+ func (p *TBinaryProtocol) ReadDouble(ctx context.Context) (value float64, err error)

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

+ func (p *TBinaryProtocol) ReadFieldEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) ReadI16(ctx context.Context) (value int16, err error)

+ func (p *TBinaryProtocol) ReadI32(ctx context.Context) (value int32, err error)

+ func (p *TBinaryProtocol) ReadI64(ctx context.Context) (value int64, err error)

+ func (p *TBinaryProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (p *TBinaryProtocol) ReadListEnd(ctx context.Context) error

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

+ func (p *TBinaryProtocol) ReadMapEnd(ctx context.Context) error

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

+ func (p *TBinaryProtocol) ReadMessageEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (p *TBinaryProtocol) ReadSetEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) ReadString(ctx context.Context) (value string, err error)

+ func (p *TBinaryProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

+ func (p *TBinaryProtocol) ReadStructEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) SetTConfiguration(conf *TConfiguration)

+ func (p *TBinaryProtocol) Skip(ctx context.Context, fieldType TType) (err error)

+ func (p *TBinaryProtocol) Transport() TTransport

+ func (p *TBinaryProtocol) WriteBinary(ctx context.Context, value []byte) error

+ func (p *TBinaryProtocol) WriteBool(ctx context.Context, value bool) error

+ func (p *TBinaryProtocol) WriteByte(ctx context.Context, value int8) error

+ func (p *TBinaryProtocol) WriteDouble(ctx context.Context, value float64) error

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

+ func (p *TBinaryProtocol) WriteFieldEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) WriteFieldStop(ctx context.Context) error

+ func (p *TBinaryProtocol) WriteI16(ctx context.Context, value int16) error

+ func (p *TBinaryProtocol) WriteI32(ctx context.Context, value int32) error

+ func (p *TBinaryProtocol) WriteI64(ctx context.Context, value int64) error

+ func (p *TBinaryProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TBinaryProtocol) WriteListEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

+ func (p *TBinaryProtocol) WriteMapEnd(ctx context.Context) error

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

+ func (p *TBinaryProtocol) WriteMessageEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TBinaryProtocol) WriteSetEnd(ctx context.Context) error

+ func (p *TBinaryProtocol) WriteString(ctx context.Context, value string) error

+ func (p *TBinaryProtocol) WriteStructBegin(ctx context.Context, name string) error

+ func (p *TBinaryProtocol) WriteStructEnd(ctx context.Context) error

+ type TBinaryProtocolFactory struct

+ func NewTBinaryProtocolFactory(strictRead, strictWrite bool) *TBinaryProtocolFactory

+ func NewTBinaryProtocolFactoryConf(conf *TConfiguration) *TBinaryProtocolFactory

+ func NewTBinaryProtocolFactoryDefault() *TBinaryProtocolFactory

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

+ func (p *TBinaryProtocolFactory) SetTConfiguration(conf *TConfiguration)

+ type TBufferedTransport struct

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

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

+ func (p *TBufferedTransport) Flush(ctx context.Context) 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) SetTConfiguration(conf *TConfiguration)

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

+ type TBufferedTransportFactory struct

+ func NewTBufferedTransportFactory(bufferSize int) *TBufferedTransportFactory

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

+ type TClient interface

+ Call func(ctx context.Context, method string, args, result TStruct) (ResponseMeta, error)

+ func WrapClient(client TClient, middlewares ...ClientMiddleware) TClient

+ type TCompactProtocol struct

+ func NewTCompactProtocol(trans TTransport) *TCompactProtocol

+ func NewTCompactProtocolConf(trans TTransport, conf *TConfiguration) *TCompactProtocol

+ func (p *TCompactProtocol) Flush(ctx context.Context) (err error)

+ func (p *TCompactProtocol) ReadBinary(ctx context.Context) (value []byte, err error)

+ func (p *TCompactProtocol) ReadBool(ctx context.Context) (value bool, err error)

+ func (p *TCompactProtocol) ReadByte(ctx context.Context) (int8, error)

+ func (p *TCompactProtocol) ReadDouble(ctx context.Context) (value float64, err error)

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

+ func (p *TCompactProtocol) ReadFieldEnd(ctx context.Context) error

+ func (p *TCompactProtocol) ReadI16(ctx context.Context) (value int16, err error)

+ func (p *TCompactProtocol) ReadI32(ctx context.Context) (value int32, err error)

+ func (p *TCompactProtocol) ReadI64(ctx context.Context) (value int64, err error)

+ func (p *TCompactProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (p *TCompactProtocol) ReadListEnd(ctx context.Context) error

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

+ func (p *TCompactProtocol) ReadMapEnd(ctx context.Context) error

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

+ func (p *TCompactProtocol) ReadMessageEnd(ctx context.Context) error

+ func (p *TCompactProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (p *TCompactProtocol) ReadSetEnd(ctx context.Context) error

+ func (p *TCompactProtocol) ReadString(ctx context.Context) (value string, err error)

+ func (p *TCompactProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

+ func (p *TCompactProtocol) ReadStructEnd(ctx context.Context) error

+ func (p *TCompactProtocol) SetTConfiguration(conf *TConfiguration)

+ func (p *TCompactProtocol) Skip(ctx context.Context, fieldType TType) (err error)

+ func (p *TCompactProtocol) Transport() TTransport

+ func (p *TCompactProtocol) WriteBinary(ctx context.Context, bin []byte) error

+ func (p *TCompactProtocol) WriteBool(ctx context.Context, value bool) error

+ func (p *TCompactProtocol) WriteByte(ctx context.Context, value int8) error

+ func (p *TCompactProtocol) WriteDouble(ctx context.Context, value float64) error

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

+ func (p *TCompactProtocol) WriteFieldEnd(ctx context.Context) error

+ func (p *TCompactProtocol) WriteFieldStop(ctx context.Context) error

+ func (p *TCompactProtocol) WriteI16(ctx context.Context, value int16) error

+ func (p *TCompactProtocol) WriteI32(ctx context.Context, value int32) error

+ func (p *TCompactProtocol) WriteI64(ctx context.Context, value int64) error

+ func (p *TCompactProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TCompactProtocol) WriteListEnd(ctx context.Context) error

+ func (p *TCompactProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

+ func (p *TCompactProtocol) WriteMapEnd(ctx context.Context) error

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

+ func (p *TCompactProtocol) WriteMessageEnd(ctx context.Context) error

+ func (p *TCompactProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TCompactProtocol) WriteSetEnd(ctx context.Context) error

+ func (p *TCompactProtocol) WriteString(ctx context.Context, value string) error

+ func (p *TCompactProtocol) WriteStructBegin(ctx context.Context, name string) error

+ func (p *TCompactProtocol) WriteStructEnd(ctx context.Context) error

+ type TCompactProtocolFactory struct

+ func NewTCompactProtocolFactory() *TCompactProtocolFactory

+ func NewTCompactProtocolFactoryConf(conf *TConfiguration) *TCompactProtocolFactory

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

+ func (p *TCompactProtocolFactory) SetTConfiguration(conf *TConfiguration)

+ type TConfiguration struct

+ ConnectTimeout time.Duration

+ MaxFrameSize int32

+ MaxMessageSize int32

+ SocketTimeout time.Duration

+ TBinaryStrictRead *bool

+ TBinaryStrictWrite *bool

+ THeaderProtocolID *THeaderProtocolID

+ TLSConfig *tls.Config

+ func (tc *TConfiguration) GetConnectTimeout() time.Duration

+ func (tc *TConfiguration) GetMaxFrameSize() int32

+ func (tc *TConfiguration) GetMaxMessageSize() int32

+ func (tc *TConfiguration) GetSocketTimeout() time.Duration

+ func (tc *TConfiguration) GetTBinaryStrictRead() bool

+ func (tc *TConfiguration) GetTBinaryStrictWrite() bool

+ func (tc *TConfiguration) GetTHeaderProtocolID() THeaderProtocolID

+ func (tc *TConfiguration) GetTLSConfig() *tls.Config

+ type TConfigurationSetter interface

+ SetTConfiguration func(*TConfiguration)

+ type TDebugProtocol struct

+ Delegate TProtocol

+ DuplicateTo TProtocol

+ LogPrefix string

+ Logger Logger

+ func (tdp *TDebugProtocol) Flush(ctx context.Context) (err error)

+ func (tdp *TDebugProtocol) ReadBinary(ctx context.Context) (value []byte, err error)

+ func (tdp *TDebugProtocol) ReadBool(ctx context.Context) (value bool, err error)

+ func (tdp *TDebugProtocol) ReadByte(ctx context.Context) (value int8, err error)

+ func (tdp *TDebugProtocol) ReadDouble(ctx context.Context) (value float64, err error)

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

+ func (tdp *TDebugProtocol) ReadFieldEnd(ctx context.Context) (err error)

+ func (tdp *TDebugProtocol) ReadI16(ctx context.Context) (value int16, err error)

+ func (tdp *TDebugProtocol) ReadI32(ctx context.Context) (value int32, err error)

+ func (tdp *TDebugProtocol) ReadI64(ctx context.Context) (value int64, err error)

+ func (tdp *TDebugProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (tdp *TDebugProtocol) ReadListEnd(ctx context.Context) (err error)

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

+ func (tdp *TDebugProtocol) ReadMapEnd(ctx context.Context) (err error)

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

+ func (tdp *TDebugProtocol) ReadMessageEnd(ctx context.Context) (err error)

+ func (tdp *TDebugProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (tdp *TDebugProtocol) ReadSetEnd(ctx context.Context) (err error)

+ func (tdp *TDebugProtocol) ReadString(ctx context.Context) (value string, err error)

+ func (tdp *TDebugProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

+ func (tdp *TDebugProtocol) ReadStructEnd(ctx context.Context) (err error)

+ func (tdp *TDebugProtocol) SetTConfiguration(conf *TConfiguration)

+ func (tdp *TDebugProtocol) Skip(ctx context.Context, fieldType TType) (err error)

+ func (tdp *TDebugProtocol) Transport() TTransport

+ func (tdp *TDebugProtocol) WriteBinary(ctx context.Context, value []byte) error

+ func (tdp *TDebugProtocol) WriteBool(ctx context.Context, value bool) error

+ func (tdp *TDebugProtocol) WriteByte(ctx context.Context, value int8) error

+ func (tdp *TDebugProtocol) WriteDouble(ctx context.Context, value float64) error

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

+ func (tdp *TDebugProtocol) WriteFieldEnd(ctx context.Context) error

+ func (tdp *TDebugProtocol) WriteFieldStop(ctx context.Context) error

+ func (tdp *TDebugProtocol) WriteI16(ctx context.Context, value int16) error

+ func (tdp *TDebugProtocol) WriteI32(ctx context.Context, value int32) error

+ func (tdp *TDebugProtocol) WriteI64(ctx context.Context, value int64) error

+ func (tdp *TDebugProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

+ func (tdp *TDebugProtocol) WriteListEnd(ctx context.Context) error

+ func (tdp *TDebugProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

+ func (tdp *TDebugProtocol) WriteMapEnd(ctx context.Context) error

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

+ func (tdp *TDebugProtocol) WriteMessageEnd(ctx context.Context) error

+ func (tdp *TDebugProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

+ func (tdp *TDebugProtocol) WriteSetEnd(ctx context.Context) error

+ func (tdp *TDebugProtocol) WriteString(ctx context.Context, value string) error

+ func (tdp *TDebugProtocol) WriteStructBegin(ctx context.Context, name string) error

+ func (tdp *TDebugProtocol) WriteStructEnd(ctx context.Context) error

+ type TDebugProtocolFactory struct

+ LogPrefix string

+ Logger Logger

+ Underlying TProtocolFactory

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

+ func NewTDebugProtocolFactoryWithLogger(underlying TProtocolFactory, logPrefix string, logger Logger) *TDebugProtocolFactory

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

+ type TDeserializer struct

+ Protocol TProtocol

+ Transport *TMemoryBuffer

+ func NewTDeserializer() *TDeserializer

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

+ func (t *TDeserializer) ReadString(ctx context.Context, msg TStruct, s string) (err error)

+ type TDeserializerPool struct

+ func NewTDeserializerPool(f func() *TDeserializer) *TDeserializerPool

+ func NewTDeserializerPoolSizeFactory(size int, factory TProtocolFactory) *TDeserializerPool

+ func (t *TDeserializerPool) Read(ctx context.Context, msg TStruct, b []byte) error

+ func (t *TDeserializerPool) ReadString(ctx context.Context, msg TStruct, s string) error

+ type TException interface

+ TExceptionType func() TExceptionType

+ func WrapTException(err error) TException

+ type TExceptionType byte

+ const TExceptionTypeApplication

+ const TExceptionTypeCompiled

+ const TExceptionTypeProtocol

+ const TExceptionTypeTransport

+ const TExceptionTypeUnknown

+ type TFramedTransport struct

+ func NewTFramedTransport(transport TTransport) *TFramedTransport

+ func NewTFramedTransportConf(transport TTransport, conf *TConfiguration) *TFramedTransport

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

+ func (p *TFramedTransport) Close() error

+ func (p *TFramedTransport) Flush(ctx context.Context) error

+ func (p *TFramedTransport) IsOpen() bool

+ func (p *TFramedTransport) Open() error

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

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

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

+ func (p *TFramedTransport) SetTConfiguration(cfg *TConfiguration)

+ 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 THeaderInfoType int32

+ const InfoKeyValue

+ type THeaderMap map[string]string

+ type THeaderProtocol struct

+ func NewTHeaderProtocol(trans TTransport) *THeaderProtocol

+ func NewTHeaderProtocolConf(trans TTransport, conf *TConfiguration) *THeaderProtocol

+ func (p *THeaderProtocol) AddTransform(transform THeaderTransformID) error

+ func (p *THeaderProtocol) ClearWriteHeaders()

+ func (p *THeaderProtocol) Flush(ctx context.Context) error

+ func (p *THeaderProtocol) GetReadHeaders() THeaderMap

+ func (p *THeaderProtocol) ReadBinary(ctx context.Context) (value []byte, err error)

+ func (p *THeaderProtocol) ReadBool(ctx context.Context) (value bool, err error)

+ func (p *THeaderProtocol) ReadByte(ctx context.Context) (value int8, err error)

+ func (p *THeaderProtocol) ReadDouble(ctx context.Context) (value float64, err error)

+ func (p *THeaderProtocol) ReadFieldBegin(ctx context.Context) (name string, typeID TType, id int16, err error)

+ func (p *THeaderProtocol) ReadFieldEnd(ctx context.Context) error

+ func (p *THeaderProtocol) ReadFrame(ctx context.Context) error

+ func (p *THeaderProtocol) ReadI16(ctx context.Context) (value int16, err error)

+ func (p *THeaderProtocol) ReadI32(ctx context.Context) (value int32, err error)

+ func (p *THeaderProtocol) ReadI64(ctx context.Context) (value int64, err error)

+ func (p *THeaderProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (p *THeaderProtocol) ReadListEnd(ctx context.Context) error

+ func (p *THeaderProtocol) ReadMapBegin(ctx context.Context) (keyType TType, valueType TType, size int, err error)

+ func (p *THeaderProtocol) ReadMapEnd(ctx context.Context) error

+ func (p *THeaderProtocol) ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error)

+ func (p *THeaderProtocol) ReadMessageEnd(ctx context.Context) error

+ func (p *THeaderProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

+ func (p *THeaderProtocol) ReadSetEnd(ctx context.Context) error

+ func (p *THeaderProtocol) ReadString(ctx context.Context) (value string, err error)

+ func (p *THeaderProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

+ func (p *THeaderProtocol) ReadStructEnd(ctx context.Context) error

+ func (p *THeaderProtocol) SetTConfiguration(cfg *TConfiguration)

+ func (p *THeaderProtocol) SetWriteHeader(key, value string)

+ func (p *THeaderProtocol) Skip(ctx context.Context, fieldType TType) error

+ func (p *THeaderProtocol) Transport() TTransport

+ func (p *THeaderProtocol) WriteBinary(ctx context.Context, value []byte) error

+ func (p *THeaderProtocol) WriteBool(ctx context.Context, value bool) error

+ func (p *THeaderProtocol) WriteByte(ctx context.Context, value int8) error

+ func (p *THeaderProtocol) WriteDouble(ctx context.Context, value float64) error

+ func (p *THeaderProtocol) WriteFieldBegin(ctx context.Context, name string, typeID TType, id int16) error

+ func (p *THeaderProtocol) WriteFieldEnd(ctx context.Context) error

+ func (p *THeaderProtocol) WriteFieldStop(ctx context.Context) error

+ func (p *THeaderProtocol) WriteI16(ctx context.Context, value int16) error

+ func (p *THeaderProtocol) WriteI32(ctx context.Context, value int32) error

+ func (p *THeaderProtocol) WriteI64(ctx context.Context, value int64) error

+ func (p *THeaderProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

+ func (p *THeaderProtocol) WriteListEnd(ctx context.Context) error

+ func (p *THeaderProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

+ func (p *THeaderProtocol) WriteMapEnd(ctx context.Context) error

+ func (p *THeaderProtocol) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) error

+ func (p *THeaderProtocol) WriteMessageEnd(ctx context.Context) error

+ func (p *THeaderProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

+ func (p *THeaderProtocol) WriteSetEnd(ctx context.Context) error

+ func (p *THeaderProtocol) WriteString(ctx context.Context, value string) error

+ func (p *THeaderProtocol) WriteStructBegin(ctx context.Context, name string) error

+ func (p *THeaderProtocol) WriteStructEnd(ctx context.Context) error

+ type THeaderProtocolID int32

+ const THeaderProtocolBinary

+ const THeaderProtocolCompact

+ const THeaderProtocolDefault

+ func THeaderProtocolIDPtr(id THeaderProtocolID) (*THeaderProtocolID, error)

+ func THeaderProtocolIDPtrMust(id THeaderProtocolID) *THeaderProtocolID

+ func (id THeaderProtocolID) GetProtocol(trans TTransport) (TProtocol, error)

+ func (id THeaderProtocolID) Validate() error

+ type THeaderResponseHelper struct

+ func NewTHeaderResponseHelper(proto TProtocol) *THeaderResponseHelper

+ func (h *THeaderResponseHelper) ClearHeaders()

+ func (h *THeaderResponseHelper) SetHeader(key, value string)

+ type THeaderTransformID int32

+ const TransformNone

+ const TransformZlib

+ type THeaderTransport struct

+ Flags uint32

+ SequenceID int32

+ func NewTHeaderTransport(trans TTransport) *THeaderTransport

+ func NewTHeaderTransportConf(trans TTransport, conf *TConfiguration) *THeaderTransport

+ func (t *THeaderTransport) AddTransform(transform THeaderTransformID) error

+ func (t *THeaderTransport) ClearWriteHeaders()

+ func (t *THeaderTransport) Close() error

+ func (t *THeaderTransport) Flush(ctx context.Context) error

+ func (t *THeaderTransport) GetReadHeaders() THeaderMap

+ func (t *THeaderTransport) IsOpen() bool

+ func (t *THeaderTransport) Open() error

+ func (t *THeaderTransport) Protocol() THeaderProtocolID

+ func (t *THeaderTransport) Read(p []byte) (read int, err error)

+ func (t *THeaderTransport) ReadFrame(ctx context.Context) error

+ func (t *THeaderTransport) RemainingBytes() uint64

+ func (t *THeaderTransport) SetTConfiguration(cfg *TConfiguration)

+ func (t *THeaderTransport) SetWriteHeader(key, value string)

+ func (t *THeaderTransport) Write(p []byte) (int, error)

+ type THeaderTransportFactory struct

+ Factory TTransportFactory

+ func (f *THeaderTransportFactory) GetTransport(trans TTransport) (TTransport, error)

+ func (f *THeaderTransportFactory) SetTConfiguration(cfg *TConfiguration)

+ type THttpClient struct

+ func (p *THttpClient) Close() error

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

+ func (p *THttpClient) Flush(ctx context.Context) 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, error)

+ type TJSONProtocol struct

+ func NewTJSONProtocol(t TTransport) *TJSONProtocol

+ func (p *TJSONProtocol) Flush(ctx context.Context) (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(ctx context.Context) ([]byte, error)

+ func (p *TJSONProtocol) ReadBool(ctx context.Context) (bool, error)

+ func (p *TJSONProtocol) ReadByte(ctx context.Context) (int8, error)

+ func (p *TJSONProtocol) ReadDouble(ctx context.Context) (float64, error)

+ func (p *TJSONProtocol) ReadFieldBegin(ctx context.Context) (string, TType, int16, error)

+ func (p *TJSONProtocol) ReadFieldEnd(ctx context.Context) error

+ func (p *TJSONProtocol) ReadI16(ctx context.Context) (int16, error)

+ func (p *TJSONProtocol) ReadI32(ctx context.Context) (int32, error)

+ func (p *TJSONProtocol) ReadI64(ctx context.Context) (int64, error)

+ func (p *TJSONProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, e error)

+ func (p *TJSONProtocol) ReadListEnd(ctx context.Context) error

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

+ func (p *TJSONProtocol) ReadMapEnd(ctx context.Context) error

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

+ func (p *TJSONProtocol) ReadMessageEnd(ctx context.Context) error

+ func (p *TJSONProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, e error)

+ func (p *TJSONProtocol) ReadSetEnd(ctx context.Context) error

+ func (p *TJSONProtocol) ReadString(ctx context.Context) (string, error)

+ func (p *TJSONProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

+ func (p *TJSONProtocol) ReadStructEnd(ctx context.Context) error

+ func (p *TJSONProtocol) Skip(ctx context.Context, 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(ctx context.Context, v []byte) error

+ func (p *TJSONProtocol) WriteBool(ctx context.Context, b bool) error

+ func (p *TJSONProtocol) WriteByte(ctx context.Context, b int8) error

+ func (p *TJSONProtocol) WriteDouble(ctx context.Context, v float64) error

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

+ func (p *TJSONProtocol) WriteFieldEnd(ctx context.Context) error

+ func (p *TJSONProtocol) WriteFieldStop(ctx context.Context) error

+ func (p *TJSONProtocol) WriteI16(ctx context.Context, v int16) error

+ func (p *TJSONProtocol) WriteI32(ctx context.Context, v int32) error

+ func (p *TJSONProtocol) WriteI64(ctx context.Context, v int64) error

+ func (p *TJSONProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TJSONProtocol) WriteListEnd(ctx context.Context) error

+ func (p *TJSONProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

+ func (p *TJSONProtocol) WriteMapEnd(ctx context.Context) error

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

+ func (p *TJSONProtocol) WriteMessageEnd(ctx context.Context) error

+ func (p *TJSONProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TJSONProtocol) WriteSetEnd(ctx context.Context) error

+ func (p *TJSONProtocol) WriteString(ctx context.Context, v string) error

+ func (p *TJSONProtocol) WriteStructBegin(ctx context.Context, name string) error

+ func (p *TJSONProtocol) WriteStructEnd(ctx context.Context) 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(ctx context.Context) 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, error)

+ 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) AddToProcessorMap(name string, processorFunc TProcessorFunction)

+ func (t *TMultiplexedProcessor) Process(ctx context.Context, in, out TProtocol) (bool, TException)

+ func (t *TMultiplexedProcessor) ProcessorMap() map[string]TProcessorFunction

+ 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(ctx context.Context, name string, typeId TMessageType, seqid int32) error

+ type TProcessor interface

+ AddToProcessorMap func(string, TProcessorFunction)

+ Process func(ctx context.Context, in, out TProtocol) (bool, TException)

+ ProcessorMap func() map[string]TProcessorFunction

+ func WrapProcessor(processor TProcessor, middlewares ...ProcessorMiddleware) TProcessor

+ type TProcessorFactory interface

+ GetProcessor func(trans TTransport) TProcessor

+ func NewTProcessorFactory(p TProcessor) TProcessorFactory

+ type TProcessorFunction interface

+ Process func(ctx context.Context, 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(ctx context.Context) (err error)

+ ReadBinary func(ctx context.Context) (value []byte, err error)

+ ReadBool func(ctx context.Context) (value bool, err error)

+ ReadByte func(ctx context.Context) (value int8, err error)

+ ReadDouble func(ctx context.Context) (value float64, err error)

+ ReadFieldBegin func(ctx context.Context) (name string, typeId TType, id int16, err error)

+ ReadFieldEnd func(ctx context.Context) error

+ ReadI16 func(ctx context.Context) (value int16, err error)

+ ReadI32 func(ctx context.Context) (value int32, err error)

+ ReadI64 func(ctx context.Context) (value int64, err error)

+ ReadListBegin func(ctx context.Context) (elemType TType, size int, err error)

+ ReadListEnd func(ctx context.Context) error

+ ReadMapBegin func(ctx context.Context) (keyType TType, valueType TType, size int, err error)

+ ReadMapEnd func(ctx context.Context) error

+ ReadMessageBegin func(ctx context.Context) (name string, typeId TMessageType, seqid int32, err error)

+ ReadMessageEnd func(ctx context.Context) error

+ ReadSetBegin func(ctx context.Context) (elemType TType, size int, err error)

+ ReadSetEnd func(ctx context.Context) error

+ ReadString func(ctx context.Context) (value string, err error)

+ ReadStructBegin func(ctx context.Context) (name string, err error)

+ ReadStructEnd func(ctx context.Context) error

+ Skip func(ctx context.Context, fieldType TType) (err error)

+ Transport func() TTransport

+ WriteBinary func(ctx context.Context, value []byte) error

+ WriteBool func(ctx context.Context, value bool) error

+ WriteByte func(ctx context.Context, value int8) error

+ WriteDouble func(ctx context.Context, value float64) error

+ WriteFieldBegin func(ctx context.Context, name string, typeId TType, id int16) error

+ WriteFieldEnd func(ctx context.Context) error

+ WriteFieldStop func(ctx context.Context) error

+ WriteI16 func(ctx context.Context, value int16) error

+ WriteI32 func(ctx context.Context, value int32) error

+ WriteI64 func(ctx context.Context, value int64) error

+ WriteListBegin func(ctx context.Context, elemType TType, size int) error

+ WriteListEnd func(ctx context.Context) error

+ WriteMapBegin func(ctx context.Context, keyType TType, valueType TType, size int) error

+ WriteMapEnd func(ctx context.Context) error

+ WriteMessageBegin func(ctx context.Context, name string, typeId TMessageType, seqid int32) error

+ WriteMessageEnd func(ctx context.Context) error

+ WriteSetBegin func(ctx context.Context, elemType TType, size int) error

+ WriteSetEnd func(ctx context.Context) error

+ WriteString func(ctx context.Context, value string) error

+ WriteStructBegin func(ctx context.Context, name string) error

+ WriteStructEnd func(ctx context.Context) 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

+ func NewTHeaderProtocolFactory() TProtocolFactory

+ func NewTHeaderProtocolFactoryConf(conf *TConfiguration) TProtocolFactory

+ func TProtocolFactoryConf(delegate TProtocolFactory, conf *TConfiguration) TProtocolFactory

+ type TResponseHelper struct

+ func GetResponseHelper(ctx context.Context) (helper TResponseHelper, ok bool)

+ 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 NewTSSLSocketConf(hostPort string, conf *TConfiguration) (*TSSLSocket, error)

+ func NewTSSLSocketFromAddrConf(addr net.Addr, conf *TConfiguration) *TSSLSocket

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

+ func NewTSSLSocketFromConnConf(conn net.Conn, conf *TConfiguration) *TSSLSocket

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

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

+ func (p *TSSLSocket) Close() error

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

+ func (p *TSSLSocket) Flush(ctx context.Context) 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) SetConnTimeout(timeout time.Duration) error

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

+ func (p *TSSLSocket) SetTConfiguration(conf *TConfiguration)

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

+ type TSerializer struct

+ Protocol TProtocol

+ Transport *TMemoryBuffer

+ func NewTSerializer() *TSerializer

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

+ func (t *TSerializer) WriteString(ctx context.Context, msg TStruct) (s string, err error)

+ type TSerializerPool struct

+ func NewTSerializerPool(f func() *TSerializer) *TSerializerPool

+ func NewTSerializerPoolSizeFactory(size int, factory TProtocolFactory) *TSerializerPool

+ func (t *TSerializerPool) Write(ctx context.Context, msg TStruct) ([]byte, error)

+ func (t *TSerializerPool) WriteString(ctx context.Context, msg TStruct) (string, 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 NewTServerSocketFromAddrTimeout(addr net.Addr, clientTimeout time.Duration) *TServerSocket

+ 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(ctx context.Context) (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(ctx context.Context) ([]byte, error)

+ func (p *TSimpleJSONProtocol) ReadBool(ctx context.Context) (bool, error)

+ func (p *TSimpleJSONProtocol) ReadByte(ctx context.Context) (int8, error)

+ func (p *TSimpleJSONProtocol) ReadDouble(ctx context.Context) (float64, error)

+ func (p *TSimpleJSONProtocol) ReadFieldBegin(ctx context.Context) (string, TType, int16, error)

+ func (p *TSimpleJSONProtocol) ReadFieldEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) ReadI16(ctx context.Context) (int16, error)

+ func (p *TSimpleJSONProtocol) ReadI32(ctx context.Context) (int32, error)

+ func (p *TSimpleJSONProtocol) ReadI64(ctx context.Context) (int64, error)

+ func (p *TSimpleJSONProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, e error)

+ func (p *TSimpleJSONProtocol) ReadListEnd(ctx context.Context) error

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

+ func (p *TSimpleJSONProtocol) ReadMapEnd(ctx context.Context) error

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

+ func (p *TSimpleJSONProtocol) ReadMessageEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, e error)

+ func (p *TSimpleJSONProtocol) ReadSetEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) ReadString(ctx context.Context) (string, error)

+ func (p *TSimpleJSONProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

+ func (p *TSimpleJSONProtocol) ReadStructEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) SetTConfiguration(conf *TConfiguration)

+ func (p *TSimpleJSONProtocol) Skip(ctx context.Context, fieldType TType) (err error)

+ func (p *TSimpleJSONProtocol) Transport() TTransport

+ func (p *TSimpleJSONProtocol) WriteBinary(ctx context.Context, v []byte) error

+ func (p *TSimpleJSONProtocol) WriteBool(ctx context.Context, b bool) error

+ func (p *TSimpleJSONProtocol) WriteByte(ctx context.Context, b int8) error

+ func (p *TSimpleJSONProtocol) WriteDouble(ctx context.Context, v float64) error

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

+ func (p *TSimpleJSONProtocol) WriteFieldEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) WriteFieldStop(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) WriteI16(ctx context.Context, v int16) error

+ func (p *TSimpleJSONProtocol) WriteI32(ctx context.Context, v int32) error

+ func (p *TSimpleJSONProtocol) WriteI64(ctx context.Context, v int64) error

+ func (p *TSimpleJSONProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TSimpleJSONProtocol) WriteListEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

+ func (p *TSimpleJSONProtocol) WriteMapEnd(ctx context.Context) error

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

+ func (p *TSimpleJSONProtocol) WriteMessageEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

+ func (p *TSimpleJSONProtocol) WriteSetEnd(ctx context.Context) error

+ func (p *TSimpleJSONProtocol) WriteString(ctx context.Context, v string) error

+ func (p *TSimpleJSONProtocol) WriteStructBegin(ctx context.Context, name string) error

+ func (p *TSimpleJSONProtocol) WriteStructEnd(ctx context.Context) 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) SetForwardHeaders(headers []string)

+ func (p *TSimpleServer) SetLogger(logger Logger)

+ func (p *TSimpleServer) Stop() error

+ type TSocket struct

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

+ func NewTSocketConf(hostPort string, conf *TConfiguration) (*TSocket, error)

+ func NewTSocketFromAddrConf(addr net.Addr, conf *TConfiguration) *TSocket

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

+ func NewTSocketFromConnConf(conn net.Conn, conf *TConfiguration) *TSocket

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

+ func NewTSocketTimeout(hostPort string, connTimeout time.Duration, soTimeout 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(ctx context.Context) 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) SetConnTimeout(timeout time.Duration) error

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

+ func (p *TSocket) SetTConfiguration(conf *TConfiguration)

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

+ type TStandardClient struct

+ func NewTStandardClient(inputProtocol, outputProtocol TProtocol) *TStandardClient

+ func (p *TStandardClient) Call(ctx context.Context, method string, args, result TStruct) (ResponseMeta, error)

+ func (p *TStandardClient) Recv(ctx context.Context, iprot TProtocol, seqId int32, method string, ...) error

+ func (p *TStandardClient) Send(ctx context.Context, oprot TProtocol, seqId int32, method string, args TStruct) error

+ type TStruct interface

+ Read func(ctx context.Context, p TProtocol) error

+ Write func(ctx context.Context, 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, error)

+ func NewTFramedTransportFactory(factory TTransportFactory) TTransportFactory

+ func NewTFramedTransportFactoryConf(factory TTransportFactory, conf *TConfiguration) TTransportFactory

+ func NewTFramedTransportFactoryMaxLength(factory TTransportFactory, maxLength uint32) TTransportFactory

+ func NewTHeaderTransportFactory(factory TTransportFactory) TTransportFactory

+ func NewTHeaderTransportFactoryConf(factory TTransportFactory, conf *TConfiguration) TTransportFactory

+ func NewTTransportFactory() TTransportFactory

+ func TTransportFactoryConf(delegate TTransportFactory, conf *TConfiguration) 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(ctx context.Context) 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) SetTConfiguration(conf *TConfiguration)

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

+ type TZlibTransportFactory struct

+ func NewTZlibTransportFactory(level int) *TZlibTransportFactory

+ func NewTZlibTransportFactoryWithFactory(level int, factory TTransportFactory) *TZlibTransportFactory

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

+ type TransformReader struct

+ func NewTransformReaderWithCapacity(baseReader io.Reader, capacity int) *TransformReader

+ func (tr *TransformReader) AddTransform(id THeaderTransformID) error

+ func (tr *TransformReader) Close() error

+ type TransformWriter struct

+ func (tw *TransformWriter) AddTransform(id THeaderTransformID) error

+ func (tw *TransformWriter) Close() error

+ type WrappedTClient struct

+ Wrapped func(ctx context.Context, method string, args, result TStruct) (ResponseMeta, error)

+ func (c WrappedTClient) Call(ctx context.Context, method string, args, result TStruct) (ResponseMeta, error)

+ type WrappedTProcessorFunction struct

+ Wrapped func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException)

+ func (p WrappedTProcessorFunction) Process(ctx context.Context, seqID int32, in, out TProtocol) (bool, TException)

v1.0.0-RC3

Sep 3, 2021

v1.0.0-RC2

Jul 26, 2021

v1.0.0-RC1

Jun 18, 2021