Documentation ¶
Index ¶
- Constants
- Variables
- 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)
- type Flusher
- type Numeric
- type ReadSizeProvider
- type RichTransport
- type TApplicationException
- type TBinaryProtocol
- func (p *TBinaryProtocol) Flush() (err error)
- func (p *TBinaryProtocol) ReadBinary() ([]byte, error)
- func (p *TBinaryProtocol) ReadBool() (bool, error)
- func (p *TBinaryProtocol) ReadByte() (int8, error)
- func (p *TBinaryProtocol) ReadDouble() (value float64, err error)
- func (p *TBinaryProtocol) ReadFieldBegin() (name string, typeId TType, seqId int16, err error)
- func (p *TBinaryProtocol) ReadFieldEnd() error
- func (p *TBinaryProtocol) ReadI16() (value int16, err error)
- func (p *TBinaryProtocol) ReadI32() (value int32, err error)
- func (p *TBinaryProtocol) ReadI64() (value int64, err error)
- func (p *TBinaryProtocol) ReadListBegin() (elemType TType, size int, err error)
- func (p *TBinaryProtocol) ReadListEnd() error
- func (p *TBinaryProtocol) ReadMapBegin() (kType, vType TType, size int, err error)
- func (p *TBinaryProtocol) ReadMapEnd() error
- func (p *TBinaryProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
- func (p *TBinaryProtocol) ReadMessageEnd() error
- func (p *TBinaryProtocol) ReadSetBegin() (elemType TType, size int, err error)
- func (p *TBinaryProtocol) ReadSetEnd() error
- func (p *TBinaryProtocol) ReadString() (value string, err error)
- func (p *TBinaryProtocol) ReadStructBegin() (name string, err error)
- func (p *TBinaryProtocol) ReadStructEnd() error
- func (p *TBinaryProtocol) Skip(fieldType TType) (err error)
- func (p *TBinaryProtocol) Transport() TTransport
- func (p *TBinaryProtocol) WriteBinary(value []byte) error
- func (p *TBinaryProtocol) WriteBool(value bool) error
- func (p *TBinaryProtocol) WriteByte(value int8) error
- func (p *TBinaryProtocol) WriteDouble(value float64) error
- func (p *TBinaryProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
- func (p *TBinaryProtocol) WriteFieldEnd() error
- func (p *TBinaryProtocol) WriteFieldStop() error
- func (p *TBinaryProtocol) WriteI16(value int16) error
- func (p *TBinaryProtocol) WriteI32(value int32) error
- func (p *TBinaryProtocol) WriteI64(value int64) error
- func (p *TBinaryProtocol) WriteListBegin(elemType TType, size int) error
- func (p *TBinaryProtocol) WriteListEnd() error
- func (p *TBinaryProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
- func (p *TBinaryProtocol) WriteMapEnd() error
- func (p *TBinaryProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error
- func (p *TBinaryProtocol) WriteMessageEnd() error
- func (p *TBinaryProtocol) WriteSetBegin(elemType TType, size int) error
- func (p *TBinaryProtocol) WriteSetEnd() error
- func (p *TBinaryProtocol) WriteString(value string) error
- func (p *TBinaryProtocol) WriteStructBegin(name string) error
- func (p *TBinaryProtocol) WriteStructEnd() error
- type TBinaryProtocolFactory
- type TCompactProtocol
- func (p *TCompactProtocol) Flush() (err error)
- func (p *TCompactProtocol) ReadBinary() (value []byte, err error)
- func (p *TCompactProtocol) ReadBool() (value bool, err error)
- func (p *TCompactProtocol) ReadByte() (int8, error)
- func (p *TCompactProtocol) ReadDouble() (value float64, err error)
- func (p *TCompactProtocol) ReadFieldBegin() (name string, typeId TType, id int16, err error)
- func (p *TCompactProtocol) ReadFieldEnd() error
- func (p *TCompactProtocol) ReadI16() (value int16, err error)
- func (p *TCompactProtocol) ReadI32() (value int32, err error)
- func (p *TCompactProtocol) ReadI64() (value int64, err error)
- func (p *TCompactProtocol) ReadListBegin() (elemType TType, size int, err error)
- func (p *TCompactProtocol) ReadListEnd() error
- func (p *TCompactProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, err error)
- func (p *TCompactProtocol) ReadMapEnd() error
- func (p *TCompactProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
- func (p *TCompactProtocol) ReadMessageEnd() error
- func (p *TCompactProtocol) ReadSetBegin() (elemType TType, size int, err error)
- func (p *TCompactProtocol) ReadSetEnd() error
- func (p *TCompactProtocol) ReadString() (value string, err error)
- func (p *TCompactProtocol) ReadStructBegin() (name string, err error)
- func (p *TCompactProtocol) ReadStructEnd() error
- func (p *TCompactProtocol) Skip(fieldType TType) (err error)
- func (p *TCompactProtocol) Transport() TTransport
- func (p *TCompactProtocol) WriteBinary(bin []byte) error
- func (p *TCompactProtocol) WriteBool(value bool) error
- func (p *TCompactProtocol) WriteByte(value int8) error
- func (p *TCompactProtocol) WriteDouble(value float64) error
- func (p *TCompactProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
- func (p *TCompactProtocol) WriteFieldEnd() error
- func (p *TCompactProtocol) WriteFieldStop() error
- func (p *TCompactProtocol) WriteI16(value int16) error
- func (p *TCompactProtocol) WriteI32(value int32) error
- func (p *TCompactProtocol) WriteI64(value int64) error
- func (p *TCompactProtocol) WriteListBegin(elemType TType, size int) error
- func (p *TCompactProtocol) WriteListEnd() error
- func (p *TCompactProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
- func (p *TCompactProtocol) WriteMapEnd() error
- func (p *TCompactProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error
- func (p *TCompactProtocol) WriteMessageEnd() error
- func (p *TCompactProtocol) WriteSetBegin(elemType TType, size int) error
- func (p *TCompactProtocol) WriteSetEnd() error
- func (p *TCompactProtocol) WriteString(value string) error
- func (p *TCompactProtocol) WriteStructBegin(name string) error
- func (p *TCompactProtocol) WriteStructEnd() error
- type TCompactProtocolFactory
- type TException
- type TMemoryBuffer
- type TMemoryBufferTransportFactory
- type TMessageType
- type TProcessor
- type TProcessorFunction
- type TProtocol
- type TProtocolException
- type TProtocolFactory
- type TRichTransport
- type TSerializer
- type TSimpleJSONProtocol
- func (p *TSimpleJSONProtocol) Flush() (err error)
- func (p *TSimpleJSONProtocol) OutputBool(value bool) error
- func (p *TSimpleJSONProtocol) OutputElemListBegin(elemType TType, size int) error
- func (p *TSimpleJSONProtocol) OutputF64(value float64) error
- func (p *TSimpleJSONProtocol) OutputI64(value int64) error
- func (p *TSimpleJSONProtocol) OutputListBegin() error
- func (p *TSimpleJSONProtocol) OutputListEnd() error
- func (p *TSimpleJSONProtocol) OutputNull() error
- func (p *TSimpleJSONProtocol) OutputObjectBegin() error
- func (p *TSimpleJSONProtocol) OutputObjectEnd() error
- func (p *TSimpleJSONProtocol) OutputPostValue() error
- func (p *TSimpleJSONProtocol) OutputPreValue() error
- func (p *TSimpleJSONProtocol) OutputString(s string) error
- func (p *TSimpleJSONProtocol) OutputStringData(s string) error
- func (p *TSimpleJSONProtocol) ParseBase64EncodedBody() ([]byte, error)
- func (p *TSimpleJSONProtocol) ParseElemListBegin() (elemType TType, size int, e error)
- func (p *TSimpleJSONProtocol) ParseF64() (float64, bool, error)
- func (p *TSimpleJSONProtocol) ParseI64() (int64, bool, error)
- func (p *TSimpleJSONProtocol) ParseListBegin() (isNull bool, err error)
- func (p *TSimpleJSONProtocol) ParseListEnd() error
- func (p *TSimpleJSONProtocol) ParseObjectEnd() error
- func (p *TSimpleJSONProtocol) ParseObjectStart() (bool, error)
- func (p *TSimpleJSONProtocol) ParsePostValue() error
- func (p *TSimpleJSONProtocol) ParsePreValue() error
- func (p *TSimpleJSONProtocol) ParseQuotedStringBody() (string, error)
- func (p *TSimpleJSONProtocol) ParseStringBody() (string, error)
- func (p *TSimpleJSONProtocol) ReadBinary() ([]byte, error)
- func (p *TSimpleJSONProtocol) ReadBool() (bool, error)
- func (p *TSimpleJSONProtocol) ReadByte() (int8, error)
- func (p *TSimpleJSONProtocol) ReadDouble() (float64, error)
- func (p *TSimpleJSONProtocol) ReadFieldBegin() (string, TType, int16, error)
- func (p *TSimpleJSONProtocol) ReadFieldEnd() error
- func (p *TSimpleJSONProtocol) ReadI16() (int16, error)
- func (p *TSimpleJSONProtocol) ReadI32() (int32, error)
- func (p *TSimpleJSONProtocol) ReadI64() (int64, error)
- func (p *TSimpleJSONProtocol) ReadListBegin() (elemType TType, size int, e error)
- func (p *TSimpleJSONProtocol) ReadListEnd() error
- func (p *TSimpleJSONProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, e error)
- func (p *TSimpleJSONProtocol) ReadMapEnd() error
- func (p *TSimpleJSONProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
- func (p *TSimpleJSONProtocol) ReadMessageEnd() error
- func (p *TSimpleJSONProtocol) ReadSetBegin() (elemType TType, size int, e error)
- func (p *TSimpleJSONProtocol) ReadSetEnd() error
- func (p *TSimpleJSONProtocol) ReadString() (string, error)
- func (p *TSimpleJSONProtocol) ReadStructBegin() (name string, err error)
- func (p *TSimpleJSONProtocol) ReadStructEnd() error
- func (p *TSimpleJSONProtocol) Skip(fieldType TType) (err error)
- func (p *TSimpleJSONProtocol) Transport() TTransport
- func (p *TSimpleJSONProtocol) WriteBinary(v []byte) error
- func (p *TSimpleJSONProtocol) WriteBool(b bool) error
- func (p *TSimpleJSONProtocol) WriteByte(b int8) error
- func (p *TSimpleJSONProtocol) WriteDouble(v float64) error
- func (p *TSimpleJSONProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
- func (p *TSimpleJSONProtocol) WriteFieldEnd() error
- func (p *TSimpleJSONProtocol) WriteFieldStop() error
- func (p *TSimpleJSONProtocol) WriteI16(v int16) error
- func (p *TSimpleJSONProtocol) WriteI32(v int32) error
- func (p *TSimpleJSONProtocol) WriteI64(v int64) error
- func (p *TSimpleJSONProtocol) WriteListBegin(elemType TType, size int) error
- func (p *TSimpleJSONProtocol) WriteListEnd() error
- func (p *TSimpleJSONProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
- func (p *TSimpleJSONProtocol) WriteMapEnd() error
- func (p *TSimpleJSONProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error
- func (p *TSimpleJSONProtocol) WriteMessageEnd() error
- func (p *TSimpleJSONProtocol) WriteSetBegin(elemType TType, size int) error
- func (p *TSimpleJSONProtocol) WriteSetEnd() error
- func (p *TSimpleJSONProtocol) WriteString(v string) error
- func (p *TSimpleJSONProtocol) WriteStructBegin(name string) error
- func (p *TSimpleJSONProtocol) WriteStructEnd() error
- type TSimpleJSONProtocolFactory
- type TStruct
- type TTransport
- type TTransportException
- type TTransportFactory
- type TType
Constants ¶
const ( UNKNOWN_APPLICATION_EXCEPTION = 0 UNKNOWN_METHOD = 1 INVALID_MESSAGE_TYPE_EXCEPTION = 2 WRONG_METHOD_NAME = 3 BAD_SEQUENCE_ID = 4 MISSING_RESULT = 5 INTERNAL_ERROR = 6 PROTOCOL_ERROR = 7 )
const ( COMPACT_PROTOCOL_ID = 0x082 COMPACT_VERSION = 1 COMPACT_VERSION_MASK = 0x1f COMPACT_TYPE_MASK = 0x0E0 COMPACT_TYPE_BITS = 0x07 COMPACT_TYPE_SHIFT_AMOUNT = 5 )
const ( COMPACT_BOOLEAN_TRUE = 0x01 COMPACT_BOOLEAN_FALSE = 0x02 COMPACT_BYTE = 0x03 COMPACT_I16 = 0x04 COMPACT_I32 = 0x05 COMPACT_I64 = 0x06 COMPACT_DOUBLE = 0x07 COMPACT_BINARY = 0x08 COMPACT_LIST = 0x09 COMPACT_SET = 0x0A COMPACT_MAP = 0x0B COMPACT_STRUCT = 0x0C )
const ( VERSION_MASK = 0xffff0000 VERSION_1 = 0x80010000 )
const ( UNKNOWN_PROTOCOL_EXCEPTION = 0 INVALID_DATA = 1 NEGATIVE_SIZE = 2 SIZE_LIMIT = 3 BAD_VERSION = 4 NOT_IMPLEMENTED = 5 DEPTH_LIMIT = 6 )
const ( UNKNOWN_TRANSPORT_EXCEPTION = 0 NOT_OPEN = 1 ALREADY_OPEN = 2 TIMED_OUT = 3 END_OF_FILE = 4 )
const ( STOP = 0 VOID = 1 BOOL = 2 BYTE = 3 I08 = 3 DOUBLE = 4 I16 = 6 I32 = 8 I64 = 10 STRING = 11 UTF7 = 11 STRUCT = 12 MAP = 13 SET = 14 LIST = 15 UTF8 = 16 UTF16 = 17 )
const DEFAULT_RECURSION_DEPTH = 64
The maximum recursive depth the skip() function will traverse
Variables ¶
var ( JSON_COMMA []byte JSON_COLON []byte JSON_LBRACE []byte JSON_RBRACE []byte JSON_LBRACKET []byte JSON_RBRACKET []byte JSON_QUOTE byte JSON_QUOTE_BYTES []byte JSON_NULL []byte JSON_TRUE []byte JSON_FALSE []byte JSON_INFINITY string JSON_NEGATIVE_INFINITY string JSON_NAN string JSON_INFINITY_BYTES []byte JSON_NEGATIVE_INFINITY_BYTES []byte JSON_NAN_BYTES []byte )
Functions ¶
func PrependError ¶
Prepends additional information to an error without losing the Thrift exception interface
func SkipDefaultDepth ¶
Skips over the next data element from the provided input TProtocol object.
Types ¶
type Numeric ¶
type Numeric interface { Int64() int64 Int32() int32 Int16() int16 Byte() byte Int() int Float64() float64 Float32() float32 String() string // contains filtered or unexported methods }
func NewNullNumeric ¶
func NewNullNumeric() Numeric
func NewNumericFromDouble ¶
func NewNumericFromI32 ¶
func NewNumericFromI64 ¶
func NewNumericFromString ¶
type ReadSizeProvider ¶
type ReadSizeProvider interface {
RemainingBytes() (num_bytes uint64)
}
type RichTransport ¶
type RichTransport struct {
TTransport
}
func NewTRichTransport ¶
func NewTRichTransport(trans TTransport) *RichTransport
Wraps Transport to provide TRichTransport interface
func (*RichTransport) ReadByte ¶
func (r *RichTransport) ReadByte() (c byte, err error)
func (*RichTransport) RemainingBytes ¶
func (r *RichTransport) RemainingBytes() (num_bytes uint64)
func (*RichTransport) WriteByte ¶
func (r *RichTransport) WriteByte(c byte) error
func (*RichTransport) WriteString ¶
func (r *RichTransport) WriteString(s string) (n int, err error)
type TApplicationException ¶
type TApplicationException interface { TException TypeId() int32 Read(iprot TProtocol) (TApplicationException, error) Write(oprot TProtocol) error }
Application level Thrift exception
func NewTApplicationException ¶
func NewTApplicationException(type_ int32, message string) TApplicationException
type TBinaryProtocol ¶
type TBinaryProtocol struct {
// contains filtered or unexported fields
}
func NewTBinaryProtocol ¶
func NewTBinaryProtocol(t TTransport, strictRead, strictWrite bool) *TBinaryProtocol
func NewTBinaryProtocolTransport ¶
func NewTBinaryProtocolTransport(t TTransport) *TBinaryProtocol
func (*TBinaryProtocol) Flush ¶
func (p *TBinaryProtocol) Flush() (err error)
func (*TBinaryProtocol) ReadBinary ¶
func (p *TBinaryProtocol) ReadBinary() ([]byte, error)
func (*TBinaryProtocol) ReadBool ¶
func (p *TBinaryProtocol) ReadBool() (bool, error)
func (*TBinaryProtocol) ReadByte ¶
func (p *TBinaryProtocol) ReadByte() (int8, error)
func (*TBinaryProtocol) ReadDouble ¶
func (p *TBinaryProtocol) ReadDouble() (value float64, err error)
func (*TBinaryProtocol) ReadFieldBegin ¶
func (p *TBinaryProtocol) ReadFieldBegin() (name string, typeId TType, seqId int16, err error)
func (*TBinaryProtocol) ReadFieldEnd ¶
func (p *TBinaryProtocol) ReadFieldEnd() error
func (*TBinaryProtocol) ReadI16 ¶
func (p *TBinaryProtocol) ReadI16() (value int16, err error)
func (*TBinaryProtocol) ReadI32 ¶
func (p *TBinaryProtocol) ReadI32() (value int32, err error)
func (*TBinaryProtocol) ReadI64 ¶
func (p *TBinaryProtocol) ReadI64() (value int64, err error)
func (*TBinaryProtocol) ReadListBegin ¶
func (p *TBinaryProtocol) ReadListBegin() (elemType TType, size int, err error)
func (*TBinaryProtocol) ReadListEnd ¶
func (p *TBinaryProtocol) ReadListEnd() error
func (*TBinaryProtocol) ReadMapBegin ¶
func (p *TBinaryProtocol) ReadMapBegin() (kType, vType TType, size int, err error)
func (*TBinaryProtocol) ReadMapEnd ¶
func (p *TBinaryProtocol) ReadMapEnd() error
func (*TBinaryProtocol) ReadMessageBegin ¶
func (p *TBinaryProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
func (*TBinaryProtocol) ReadMessageEnd ¶
func (p *TBinaryProtocol) ReadMessageEnd() error
func (*TBinaryProtocol) ReadSetBegin ¶
func (p *TBinaryProtocol) ReadSetBegin() (elemType TType, size int, err error)
func (*TBinaryProtocol) ReadSetEnd ¶
func (p *TBinaryProtocol) ReadSetEnd() error
func (*TBinaryProtocol) ReadString ¶
func (p *TBinaryProtocol) ReadString() (value string, err error)
func (*TBinaryProtocol) ReadStructBegin ¶
func (p *TBinaryProtocol) ReadStructBegin() (name string, err error)
func (*TBinaryProtocol) ReadStructEnd ¶
func (p *TBinaryProtocol) ReadStructEnd() error
func (*TBinaryProtocol) Skip ¶
func (p *TBinaryProtocol) Skip(fieldType TType) (err error)
func (*TBinaryProtocol) Transport ¶
func (p *TBinaryProtocol) Transport() TTransport
func (*TBinaryProtocol) WriteBinary ¶
func (p *TBinaryProtocol) WriteBinary(value []byte) error
func (*TBinaryProtocol) WriteBool ¶
func (p *TBinaryProtocol) WriteBool(value bool) error
func (*TBinaryProtocol) WriteByte ¶
func (p *TBinaryProtocol) WriteByte(value int8) error
func (*TBinaryProtocol) WriteDouble ¶
func (p *TBinaryProtocol) WriteDouble(value float64) error
func (*TBinaryProtocol) WriteFieldBegin ¶
func (p *TBinaryProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
func (*TBinaryProtocol) WriteFieldEnd ¶
func (p *TBinaryProtocol) WriteFieldEnd() error
func (*TBinaryProtocol) WriteFieldStop ¶
func (p *TBinaryProtocol) WriteFieldStop() error
func (*TBinaryProtocol) WriteI16 ¶
func (p *TBinaryProtocol) WriteI16(value int16) error
func (*TBinaryProtocol) WriteI32 ¶
func (p *TBinaryProtocol) WriteI32(value int32) error
func (*TBinaryProtocol) WriteI64 ¶
func (p *TBinaryProtocol) WriteI64(value int64) error
func (*TBinaryProtocol) WriteListBegin ¶
func (p *TBinaryProtocol) WriteListBegin(elemType TType, size int) error
func (*TBinaryProtocol) WriteListEnd ¶
func (p *TBinaryProtocol) WriteListEnd() error
func (*TBinaryProtocol) WriteMapBegin ¶
func (p *TBinaryProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
func (*TBinaryProtocol) WriteMapEnd ¶
func (p *TBinaryProtocol) WriteMapEnd() error
func (*TBinaryProtocol) WriteMessageBegin ¶
func (p *TBinaryProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error
func (*TBinaryProtocol) WriteMessageEnd ¶
func (p *TBinaryProtocol) WriteMessageEnd() error
func (*TBinaryProtocol) WriteSetBegin ¶
func (p *TBinaryProtocol) WriteSetBegin(elemType TType, size int) error
func (*TBinaryProtocol) WriteSetEnd ¶
func (p *TBinaryProtocol) WriteSetEnd() error
func (*TBinaryProtocol) WriteString ¶
func (p *TBinaryProtocol) WriteString(value string) error
func (*TBinaryProtocol) WriteStructBegin ¶
func (p *TBinaryProtocol) WriteStructBegin(name string) error
func (*TBinaryProtocol) WriteStructEnd ¶
func (p *TBinaryProtocol) WriteStructEnd() error
type TBinaryProtocolFactory ¶
type TBinaryProtocolFactory struct {
// contains filtered or unexported fields
}
func NewTBinaryProtocolFactory ¶
func NewTBinaryProtocolFactory(strictRead, strictWrite bool) *TBinaryProtocolFactory
func NewTBinaryProtocolFactoryDefault ¶
func NewTBinaryProtocolFactoryDefault() *TBinaryProtocolFactory
func (*TBinaryProtocolFactory) GetProtocol ¶
func (p *TBinaryProtocolFactory) GetProtocol(t TTransport) TProtocol
type TCompactProtocol ¶
type TCompactProtocol struct {
// contains filtered or unexported fields
}
func NewTCompactProtocol ¶
func NewTCompactProtocol(trans TTransport) *TCompactProtocol
Create a TCompactProtocol given a TTransport
func (*TCompactProtocol) Flush ¶
func (p *TCompactProtocol) Flush() (err error)
func (*TCompactProtocol) ReadBinary ¶
func (p *TCompactProtocol) ReadBinary() (value []byte, err error)
Read a []byte from the wire.
func (*TCompactProtocol) ReadBool ¶
func (p *TCompactProtocol) ReadBool() (value bool, err error)
Read a boolean off the wire. If this is a boolean field, the value should already have been read during readFieldBegin, so we'll just consume the pre-stored value. Otherwise, read a byte.
func (*TCompactProtocol) ReadByte ¶
func (p *TCompactProtocol) ReadByte() (int8, error)
Read a single byte off the wire. Nothing interesting here.
func (*TCompactProtocol) ReadDouble ¶
func (p *TCompactProtocol) ReadDouble() (value float64, err error)
No magic here - just read a double off the wire.
func (*TCompactProtocol) ReadFieldBegin ¶
func (p *TCompactProtocol) ReadFieldBegin() (name string, typeId TType, id int16, err error)
Read a field header off the wire.
func (*TCompactProtocol) ReadFieldEnd ¶
func (p *TCompactProtocol) ReadFieldEnd() error
func (*TCompactProtocol) ReadI16 ¶
func (p *TCompactProtocol) ReadI16() (value int16, err error)
Read an i16 from the wire as a zigzag varint.
func (*TCompactProtocol) ReadI32 ¶
func (p *TCompactProtocol) ReadI32() (value int32, err error)
Read an i32 from the wire as a zigzag varint.
func (*TCompactProtocol) ReadI64 ¶
func (p *TCompactProtocol) ReadI64() (value int64, err error)
Read an i64 from the wire as a zigzag varint.
func (*TCompactProtocol) ReadListBegin ¶
func (p *TCompactProtocol) ReadListBegin() (elemType TType, size int, err error)
Read a list header off the wire. If the list size is 0-14, the size will be packed into the element type header. If it's a longer list, the 4 MSB of the element type header will be 0xF, and a varint will follow with the true size.
func (*TCompactProtocol) ReadListEnd ¶
func (p *TCompactProtocol) ReadListEnd() error
func (*TCompactProtocol) ReadMapBegin ¶
func (p *TCompactProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, err error)
Read a map header off the wire. If the size is zero, skip reading the key and value type. This means that 0-length maps will yield TMaps without the "correct" types.
func (*TCompactProtocol) ReadMapEnd ¶
func (p *TCompactProtocol) ReadMapEnd() error
func (*TCompactProtocol) ReadMessageBegin ¶
func (p *TCompactProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
Read a message header.
func (*TCompactProtocol) ReadMessageEnd ¶
func (p *TCompactProtocol) ReadMessageEnd() error
func (*TCompactProtocol) ReadSetBegin ¶
func (p *TCompactProtocol) ReadSetBegin() (elemType TType, size int, err error)
Read a set header off the wire. If the set size is 0-14, the size will be packed into the element type header. If it's a longer set, the 4 MSB of the element type header will be 0xF, and a varint will follow with the true size.
func (*TCompactProtocol) ReadSetEnd ¶
func (p *TCompactProtocol) ReadSetEnd() error
func (*TCompactProtocol) ReadString ¶
func (p *TCompactProtocol) ReadString() (value string, err error)
Reads a []byte (via readBinary), and then UTF-8 decodes it.
func (*TCompactProtocol) ReadStructBegin ¶
func (p *TCompactProtocol) ReadStructBegin() (name string, err error)
Read a struct begin. There's nothing on the wire for this, but it is our opportunity to push a new struct begin marker onto the field stack.
func (*TCompactProtocol) ReadStructEnd ¶
func (p *TCompactProtocol) ReadStructEnd() error
Doesn't actually consume any wire data, just removes the last field for this struct from the field stack.
func (*TCompactProtocol) Skip ¶
func (p *TCompactProtocol) Skip(fieldType TType) (err error)
func (*TCompactProtocol) Transport ¶
func (p *TCompactProtocol) Transport() TTransport
func (*TCompactProtocol) WriteBinary ¶
func (p *TCompactProtocol) WriteBinary(bin []byte) error
Write a byte array, using a varint for the size.
func (*TCompactProtocol) WriteBool ¶
func (p *TCompactProtocol) WriteBool(value bool) error
func (*TCompactProtocol) WriteByte ¶
func (p *TCompactProtocol) WriteByte(value int8) error
Write a byte. Nothing to see here!
func (*TCompactProtocol) WriteDouble ¶
func (p *TCompactProtocol) WriteDouble(value float64) error
Write a double to the wire as 8 bytes.
func (*TCompactProtocol) WriteFieldBegin ¶
func (p *TCompactProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
func (*TCompactProtocol) WriteFieldEnd ¶
func (p *TCompactProtocol) WriteFieldEnd() error
func (*TCompactProtocol) WriteFieldStop ¶
func (p *TCompactProtocol) WriteFieldStop() error
func (*TCompactProtocol) WriteI16 ¶
func (p *TCompactProtocol) WriteI16(value int16) error
Write an I16 as a zigzag varint.
func (*TCompactProtocol) WriteI32 ¶
func (p *TCompactProtocol) WriteI32(value int32) error
Write an i32 as a zigzag varint.
func (*TCompactProtocol) WriteI64 ¶
func (p *TCompactProtocol) WriteI64(value int64) error
Write an i64 as a zigzag varint.
func (*TCompactProtocol) WriteListBegin ¶
func (p *TCompactProtocol) WriteListBegin(elemType TType, size int) error
Write a list header.
func (*TCompactProtocol) WriteListEnd ¶
func (p *TCompactProtocol) WriteListEnd() error
func (*TCompactProtocol) WriteMapBegin ¶
func (p *TCompactProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
func (*TCompactProtocol) WriteMapEnd ¶
func (p *TCompactProtocol) WriteMapEnd() error
func (*TCompactProtocol) WriteMessageBegin ¶
func (p *TCompactProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error
Write a message header to the wire. Compact Protocol messages contain the protocol version so we can migrate forwards in the future if need be.
func (*TCompactProtocol) WriteMessageEnd ¶
func (p *TCompactProtocol) WriteMessageEnd() error
func (*TCompactProtocol) WriteSetBegin ¶
func (p *TCompactProtocol) WriteSetBegin(elemType TType, size int) error
Write a set header.
func (*TCompactProtocol) WriteSetEnd ¶
func (p *TCompactProtocol) WriteSetEnd() error
func (*TCompactProtocol) WriteString ¶
func (p *TCompactProtocol) WriteString(value string) error
Write a string to the wire with a varint size preceding.
func (*TCompactProtocol) WriteStructBegin ¶
func (p *TCompactProtocol) WriteStructBegin(name string) error
Write a struct begin. This doesn't actually put anything on the wire. We use it as an opportunity to put special placeholder markers on the field stack so we can get the field id deltas correct.
func (*TCompactProtocol) WriteStructEnd ¶
func (p *TCompactProtocol) WriteStructEnd() error
Write a struct end. This doesn't actually put anything on the wire. We use this as an opportunity to pop the last field from the current struct off of the field stack.
type TCompactProtocolFactory ¶
type TCompactProtocolFactory struct{}
func NewTCompactProtocolFactory ¶
func NewTCompactProtocolFactory() *TCompactProtocolFactory
func (*TCompactProtocolFactory) GetProtocol ¶
func (p *TCompactProtocolFactory) GetProtocol(trans TTransport) TProtocol
type TMemoryBuffer ¶
Memory buffer-based implementation of the TTransport interface.
func NewTMemoryBuffer ¶
func NewTMemoryBuffer() *TMemoryBuffer
func NewTMemoryBufferLen ¶
func NewTMemoryBufferLen(size int) *TMemoryBuffer
func (*TMemoryBuffer) Close ¶
func (p *TMemoryBuffer) Close() error
func (*TMemoryBuffer) Flush ¶
func (p *TMemoryBuffer) Flush() error
Flushing a memory buffer is a no-op
func (*TMemoryBuffer) IsOpen ¶
func (p *TMemoryBuffer) IsOpen() bool
func (*TMemoryBuffer) Open ¶
func (p *TMemoryBuffer) Open() error
func (*TMemoryBuffer) RemainingBytes ¶
func (p *TMemoryBuffer) RemainingBytes() (num_bytes uint64)
type TMemoryBufferTransportFactory ¶
type TMemoryBufferTransportFactory struct {
// contains filtered or unexported fields
}
func NewTMemoryBufferTransportFactory ¶
func NewTMemoryBufferTransportFactory(size int) *TMemoryBufferTransportFactory
func (*TMemoryBufferTransportFactory) GetTransport ¶
func (p *TMemoryBufferTransportFactory) GetTransport(trans TTransport) TTransport
type TMessageType ¶
type TMessageType int32
Message type constants in the Thrift protocol.
const ( INVALID_TMESSAGE_TYPE TMessageType = 0 CALL TMessageType = 1 REPLY TMessageType = 2 EXCEPTION TMessageType = 3 ONEWAY TMessageType = 4 )
type TProcessor ¶
type TProcessor interface {
Process(in, out TProtocol) (bool, TException)
}
A processor is a generic object which operates upon an input stream and writes to some output stream.
type TProcessorFunction ¶
type TProcessorFunction interface {
Process(seqId int32, in, out TProtocol) (bool, TException)
}
type TProtocol ¶
type TProtocol interface { WriteMessageBegin(name string, typeId TMessageType, seqid int32) error WriteMessageEnd() error WriteStructBegin(name string) error WriteStructEnd() error WriteFieldBegin(name string, typeId TType, id int16) error WriteFieldEnd() error WriteFieldStop() error WriteMapBegin(keyType TType, valueType TType, size int) error WriteMapEnd() error WriteListBegin(elemType TType, size int) error WriteListEnd() error WriteSetBegin(elemType TType, size int) error WriteSetEnd() error WriteBool(value bool) error WriteByte(value int8) error WriteI16(value int16) error WriteI32(value int32) error WriteI64(value int64) error WriteDouble(value float64) error WriteString(value string) error WriteBinary(value []byte) error ReadMessageBegin() (name string, typeId TMessageType, seqid int32, err error) ReadMessageEnd() error ReadStructBegin() (name string, err error) ReadStructEnd() error ReadFieldBegin() (name string, typeId TType, id int16, err error) ReadFieldEnd() error ReadMapBegin() (keyType TType, valueType TType, size int, err error) ReadMapEnd() error ReadListBegin() (elemType TType, size int, err error) ReadListEnd() error ReadSetBegin() (elemType TType, size int, err error) ReadSetEnd() error ReadBool() (value bool, err error) ReadByte() (value int8, err error) ReadI16() (value int16, err error) ReadI32() (value int32, err error) ReadI64() (value int64, err error) ReadDouble() (value float64, err error) ReadString() (value string, err error) ReadBinary() (value []byte, err error) Skip(fieldType TType) (err error) Flush() (err error) Transport() TTransport }
type TProtocolException ¶
type TProtocolException interface { TException TypeId() int }
Thrift Protocol exception
func NewTProtocolException ¶
func NewTProtocolException(err error) TProtocolException
func NewTProtocolExceptionWithType ¶
func NewTProtocolExceptionWithType(errType int, err error) TProtocolException
type TProtocolFactory ¶
type TProtocolFactory interface {
GetProtocol(trans TTransport) TProtocol
}
Factory interface for constructing protocol instances.
type TRichTransport ¶
type TRichTransport interface { io.ReadWriter io.ByteReader io.ByteWriter Flusher ReadSizeProvider // contains filtered or unexported methods }
This is "enchanced" transport with extra capabilities. You need to use one of these to construct protocol. Notably, TSocket does not implement this interface, and it is always a mistake to use TSocket directly in protocol.
type TSerializer ¶
type TSerializer struct { Transport *TMemoryBuffer Protocol TProtocol }
func NewTSerializer ¶
func NewTSerializer() *TSerializer
func (*TSerializer) WriteString ¶
func (t *TSerializer) WriteString(msg TStruct) (s string, err error)
type TSimpleJSONProtocol ¶
type TSimpleJSONProtocol struct {
// contains filtered or unexported fields
}
JSON protocol implementation for thrift.
This protocol produces/consumes a simple output format suitable for parsing by scripting languages. It should not be confused with the full-featured TJSONProtocol.
func NewTSimpleJSONProtocol ¶
func NewTSimpleJSONProtocol(t TTransport) *TSimpleJSONProtocol
Constructor
func (*TSimpleJSONProtocol) Flush ¶
func (p *TSimpleJSONProtocol) Flush() (err error)
func (*TSimpleJSONProtocol) OutputBool ¶
func (p *TSimpleJSONProtocol) OutputBool(value bool) error
func (*TSimpleJSONProtocol) OutputElemListBegin ¶
func (p *TSimpleJSONProtocol) OutputElemListBegin(elemType TType, size int) error
func (*TSimpleJSONProtocol) OutputF64 ¶
func (p *TSimpleJSONProtocol) OutputF64(value float64) error
func (*TSimpleJSONProtocol) OutputI64 ¶
func (p *TSimpleJSONProtocol) OutputI64(value int64) error
func (*TSimpleJSONProtocol) OutputListBegin ¶
func (p *TSimpleJSONProtocol) OutputListBegin() error
func (*TSimpleJSONProtocol) OutputListEnd ¶
func (p *TSimpleJSONProtocol) OutputListEnd() error
func (*TSimpleJSONProtocol) OutputNull ¶
func (p *TSimpleJSONProtocol) OutputNull() error
func (*TSimpleJSONProtocol) OutputObjectBegin ¶
func (p *TSimpleJSONProtocol) OutputObjectBegin() error
func (*TSimpleJSONProtocol) OutputObjectEnd ¶
func (p *TSimpleJSONProtocol) OutputObjectEnd() error
func (*TSimpleJSONProtocol) OutputPostValue ¶
func (p *TSimpleJSONProtocol) OutputPostValue() error
func (*TSimpleJSONProtocol) OutputPreValue ¶
func (p *TSimpleJSONProtocol) OutputPreValue() error
func (*TSimpleJSONProtocol) OutputString ¶
func (p *TSimpleJSONProtocol) OutputString(s string) error
func (*TSimpleJSONProtocol) OutputStringData ¶
func (p *TSimpleJSONProtocol) OutputStringData(s string) error
func (*TSimpleJSONProtocol) ParseBase64EncodedBody ¶
func (p *TSimpleJSONProtocol) ParseBase64EncodedBody() ([]byte, error)
func (*TSimpleJSONProtocol) ParseElemListBegin ¶
func (p *TSimpleJSONProtocol) ParseElemListBegin() (elemType TType, size int, e error)
func (*TSimpleJSONProtocol) ParseF64 ¶
func (p *TSimpleJSONProtocol) ParseF64() (float64, bool, error)
func (*TSimpleJSONProtocol) ParseI64 ¶
func (p *TSimpleJSONProtocol) ParseI64() (int64, bool, error)
func (*TSimpleJSONProtocol) ParseListBegin ¶
func (p *TSimpleJSONProtocol) ParseListBegin() (isNull bool, err error)
func (*TSimpleJSONProtocol) ParseListEnd ¶
func (p *TSimpleJSONProtocol) ParseListEnd() error
func (*TSimpleJSONProtocol) ParseObjectEnd ¶
func (p *TSimpleJSONProtocol) ParseObjectEnd() error
func (*TSimpleJSONProtocol) ParseObjectStart ¶
func (p *TSimpleJSONProtocol) ParseObjectStart() (bool, error)
func (*TSimpleJSONProtocol) ParsePostValue ¶
func (p *TSimpleJSONProtocol) ParsePostValue() error
func (*TSimpleJSONProtocol) ParsePreValue ¶
func (p *TSimpleJSONProtocol) ParsePreValue() error
func (*TSimpleJSONProtocol) ParseQuotedStringBody ¶
func (p *TSimpleJSONProtocol) ParseQuotedStringBody() (string, error)
func (*TSimpleJSONProtocol) ParseStringBody ¶
func (p *TSimpleJSONProtocol) ParseStringBody() (string, error)
func (*TSimpleJSONProtocol) ReadBinary ¶
func (p *TSimpleJSONProtocol) ReadBinary() ([]byte, error)
func (*TSimpleJSONProtocol) ReadBool ¶
func (p *TSimpleJSONProtocol) ReadBool() (bool, error)
func (*TSimpleJSONProtocol) ReadByte ¶
func (p *TSimpleJSONProtocol) ReadByte() (int8, error)
func (*TSimpleJSONProtocol) ReadDouble ¶
func (p *TSimpleJSONProtocol) ReadDouble() (float64, error)
func (*TSimpleJSONProtocol) ReadFieldBegin ¶
func (p *TSimpleJSONProtocol) ReadFieldBegin() (string, TType, int16, error)
func (*TSimpleJSONProtocol) ReadFieldEnd ¶
func (p *TSimpleJSONProtocol) ReadFieldEnd() error
func (*TSimpleJSONProtocol) ReadI16 ¶
func (p *TSimpleJSONProtocol) ReadI16() (int16, error)
func (*TSimpleJSONProtocol) ReadI32 ¶
func (p *TSimpleJSONProtocol) ReadI32() (int32, error)
func (*TSimpleJSONProtocol) ReadI64 ¶
func (p *TSimpleJSONProtocol) ReadI64() (int64, error)
func (*TSimpleJSONProtocol) ReadListBegin ¶
func (p *TSimpleJSONProtocol) ReadListBegin() (elemType TType, size int, e error)
func (*TSimpleJSONProtocol) ReadListEnd ¶
func (p *TSimpleJSONProtocol) ReadListEnd() error
func (*TSimpleJSONProtocol) ReadMapBegin ¶
func (p *TSimpleJSONProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, e error)
func (*TSimpleJSONProtocol) ReadMapEnd ¶
func (p *TSimpleJSONProtocol) ReadMapEnd() error
func (*TSimpleJSONProtocol) ReadMessageBegin ¶
func (p *TSimpleJSONProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
Reading methods.
func (*TSimpleJSONProtocol) ReadMessageEnd ¶
func (p *TSimpleJSONProtocol) ReadMessageEnd() error
func (*TSimpleJSONProtocol) ReadSetBegin ¶
func (p *TSimpleJSONProtocol) ReadSetBegin() (elemType TType, size int, e error)
func (*TSimpleJSONProtocol) ReadSetEnd ¶
func (p *TSimpleJSONProtocol) ReadSetEnd() error
func (*TSimpleJSONProtocol) ReadString ¶
func (p *TSimpleJSONProtocol) ReadString() (string, error)
func (*TSimpleJSONProtocol) ReadStructBegin ¶
func (p *TSimpleJSONProtocol) ReadStructBegin() (name string, err error)
func (*TSimpleJSONProtocol) ReadStructEnd ¶
func (p *TSimpleJSONProtocol) ReadStructEnd() error
func (*TSimpleJSONProtocol) Skip ¶
func (p *TSimpleJSONProtocol) Skip(fieldType TType) (err error)
func (*TSimpleJSONProtocol) Transport ¶
func (p *TSimpleJSONProtocol) Transport() TTransport
func (*TSimpleJSONProtocol) WriteBinary ¶
func (p *TSimpleJSONProtocol) WriteBinary(v []byte) error
func (*TSimpleJSONProtocol) WriteBool ¶
func (p *TSimpleJSONProtocol) WriteBool(b bool) error
func (*TSimpleJSONProtocol) WriteByte ¶
func (p *TSimpleJSONProtocol) WriteByte(b int8) error
func (*TSimpleJSONProtocol) WriteDouble ¶
func (p *TSimpleJSONProtocol) WriteDouble(v float64) error
func (*TSimpleJSONProtocol) WriteFieldBegin ¶
func (p *TSimpleJSONProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
func (*TSimpleJSONProtocol) WriteFieldEnd ¶
func (p *TSimpleJSONProtocol) WriteFieldEnd() error
func (*TSimpleJSONProtocol) WriteFieldStop ¶
func (p *TSimpleJSONProtocol) WriteFieldStop() error
func (*TSimpleJSONProtocol) WriteI16 ¶
func (p *TSimpleJSONProtocol) WriteI16(v int16) error
func (*TSimpleJSONProtocol) WriteI32 ¶
func (p *TSimpleJSONProtocol) WriteI32(v int32) error
func (*TSimpleJSONProtocol) WriteI64 ¶
func (p *TSimpleJSONProtocol) WriteI64(v int64) error
func (*TSimpleJSONProtocol) WriteListBegin ¶
func (p *TSimpleJSONProtocol) WriteListBegin(elemType TType, size int) error
func (*TSimpleJSONProtocol) WriteListEnd ¶
func (p *TSimpleJSONProtocol) WriteListEnd() error
func (*TSimpleJSONProtocol) WriteMapBegin ¶
func (p *TSimpleJSONProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
func (*TSimpleJSONProtocol) WriteMapEnd ¶
func (p *TSimpleJSONProtocol) WriteMapEnd() error
func (*TSimpleJSONProtocol) WriteMessageBegin ¶
func (p *TSimpleJSONProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error
func (*TSimpleJSONProtocol) WriteMessageEnd ¶
func (p *TSimpleJSONProtocol) WriteMessageEnd() error
func (*TSimpleJSONProtocol) WriteSetBegin ¶
func (p *TSimpleJSONProtocol) WriteSetBegin(elemType TType, size int) error
func (*TSimpleJSONProtocol) WriteSetEnd ¶
func (p *TSimpleJSONProtocol) WriteSetEnd() error
func (*TSimpleJSONProtocol) WriteString ¶
func (p *TSimpleJSONProtocol) WriteString(v string) error
func (*TSimpleJSONProtocol) WriteStructBegin ¶
func (p *TSimpleJSONProtocol) WriteStructBegin(name string) error
func (*TSimpleJSONProtocol) WriteStructEnd ¶
func (p *TSimpleJSONProtocol) WriteStructEnd() error
type TSimpleJSONProtocolFactory ¶
type TSimpleJSONProtocolFactory struct{}
Factory
func NewTSimpleJSONProtocolFactory ¶
func NewTSimpleJSONProtocolFactory() *TSimpleJSONProtocolFactory
func (*TSimpleJSONProtocolFactory) GetProtocol ¶
func (p *TSimpleJSONProtocolFactory) GetProtocol(trans TTransport) TProtocol
type TTransport ¶
type TTransport interface { io.ReadWriteCloser Flusher ReadSizeProvider // Opens the transport for communication Open() error // Returns true if the transport is open IsOpen() bool }
Encapsulates the I/O layer
type TTransportException ¶
type TTransportException interface { TException TypeId() int Err() error }
Thrift Transport exception
func NewTTransportException ¶
func NewTTransportException(t int, e string) TTransportException
func NewTTransportExceptionFromError ¶
func NewTTransportExceptionFromError(e error) TTransportException
type TTransportFactory ¶
type TTransportFactory interface {
GetTransport(trans TTransport) TTransport
}
Factory class used to create wrapped instance of Transports. This is used primarily in servers, which get Transports from a ServerTransport and then may want to mutate them (i.e. create a BufferedTransport from the underlying base transport)
func NewTTransportFactory ¶
func NewTTransportFactory() TTransportFactory
Source Files ¶
- application_exception.go
- binary_protocol.go
- compact_protocol.go
- exception.go
- memory_buffer.go
- messagetype.go
- numeric.go
- processor.go
- protocol.go
- protocol_exception.go
- protocol_factory.go
- rich_transport.go
- serializer.go
- simple_json_protocol.go
- transport.go
- transport_exception.go
- transport_factory.go
- type.go