thrift

package

Go to main page

Versions in this module

v0

v0.20.0

Mar 12, 2024

Changes in this version

+ type SlogTStructWrapper struct

+ Type string

+ Value TStruct

+ func (w SlogTStructWrapper) MarshalJSON() ([]byte, error)

+ func (w SlogTStructWrapper) String() string

type TSimpleServer

+ func (p *TSimpleServer) SetLogContext(ctx context.Context)

v0.19.0

Aug 27, 2023

v0.18.1

Feb 23, 2023

v0.18.0

Feb 6, 2023

Changes in this version

+ const COMPACT_UUID

+ const UUID

+ const VALIDATION_FAILED

+ func Must(v T, err error) T

type TApplicationException

+ func NewValidationException(type_ int32, check string, field string, message string) TApplicationException

type TBinaryProtocol

+ func (p *TBinaryProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error)

+ func (p *TBinaryProtocol) WriteUUID(ctx context.Context, value Tuuid) error

type TCompactProtocol

+ func (p *TCompactProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error)

+ func (p *TCompactProtocol) WriteUUID(ctx context.Context, value Tuuid) error

type TDebugProtocol

+ func (tdp *TDebugProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error)

+ func (tdp *TDebugProtocol) WriteUUID(ctx context.Context, value Tuuid) error

type TDuplicateToProtocol

+ func (tdtp *TDuplicateToProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error)

+ func (tdtp *TDuplicateToProtocol) WriteUUID(ctx context.Context, value Tuuid) error

type THeaderProtocol

+ func (p *THeaderProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error)

+ func (p *THeaderProtocol) WriteUUID(ctx context.Context, value Tuuid) error

type TProtocol

+ ReadUUID func(ctx context.Context) (value Tuuid, err error)

+ WriteUUID func(ctx context.Context, value Tuuid) error

type TSimpleJSONProtocol

+ func (p *TSimpleJSONProtocol) ReadUUID(ctx context.Context) (v Tuuid, err error)

+ func (p *TSimpleJSONProtocol) WriteUUID(ctx context.Context, v Tuuid) error

+ type Tuuid [16]byte

+ func ParseTuuid(s string) (u Tuuid, err error)

+ func TuuidPtr(v Tuuid) *Tuuid

+ func (u Tuuid) String() string

+ type ValidationError struct

+ func (e *ValidationError) Check() string

+ func (e *ValidationError) Field() string

+ func (e *ValidationError) FieldSymbol() string

+ func (e *ValidationError) TypeName() string

+ func (e ValidationError) Error() string

v0.17.0

Aug 31, 2022

Changes in this version

+ var ServerStopTimeout = time.Duration(0)

+ func ExtractExceptionFromResult(result TStruct) error

+ func Pointer(v T) *T

type TClient

+ func ExtractIDLExceptionClientMiddleware(next TClient) TClient

+ type TDuplicateToProtocol struct

+ Delegate TProtocol

+ DuplicateTo TProtocol

+ func (tdtp *TDuplicateToProtocol) Flush(ctx context.Context) (err error)

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

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

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

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

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

+ func (tdtp *TDuplicateToProtocol) ReadFieldEnd(ctx context.Context) (err error)

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

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

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

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

+ func (tdtp *TDuplicateToProtocol) ReadListEnd(ctx context.Context) (err error)

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

+ func (tdtp *TDuplicateToProtocol) ReadMapEnd(ctx context.Context) (err error)

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

+ func (tdtp *TDuplicateToProtocol) ReadMessageEnd(ctx context.Context) (err error)

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

+ func (tdtp *TDuplicateToProtocol) ReadSetEnd(ctx context.Context) (err error)

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

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

+ func (tdtp *TDuplicateToProtocol) ReadStructEnd(ctx context.Context) (err error)

+ func (tdtp *TDuplicateToProtocol) SetTConfiguration(conf *TConfiguration)

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

+ func (tdtp *TDuplicateToProtocol) Transport() TTransport

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

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

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

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

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

+ func (tdtp *TDuplicateToProtocol) WriteFieldEnd(ctx context.Context) error

+ func (tdtp *TDuplicateToProtocol) WriteFieldStop(ctx context.Context) error

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

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

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

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

+ func (tdtp *TDuplicateToProtocol) WriteListEnd(ctx context.Context) error

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

+ func (tdtp *TDuplicateToProtocol) WriteMapEnd(ctx context.Context) error

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

