Versions in this module Expand all Collapse all v0 v0.13.0 Oct 11, 2019 Changes in this version + const ALREADY_OPEN + const BAD_SEQUENCE_ID + const BAD_VERSION + const BOOL + const BYTE + const COMPACT_BINARY + const COMPACT_BOOLEAN_FALSE + const COMPACT_BOOLEAN_TRUE + const COMPACT_BYTE + const COMPACT_DOUBLE + const COMPACT_I16 + const COMPACT_I32 + const COMPACT_I64 + const COMPACT_LIST + const COMPACT_MAP + const COMPACT_PROTOCOL_ID + const COMPACT_SET + const COMPACT_STRUCT + const COMPACT_TYPE_BITS + const COMPACT_TYPE_MASK + const COMPACT_TYPE_SHIFT_AMOUNT + const COMPACT_VERSION + const COMPACT_VERSION_MASK + const DEFAULT_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 INVALID_PROTOCOL + const INVALID_TRANSFORM + const LIST + const MAP + const MISSING_RESULT + const MULTIPLEXED_SEPARATOR + const NEGATIVE_SIZE + const NOT_IMPLEMENTED + const NOT_OPEN + const PROTOCOL_ERROR + const SET + const SIZE_LIMIT + const STOP + const STRING + const STRUCT + const THRIFT_JSON_PROTOCOL_VERSION + const THeaderFlagsMask + const THeaderHeaderMagic + const THeaderHeaderMask + const THeaderMaxFrameSize + const TIMED_OUT + const UNKNOWN_APPLICATION_EXCEPTION + const UNKNOWN_METHOD + const UNKNOWN_PROTOCOL_EXCEPTION + const UNKNOWN_TRANSPORT_EXCEPTION + const UNSUPPORTED_CLIENT_TYPE + const UTF16 + const UTF7 + const UTF8 + const VERSION_1 + const VERSION_MASK + const VOID + const WRONG_METHOD_NAME + var 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 AddReadTHeaderToContext(ctx context.Context, headers THeaderMap) context.Context + func BoolPtr(v bool) *bool + func ByteSlicePtr(v []byte) *[]byte + func Float32Ptr(v float32) *float32 + func Float64Ptr(v float64) *float64 + func GetHeader(ctx context.Context, key string) (value string, ok bool) + func GetReadHeaderList(ctx context.Context) []string + func GetWriteHeaderList(ctx context.Context) []string + func Int16Ptr(v int16) *int16 + func Int32Ptr(v int32) *int32 + func Int64Ptr(v int64) *int64 + func Int8Ptr(v int8) *int8 + func IntPtr(v int) *int + func NewStoredMessageProtocol(protocol TProtocol, name string, typeId TMessageType, seqid int32) *storedMessageProtocol + func NewThriftHandlerFunc(processor TProcessor, inPfactory, outPfactory TProtocolFactory) func(w http.ResponseWriter, r *http.Request) + func NewTransformWriter(baseWriter io.Writer, transforms []THeaderTransformID) (io.WriteCloser, error) + func PrependError(prepend string, err error) 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 + 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 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 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 + func NewTHeaderProtocolFactory() TProtocolFactory + 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) SetForwardHeaders(headers []string) + 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 NewTHeaderTransportFactory(factory TTransportFactory) 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) + 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