thrift

package

Go to main page

Versions in this module

v0

v0.15.3

Feb 13, 2020

v0.15.2

Feb 13, 2020

v0.15.1

Feb 12, 2020

v0.15.0

Feb 12, 2020

v0.14.15

Feb 7, 2020

v0.14.14

Feb 6, 2020

v0.14.13

Jan 24, 2020

v0.14.12

Jan 23, 2020

v0.14.11

Jan 22, 2020

Changes in this version

+ func NopLogger(msg string)

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

+ type Logger func(msg string)

+ func StdLogger(logger *log.Logger) Logger

+ func TestLogger(tb testing.TB) Logger

type TDebugProtocol

+ Logger Logger

type TDebugProtocolFactory

+ Logger Logger

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

+ type TDeserializerPool struct

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

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

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

type THeaderMap

+ func GetResponseHeadersFromClient(c TClient) THeaderMap

+ type THeaderResponseHelper struct

+ func NewTHeaderResponseHelper(proto TProtocol) *THeaderResponseHelper

+ func (h *THeaderResponseHelper) ClearHeaders()

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

+ type TResponseHelper struct

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

+ type TSerializerPool struct

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

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

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

type TSimpleServer

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

v0.14.10

Jan 22, 2020

v0.14.9

Jan 22, 2020

v0.14.8

Jan 22, 2020

v0.14.7

Jan 21, 2020

v0.14.6

Jan 21, 2020

v0.14.5

Jan 21, 2020

v0.14.4

Jan 21, 2020

v0.14.3

Jan 21, 2020

v0.14.2

Jan 20, 2020

v0.14.1

Jan 20, 2020

v0.14.0

Jan 20, 2020

Changes in this version

+ var DefaultProcessorOptions = &ProcessorOptions

+ type HandlerFunc func(ctx context.Context, arg interface{}) (result interface{}, err error)

+ type HandlerInterceptor func(ctx context.Context, arg interface{}, handlerFunc HandlerFunc) (result interface{}, err error)

+ func ChainedHandlerInterceptor(interceptors ...HandlerInterceptor) HandlerInterceptor

+ func NullInterceptor() HandlerInterceptor

+ type ProcessorOption interface

+ Apply func(processorOptions *ProcessorOptions)

+ func NewHandlerInterceptorOption(interceptor HandlerInterceptor) ProcessorOption

+ type ProcessorOptions struct

+ Interceptor HandlerInterceptor

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

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)

Incompatible versions in this module

v2.0.0+incompatible

Feb 25, 2021

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