+ func (tdtp *TDuplicateToProtocol) WriteMessageEnd(ctx context.Context) error

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

+ func (tdtp *TDuplicateToProtocol) WriteSetEnd(ctx context.Context) error

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

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

+ func (tdtp *TDuplicateToProtocol) WriteStructEnd(ctx context.Context) error

type TSimpleJSONProtocol

+ func (p *TSimpleJSONProtocol) Reset()

v0.16.0

Feb 9, 2022

v0.15.0

Sep 4, 2021

v0.14.2

Jun 12, 2021

Changes in this version

type TSimpleJSONProtocol

+ func NewTSimpleJSONProtocolConf(t TTransport, conf *TConfiguration) *TSimpleJSONProtocol

type TSimpleJSONProtocolFactory

+ func NewTSimpleJSONProtocolFactoryConf(conf *TConfiguration) *TSimpleJSONProtocolFactory

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

v0.14.1

Mar 2, 2021

v0.14.0

Feb 4, 2021

Changes in this version

+ const DEFAULT_CONNECT_TIMEOUT

+ const DEFAULT_MAX_FRAME_SIZE

+ const DEFAULT_MAX_MESSAGE_SIZE

+ const DEFAULT_SOCKET_TIMEOUT

+ const DEFAULT_TBINARY_STRICT_READ

+ const DEFAULT_TBINARY_STRICT_WRITE

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

+ var ServerConnectivityCheckInterval = time.Millisecond * 5

+ func NopLogger(msg string)

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

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

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

+ type ClientMiddleware func(TClient) TClient

+ type Logger func(msg string)

+ func StdLogger(logger *log.Logger) Logger

+ func TestLogger(tb testing.TB) Logger

+ type ProcessorMiddleware func(name string, next TProcessorFunction) TProcessorFunction

+ type ResponseMeta struct

+ Headers THeaderMap

type StreamTransport

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

type TBinaryProtocol

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

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

type TBinaryProtocolFactory

+ func NewTBinaryProtocolFactoryConf(conf *TConfiguration) *TBinaryProtocolFactory

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

type TBufferedTransport

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

type TClient

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

type TCompactProtocol

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

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

type TCompactProtocolFactory

+ func NewTCompactProtocolFactoryConf(conf *TConfiguration) *TCompactProtocolFactory

+ 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

+ DuplicateTo TProtocol

+ Logger Logger

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

type TDebugProtocolFactory

+ Logger Logger

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

+ 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

+ func WrapTException(err error) TException

+ TExceptionType func() TExceptionType

+ type TExceptionType byte

+ const TExceptionTypeApplication

+ const TExceptionTypeCompiled

+ const TExceptionTypeProtocol

+ const TExceptionTypeTransport

+ const TExceptionTypeUnknown

type TFramedTransport

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

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

type THeaderProtocol

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

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

type THeaderProtocolID

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

+ func THeaderProtocolIDPtrMust(id THeaderProtocolID) *THeaderProtocolID

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

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

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

type THeaderTransportFactory

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

type TMultiplexedProcessor

+ func (t *TMultiplexedProcessor) AddToProcessorMap(name string, processorFunc TProcessorFunction)

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

type TProcessor

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

+ AddToProcessorMap func(string, TProcessorFunction)

+ ProcessorMap func() map[string]TProcessorFunction

type 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 TSSLSocket

+ func NewTSSLSocketConf(hostPort string, conf *TConfiguration) (*TSSLSocket, error)

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

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

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

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

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

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

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

type TSimpleServer

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

type TSocket

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

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

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

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

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

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

type TTransportFactory

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

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

+ func TTransportFactoryConf(delegate TTransportFactory, conf *TConfiguration) TTransportFactory

type TZlibTransport

+ func (z *TZlibTransport) SetTConfiguration(conf *TConfiguration)

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

v0.13.0

Oct 11, 2019

Changes in this version

+ const INVALID_PROTOCOL

+ const INVALID_TRANSFORM

+ const THeaderFlagsMask

+ const THeaderHeaderMagic

+ const THeaderHeaderMask

+ const THeaderMaxFrameSize

+ const UNSUPPORTED_CLIENT_TYPE

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

+ 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 Int8Ptr(v int8) *int8

+ func NewTransformWriter(baseWriter io.Writer, transforms []THeaderTransformID) (io.WriteCloser, error)

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

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

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

+ type THeaderInfoType int32

+ const InfoKeyValue

+ type THeaderMap map[string]string

+ type THeaderProtocol struct

+ func NewTHeaderProtocol(trans TTransport) *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() (value []byte, err error)

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

+ func (p *THeaderProtocol) ReadByte() (value int8, err error)

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

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

+ func (p *THeaderProtocol) ReadFieldEnd() error

+ func (p *THeaderProtocol) ReadFrame() error

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

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

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

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

+ func (p *THeaderProtocol) ReadListEnd() error

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

+ func (p *THeaderProtocol) ReadMapEnd() error

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

+ func (p *THeaderProtocol) ReadMessageEnd() error

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

+ func (p *THeaderProtocol) ReadSetEnd() error

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

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

+ func (p *THeaderProtocol) ReadStructEnd() error

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

+ func (p *THeaderProtocol) Skip(fieldType TType) error

+ func (p *THeaderProtocol) Transport() TTransport

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

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

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

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

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

+ func (p *THeaderProtocol) WriteFieldEnd() error

+ func (p *THeaderProtocol) WriteFieldStop() error

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

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

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

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

+ func (p *THeaderProtocol) WriteListEnd() error

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

+ func (p *THeaderProtocol) WriteMapEnd() error

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

+ func (p *THeaderProtocol) WriteMessageEnd() error

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

+ func (p *THeaderProtocol) WriteSetEnd() error

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

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

+ func (p *THeaderProtocol) WriteStructEnd() error

+ type THeaderProtocolID int32

+ const THeaderProtocolBinary

+ const THeaderProtocolCompact

+ const THeaderProtocolDefault

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

+ type THeaderTransformID int32

+ const TransformNone

+ const TransformZlib

+ type THeaderTransport struct

+ Flags uint32

+ SequenceID int32

+ func NewTHeaderTransport(trans TTransport) *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() error

+ func (t *THeaderTransport) RemainingBytes() uint64

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

type TProtocolFactory

+ func NewTHeaderProtocolFactory() TProtocolFactory

type TSimpleServer

+ func (p *TSimpleServer) SetForwardHeaders(headers []string)

type TTransportFactory

+ func NewTHeaderTransportFactory(factory TTransportFactory) TTransportFactory

+ 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

v0.12.0

Dec 19, 2018 GO-2021-0101

GO-2021-0101: Panic due to out-of-bounds read in github.com/apache/thrift

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 ContextFlusher interface

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

+ type Flusher interface

+ Flush func() (err error)

+ type Numeric interface

+ Byte func() byte

+ Float32 func() float32

+ Float64 func() float64

+ Int func() int

+ Int16 func() int16

+ Int32 func() int32

+ Int64 func() int64

+ String func() string

+ var INFINITY Numeric

+ var NAN Numeric

+ var NEGATIVE_INFINITY Numeric

+ var NUMERIC_NULL Numeric

+ var ZERO Numeric

+ func NewNullNumeric() Numeric

+ func NewNumericFromDouble(dValue float64) Numeric

+ func NewNumericFromI32(iValue int32) Numeric

+ func NewNumericFromI64(iValue int64) Numeric

+ func NewNumericFromJSONString(sValue string, isNull bool) Numeric

+ func NewNumericFromString(sValue string) Numeric

+ type ReadSizeProvider interface

+ RemainingBytes func() (num_bytes uint64)

+ type RichTransport struct

+ func NewTRichTransport(trans TTransport) *RichTransport

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

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

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

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

+ type 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) 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(iprot TProtocol) 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(ctx context.Context) (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(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) 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) error

+ type TCompactProtocol struct

+ func NewTCompactProtocol(trans TTransport) *TCompactProtocol

+ func (p *TCompactProtocol) Flush(ctx context.Context) (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(ctx context.Context) (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(ctx context.Context) 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(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() ([]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(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) Process(ctx context.Context, 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(ctx context.Context, in, out TProtocol) (bool, TException)

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

+ func (t *TSerializer) WriteString(ctx context.Context, 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 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() ([]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(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) SetTimeout(timeout time.Duration) error

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

+ func (p *TStandardClient) Recv(iprot TProtocol, seqId int32, method string, result TStruct) error

+ func (p *TStandardClient) Send(ctx context.Context, oprot TProtocol, seqId int32, method string, args TStruct) 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, error)

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

Other modules containing this package

github.com/apache/thrift/lib/go/thrift

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