...
ActiveGo 1.8Package thrift
Overview ▹
Index ▹
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
BINARY = 18
)
const DEFAULT_MAX_LENGTH = 16384000
const MULTIPLEXED_SEPARATOR = ":"
const (
THRIFT_JSON_PROTOCOL_VERSION = 1
)
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
)
var ANONYMOUS_FIELD *field
var GoUnusedProtection__ int
The maximum recursive depth the skip() function will traverse
var MaxSkipDepth = 1<<31 - 1
func BoolPtr ¶
func BoolPtr(v bool) *bool
func ByteSlicePtr ¶
func ByteSlicePtr(v []byte) *[]byte
func Float32Ptr ¶
func Float32Ptr(v float32) *float32
func Float64Ptr ¶
func Float64Ptr(v float64) *float64
func Int32Ptr ¶
func Int32Ptr(v int32) *int32
func Int64Ptr ¶
func Int64Ptr(v int64) *int64
func IntPtr ¶
func IntPtr(v int) *int
func NewStoredMessageProtocol ¶
func NewStoredMessageProtocol(protocol TProtocol, name string, typeId TMessageType, seqid int32) *storedMessageProtocol
func Skip ¶
func Skip(self TProtocol, fieldType TType, maxDepth int) (err error)
Skips over the next data element from the provided input TProtocol object.
func SkipDefaultDepth ¶
func SkipDefaultDepth(prot TProtocol, typeId TType) (err error)
Skips over the next data element from the provided input TProtocol object.
func StringPtr ¶
func StringPtr(v string) *string
func Uint32Ptr ¶
func Uint32Ptr(v uint32) *uint32
func Uint64Ptr ¶
func Uint64Ptr(v uint64) *uint64
type Flusher ¶
type Flusher interface {
Flush() (err error)
}
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
}
var (
INFINITY Numeric
NEGATIVE_INFINITY Numeric
NAN Numeric
ZERO Numeric
NUMERIC_NULL Numeric
)
func NewNullNumeric ¶
func NewNullNumeric() Numeric
func NewNumericFromDouble ¶
func NewNumericFromDouble(dValue float64) Numeric
func NewNumericFromI32 ¶
func NewNumericFromI32(iValue int32) Numeric
func NewNumericFromI64 ¶
func NewNumericFromI64(iValue int64) Numeric
func NewNumericFromJSONString ¶
func NewNumericFromJSONString(sValue string, isNull bool) Numeric
func NewNumericFromString ¶
func NewNumericFromString(sValue string) Numeric
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) WriteByte ¶
func (r *RichTransport) WriteByte(c byte) error
func (*RichTransport) WriteString ¶
func (r *RichTransport) WriteString(s string) (n int, err error)
type StreamTransport ¶
StreamTransport is a Transport made of an io.Reader and/or an io.Writer
type StreamTransport struct {
io.Reader
io.Writer
// contains filtered or unexported fields
}
func NewStreamTransport ¶
func NewStreamTransport(r io.Reader, w io.Writer) *StreamTransport
func NewStreamTransportR ¶
func NewStreamTransportR(r io.Reader) *StreamTransport
func NewStreamTransportRW ¶
func NewStreamTransportRW(rw io.ReadWriter) *StreamTransport
func NewStreamTransportW ¶
func NewStreamTransportW(w io.Writer) *StreamTransport
func (*StreamTransport) Close ¶
func (p *StreamTransport) Close() error
Closes both the input and output streams.
func (*StreamTransport) Flush ¶
func (p *StreamTransport) Flush() error
Flushes the underlying output stream if not null.
func (*StreamTransport) IsOpen ¶
func (p *StreamTransport) IsOpen() bool
(The streams must already be open at construction time, so this should always return true.)
func (*StreamTransport) Open ¶
func (p *StreamTransport) Open() error
(The streams must already be open. This method does nothing.)
func (*StreamTransport) Read ¶
func (p *StreamTransport) Read(c []byte) (n int, err error)
func (*StreamTransport) ReadByte ¶
func (p *StreamTransport) ReadByte() (c byte, err error)
func (*StreamTransport) Write ¶
func (p *StreamTransport) Write(c []byte) (n int, err error)
func (*StreamTransport) WriteByte ¶
func (p *StreamTransport) WriteByte(c byte) (err error)
func (*StreamTransport) WriteString ¶
func (p *StreamTransport) WriteString(s string) (n int, err error)
type StreamTransportFactory ¶
type StreamTransportFactory struct {
Reader io.Reader
Writer io.Writer
// contains filtered or unexported fields
}
func NewStreamTransportFactory ¶
func NewStreamTransportFactory(reader io.Reader, writer io.Writer, isReadWriter bool) *StreamTransportFactory
func (*StreamTransportFactory) GetTransport ¶
func (p *StreamTransportFactory) GetTransport(trans TTransport) TTransport
type TApplicationException ¶
Application level Thrift exception
type TApplicationException interface {
TException
TypeId() int32
Read(iprot TProtocol) (TApplicationException, error)
Write(oprot TProtocol) error
}
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() (value byte, err 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 byte) 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 TBufferedTransport ¶
type TBufferedTransport struct {
bufio.ReadWriter
// contains filtered or unexported fields
}
func NewTBufferedTransport ¶
func NewTBufferedTransport(trans TTransport, bufferSize int) *TBufferedTransport
func (*TBufferedTransport) Close ¶
func (p *TBufferedTransport) Close() (err error)
func (*TBufferedTransport) Flush ¶
func (p *TBufferedTransport) Flush() error
func (*TBufferedTransport) IsOpen ¶
func (p *TBufferedTransport) IsOpen() bool
func (*TBufferedTransport) Open ¶
func (p *TBufferedTransport) Open() (err error)
type TBufferedTransportFactory ¶
type TBufferedTransportFactory struct {
// contains filtered or unexported fields
}
func NewTBufferedTransportFactory ¶
func NewTBufferedTransportFactory(bufferSize int) *TBufferedTransportFactory
func (*TBufferedTransportFactory) GetTransport ¶
func (p *TBufferedTransportFactory) GetTransport(trans TTransport) TTransport
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() (value byte, err 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 byte) 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 preceeding.
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 TDebugProtocol ¶
type TDebugProtocol struct {
Delegate TProtocol
LogPrefix string
}
func (*TDebugProtocol) Flush ¶
func (tdp *TDebugProtocol) Flush() (err error)
func (*TDebugProtocol) ReadBinary ¶
func (tdp *TDebugProtocol) ReadBinary() (value []byte, err error)
func (*TDebugProtocol) ReadBool ¶
func (tdp *TDebugProtocol) ReadBool() (value bool, err error)
func (*TDebugProtocol) ReadByte ¶
func (tdp *TDebugProtocol) ReadByte() (value byte, err error)
func (*TDebugProtocol) ReadDouble ¶
func (tdp *TDebugProtocol) ReadDouble() (value float64, err error)
func (*TDebugProtocol) ReadFieldBegin ¶
func (tdp *TDebugProtocol) ReadFieldBegin() (name string, typeId TType, id int16, err error)
func (*TDebugProtocol) ReadFieldEnd ¶
func (tdp *TDebugProtocol) ReadFieldEnd() (err error)
func (*TDebugProtocol) ReadI16 ¶
func (tdp *TDebugProtocol) ReadI16() (value int16, err error)
func (*TDebugProtocol) ReadI32 ¶
func (tdp *TDebugProtocol) ReadI32() (value int32, err error)
func (*TDebugProtocol) ReadI64 ¶
func (tdp *TDebugProtocol) ReadI64() (value int64, err error)
func (*TDebugProtocol) ReadListBegin ¶
func (tdp *TDebugProtocol) ReadListBegin() (elemType TType, size int, err error)
func (*TDebugProtocol) ReadListEnd ¶
func (tdp *TDebugProtocol) ReadListEnd() (err error)
func (*TDebugProtocol) ReadMapBegin ¶
func (tdp *TDebugProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, err error)
func (*TDebugProtocol) ReadMapEnd ¶
func (tdp *TDebugProtocol) ReadMapEnd() (err error)
func (*TDebugProtocol) ReadMessageBegin ¶
func (tdp *TDebugProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqid int32, err error)
func (*TDebugProtocol) ReadMessageEnd ¶
func (tdp *TDebugProtocol) ReadMessageEnd() (err error)
func (*TDebugProtocol) ReadSetBegin ¶
func (tdp *TDebugProtocol) ReadSetBegin() (elemType TType, size int, err error)
func (*TDebugProtocol) ReadSetEnd ¶
func (tdp *TDebugProtocol) ReadSetEnd() (err error)
func (*TDebugProtocol) ReadString ¶
func (tdp *TDebugProtocol) ReadString() (value string, err error)
func (*TDebugProtocol) ReadStructBegin ¶
func (tdp *TDebugProtocol) ReadStructBegin() (name string, err error)
func (*TDebugProtocol) ReadStructEnd ¶
func (tdp *TDebugProtocol) ReadStructEnd() (err error)
func (*TDebugProtocol) Skip ¶
func (tdp *TDebugProtocol) Skip(fieldType TType) (err error)
func (*TDebugProtocol) Transport ¶
func (tdp *TDebugProtocol) Transport() TTransport
func (*TDebugProtocol) WriteBinary ¶
func (tdp *TDebugProtocol) WriteBinary(value []byte) error
func (*TDebugProtocol) WriteBool ¶
func (tdp *TDebugProtocol) WriteBool(value bool) error
func (*TDebugProtocol) WriteByte ¶
func (tdp *TDebugProtocol) WriteByte(value byte) error
func (*TDebugProtocol) WriteDouble ¶
func (tdp *TDebugProtocol) WriteDouble(value float64) error
func (*TDebugProtocol) WriteFieldBegin ¶
func (tdp *TDebugProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
func (*TDebugProtocol) WriteFieldEnd ¶
func (tdp *TDebugProtocol) WriteFieldEnd() error
func (*TDebugProtocol) WriteFieldStop ¶
func (tdp *TDebugProtocol) WriteFieldStop() error
func (*TDebugProtocol) WriteI16 ¶
func (tdp *TDebugProtocol) WriteI16(value int16) error
func (*TDebugProtocol) WriteI32 ¶
func (tdp *TDebugProtocol) WriteI32(value int32) error
func (*TDebugProtocol) WriteI64 ¶
func (tdp *TDebugProtocol) WriteI64(value int64) error
func (*TDebugProtocol) WriteListBegin ¶
func (tdp *TDebugProtocol) WriteListBegin(elemType TType, size int) error
func (*TDebugProtocol) WriteListEnd ¶
func (tdp *TDebugProtocol) WriteListEnd() error
func (*TDebugProtocol) WriteMapBegin ¶
func (tdp *TDebugProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
func (*TDebugProtocol) WriteMapEnd ¶
func (tdp *TDebugProtocol) WriteMapEnd() error
func (*TDebugProtocol) WriteMessageBegin ¶
func (tdp *TDebugProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error
func (*TDebugProtocol) WriteMessageEnd ¶
func (tdp *TDebugProtocol) WriteMessageEnd() error
func (*TDebugProtocol) WriteSetBegin ¶
func (tdp *TDebugProtocol) WriteSetBegin(elemType TType, size int) error
func (*TDebugProtocol) WriteSetEnd ¶
func (tdp *TDebugProtocol) WriteSetEnd() error
func (*TDebugProtocol) WriteString ¶
func (tdp *TDebugProtocol) WriteString(value string) error
func (*TDebugProtocol) WriteStructBegin ¶
func (tdp *TDebugProtocol) WriteStructBegin(name string) error
func (*TDebugProtocol) WriteStructEnd ¶
func (tdp *TDebugProtocol) WriteStructEnd() error
type TDebugProtocolFactory ¶
type TDebugProtocolFactory struct {
Underlying TProtocolFactory
LogPrefix string
}
func NewTDebugProtocolFactory ¶
func NewTDebugProtocolFactory(underlying TProtocolFactory, logPrefix string) *TDebugProtocolFactory
func (*TDebugProtocolFactory) GetProtocol ¶
func (t *TDebugProtocolFactory) GetProtocol(trans TTransport) TProtocol
type TDeserializer ¶
type TDeserializer struct {
Transport TTransport
Protocol TProtocol
}
func NewTDeserializer ¶
func NewTDeserializer() *TDeserializer
func (*TDeserializer) Read ¶
func (t *TDeserializer) Read(msg TStruct, b []byte) (err error)
func (*TDeserializer) ReadString ¶
func (t *TDeserializer) ReadString(msg TStruct, s string) (err error)
type TException ¶
Generic Thrift exception
type TException interface {
error
}
type TFramedTransport ¶
type TFramedTransport struct {
// contains filtered or unexported fields
}
func NewTFramedTransport ¶
func NewTFramedTransport(transport TTransport) *TFramedTransport
func NewTFramedTransportMaxLength ¶
func NewTFramedTransportMaxLength(transport TTransport, maxLength int) *TFramedTransport
func (*TFramedTransport) Close ¶
func (p *TFramedTransport) Close() error
func (*TFramedTransport) Flush ¶
func (p *TFramedTransport) Flush() error
func (*TFramedTransport) IsOpen ¶
func (p *TFramedTransport) IsOpen() bool
func (*TFramedTransport) Open ¶
func (p *TFramedTransport) Open() error
func (*TFramedTransport) Read ¶
func (p *TFramedTransport) Read(buf []byte) (l int, err error)
func (*TFramedTransport) ReadByte ¶
func (p *TFramedTransport) ReadByte() (c byte, err error)
func (*TFramedTransport) Write ¶
func (p *TFramedTransport) Write(buf []byte) (int, error)
func (*TFramedTransport) WriteByte ¶
func (p *TFramedTransport) WriteByte(c byte) error
func (*TFramedTransport) WriteString ¶
func (p *TFramedTransport) WriteString(s string) (n int, err error)
type THttpClient ¶
type THttpClient struct {
// contains filtered or unexported fields
}
func (*THttpClient) Close ¶
func (p *THttpClient) Close() error
func (*THttpClient) DelHeader ¶
func (p *THttpClient) DelHeader(key string)
Deletes the HTTP Header given a Header Key for this specific Thrift Transport It is important that you first assert the TTransport as a THttpClient type like so:
httpTrans := trans.(THttpClient) httpTrans.DelHeader("User-Agent")
func (*THttpClient) Flush ¶
func (p *THttpClient) Flush() error
func (*THttpClient) GetHeader ¶
func (p *THttpClient) GetHeader(key string) string
Get the HTTP Header represented by the supplied Header Key for this specific Thrift Transport It is important that you first assert the TTransport as a THttpClient type like so:
httpTrans := trans.(THttpClient) hdrValue := httpTrans.GetHeader("User-Agent")
func (*THttpClient) IsOpen ¶
func (p *THttpClient) IsOpen() bool
func (*THttpClient) Open ¶
func (p *THttpClient) Open() error
func (*THttpClient) Peek ¶
func (p *THttpClient) Peek() bool
func (*THttpClient) Read ¶
func (p *THttpClient) Read(buf []byte) (int, error)
func (*THttpClient) ReadByte ¶
func (p *THttpClient) ReadByte() (c byte, err error)
func (*THttpClient) SetHeader ¶
func (p *THttpClient) SetHeader(key string, value string)
Set the HTTP Header for this specific Thrift Transport It is important that you first assert the TTransport as a THttpClient type like so:
httpTrans := trans.(THttpClient) httpTrans.SetHeader("User-Agent","Thrift Client 1.0")
func (*THttpClient) Write ¶
func (p *THttpClient) Write(buf []byte) (int, error)
func (*THttpClient) WriteByte ¶
func (p *THttpClient) WriteByte(c byte) error
func (*THttpClient) WriteString ¶
func (p *THttpClient) WriteString(s string) (n int, err error)
type THttpClientTransportFactory ¶
type THttpClientTransportFactory struct {
// contains filtered or unexported fields
}
func NewTHttpClientTransportFactory ¶
func NewTHttpClientTransportFactory(url string, timeout time.Duration) *THttpClientTransportFactory
func NewTHttpPostClientTransportFactory ¶
func NewTHttpPostClientTransportFactory(url string, timeout time.Duration) *THttpClientTransportFactory
func (*THttpClientTransportFactory) GetTransport ¶
func (p *THttpClientTransportFactory) GetTransport(trans TTransport) TTransport
type TJSONProtocol ¶
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.
type TJSONProtocol struct {
*TSimpleJSONProtocol
}
func NewTJSONProtocol ¶
func NewTJSONProtocol(t TTransport) *TJSONProtocol
Constructor
func (*TJSONProtocol) Flush ¶
func (p *TJSONProtocol) Flush() (err error)
func (*TJSONProtocol) OutputElemListBegin ¶
func (p *TJSONProtocol) OutputElemListBegin(elemType TType, size int) error
func (*TJSONProtocol) ParseElemListBegin ¶
func (p *TJSONProtocol) ParseElemListBegin() (elemType TType, size int, e error)
func (*TJSONProtocol) ReadBinary ¶
func (p *TJSONProtocol) ReadBinary() ([]byte, error)
func (*TJSONProtocol) ReadBool ¶
func (p *TJSONProtocol) ReadBool() (bool, error)
func (*TJSONProtocol) ReadByte ¶
func (p *TJSONProtocol) ReadByte() (byte, error)
func (*TJSONProtocol) ReadDouble ¶
func (p *TJSONProtocol) ReadDouble() (float64, error)
func (*TJSONProtocol) ReadFieldBegin ¶
func (p *TJSONProtocol) ReadFieldBegin() (string, TType, int16, error)
func (*TJSONProtocol) ReadFieldEnd ¶
func (p *TJSONProtocol) ReadFieldEnd() error
func (*TJSONProtocol) ReadI16 ¶
func (p *TJSONProtocol) ReadI16() (int16, error)
func (*TJSONProtocol) ReadI32 ¶
func (p *TJSONProtocol) ReadI32() (int32, error)
func (*TJSONProtocol) ReadI64 ¶
func (p *TJSONProtocol) ReadI64() (int64, error)
func (*TJSONProtocol) ReadListBegin ¶
func (p *TJSONProtocol) ReadListBegin() (elemType TType, size int, e error)
func (*TJSONProtocol) ReadListEnd ¶
func (p *TJSONProtocol) ReadListEnd() error
func (*TJSONProtocol) ReadMapBegin ¶
func (p *TJSONProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, e error)
func (*TJSONProtocol) ReadMapEnd ¶
func (p *TJSONProtocol) ReadMapEnd() error
func (*TJSONProtocol) ReadMessageBegin ¶
func (p *TJSONProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)
func (*TJSONProtocol) ReadMessageEnd ¶
func (p *TJSONProtocol) ReadMessageEnd() error
func (*TJSONProtocol) ReadSetBegin ¶
func (p *TJSONProtocol) ReadSetBegin() (elemType TType, size int, e error)
func (*TJSONProtocol) ReadSetEnd ¶
func (p *TJSONProtocol) ReadSetEnd() error
func (*TJSONProtocol) ReadString ¶
func (p *TJSONProtocol) ReadString() (string, error)
func (*TJSONProtocol) ReadStructBegin ¶
func (p *TJSONProtocol) ReadStructBegin() (name string, err error)
func (*TJSONProtocol) ReadStructEnd ¶
func (p *TJSONProtocol) ReadStructEnd() error
func (*TJSONProtocol) Skip ¶
func (p *TJSONProtocol) Skip(fieldType TType) (err error)
func (*TJSONProtocol) StringToTypeId ¶
func (p *TJSONProtocol) StringToTypeId(fieldType string) (TType, error)
func (*TJSONProtocol) Transport ¶
func (p *TJSONProtocol) Transport() TTransport
func (*TJSONProtocol) TypeIdToString ¶
func (p *TJSONProtocol) TypeIdToString(fieldType TType) (string, error)
func (*TJSONProtocol) WriteBinary ¶
func (p *TJSONProtocol) WriteBinary(v []byte) error
func (*TJSONProtocol) WriteBool ¶
func (p *TJSONProtocol) WriteBool(b bool) error
func (*TJSONProtocol) WriteByte ¶
func (p *TJSONProtocol) WriteByte(b byte) error
func (*TJSONProtocol) WriteDouble ¶
func (p *TJSONProtocol) WriteDouble(v float64) error
func (*TJSONProtocol) WriteFieldBegin ¶
func (p *TJSONProtocol) WriteFieldBegin(name string, typeId TType, id int16) error
func (*TJSONProtocol) WriteFieldEnd ¶
func (p *TJSONProtocol) WriteFieldEnd() error
func (*TJSONProtocol) WriteFieldStop ¶
func (p *TJSONProtocol) WriteFieldStop() error
func (*TJSONProtocol) WriteI16 ¶
func (p *TJSONProtocol) WriteI16(v int16) error
func (*TJSONProtocol) WriteI32 ¶
func (p *TJSONProtocol) WriteI32(v int32) error
func (*TJSONProtocol) WriteI64 ¶
func (p *TJSONProtocol) WriteI64(v int64) error
func (*TJSONProtocol) WriteListBegin ¶
func (p *TJSONProtocol) WriteListBegin(elemType TType, size int) error
func (*TJSONProtocol) WriteListEnd ¶
func (p *TJSONProtocol) WriteListEnd() error
func (*TJSONProtocol) WriteMapBegin ¶
func (p *TJSONProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error
func (*TJSONProtocol) WriteMapEnd ¶
func (p *TJSONProtocol) WriteMapEnd() error
func (*TJSONProtocol) WriteMessageBegin ¶
func (p *TJSONProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error
func (*TJSONProtocol) WriteMessageEnd ¶
func (p *TJSONProtocol) WriteMessageEnd() error
func (*TJSONProtocol) WriteSetBegin ¶
func (p *TJSONProtocol) WriteSetBegin(elemType TType, size int) error
func (*TJSONProtocol) WriteSetEnd ¶
func (p *TJSONProtocol) WriteSetEnd() error
func (*TJSONProtocol) WriteString ¶
func (p *TJSONProtocol) WriteString(v string) error
func (*TJSONProtocol) WriteStructBegin ¶
func (p *TJSONProtocol) WriteStructBegin(name string) error
func (*TJSONProtocol) WriteStructEnd ¶
func (p *TJSONProtocol) WriteStructEnd() error
type TJSONProtocolFactory ¶
Factory
type TJSONProtocolFactory struct{}
func NewTJSONProtocolFactory ¶
func NewTJSONProtocolFactory() *TJSONProtocolFactory
func (*TJSONProtocolFactory) GetProtocol ¶
func (p *TJSONProtocolFactory) GetProtocol(trans TTransport) TProtocol
type TMemoryBuffer ¶
Memory buffer-based implementation of the TTransport interface.
type TMemoryBuffer struct {
*bytes.Buffer
// contains filtered or unexported fields
}
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) Peek ¶
func (p *TMemoryBuffer) Peek() bool
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 ¶
Message type constants in the Thrift protocol.
type TMessageType int32
const (
INVALID_TMESSAGE_TYPE TMessageType = 0
CALL TMessageType = 1
REPLY TMessageType = 2
EXCEPTION TMessageType = 3
ONEWAY TMessageType = 4
)
type TMultiplexedProcessor ¶
type TMultiplexedProcessor struct {
DefaultProcessor TProcessor
// contains filtered or unexported fields
}
func NewTMultiplexedProcessor ¶
func NewTMultiplexedProcessor() *TMultiplexedProcessor
func (*TMultiplexedProcessor) Process ¶
func (t *TMultiplexedProcessor) Process(in, out TProtocol) (bool, TException)
func (*TMultiplexedProcessor) RegisterDefault ¶
func (t *TMultiplexedProcessor) RegisterDefault(processor TProcessor)
func (*TMultiplexedProcessor) RegisterProcessor ¶
func (t *TMultiplexedProcessor) RegisterProcessor(name string, processor TProcessor)
type TMultiplexedProtocol ¶
type TMultiplexedProtocol struct {
TProtocol
// contains filtered or unexported fields
}
func NewTMultiplexedProtocol ¶
func NewTMultiplexedProtocol(protocol TProtocol, serviceName string) *TMultiplexedProtocol
func (*TMultiplexedProtocol) WriteMessageBegin ¶
func (t *TMultiplexedProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error
type TProcessor ¶
A processor is a generic object which operates upon an input stream and writes to some output stream.
type TProcessor interface {
Process(in, out TProtocol) (bool, TException)
}
type TProcessorFactory ¶
The default processor factory just returns a singleton instance.
type TProcessorFactory interface {
GetProcessor(trans TTransport) TProcessor
}
func NewTProcessorFactory ¶
func NewTProcessorFactory(p TProcessor) TProcessorFactory
type TProcessorFunction ¶
type TProcessorFunction interface {
Process(seqId int32, in, out TProtocol) (bool, TException)
}
type TProcessorFunctionFactory ¶
*
* The default processor factory just returns a singleton * instance.
type TProcessorFunctionFactory interface {
GetProcessorFunction(trans TTransport) TProcessorFunction
}
func NewTProcessorFunctionFactory ¶
func NewTProcessorFunctionFactory(p TProcessorFunction) TProcessorFunctionFactory
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 byte) 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 byte, 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 ¶
Thrift Protocol exception
type TProtocolException interface {
TException
TypeId() int
}
func NewTProtocolException ¶
func NewTProtocolException(err error) TProtocolException
func NewTProtocolExceptionWithType ¶
func NewTProtocolExceptionWithType(errType int, err error) TProtocolException
type TProtocolFactory ¶
Factory interface for constructing protocol instances.
type TProtocolFactory interface {
GetProtocol(trans TTransport) TProtocol
}
type TRichTransport ¶
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 TRichTransport interface {
io.ReadWriter
io.ByteReader
io.ByteWriter
Flusher
// contains filtered or unexported methods
}
type TSSLServerSocket ¶
type TSSLServerSocket struct {
// contains filtered or unexported fields
}
func NewTSSLServerSocket ¶
func NewTSSLServerSocket(listenAddr string, cfg *tls.Config) (*TSSLServerSocket, error)
func NewTSSLServerSocketTimeout ¶
func NewTSSLServerSocketTimeout(listenAddr string, cfg *tls.Config, clientTimeout time.Duration) (*TSSLServerSocket, error)
func (*TSSLServerSocket) Accept ¶
func (p *TSSLServerSocket) Accept() (TTransport, error)
func (*TSSLServerSocket) Addr ¶
func (p *TSSLServerSocket) Addr() net.Addr
func (*TSSLServerSocket) Close ¶
func (p *TSSLServerSocket) Close() error
func (*TSSLServerSocket) Interrupt ¶
func (p *TSSLServerSocket) Interrupt() error
func (*TSSLServerSocket) IsListening ¶
func (p *TSSLServerSocket) IsListening() bool
Checks whether the socket is listening.
func (*TSSLServerSocket) Listen ¶
func (p *TSSLServerSocket) Listen() error
func (*TSSLServerSocket) Open ¶
func (p *TSSLServerSocket) Open() error
Connects the socket, creating a new socket object if necessary.
type TSSLSocket ¶
type TSSLSocket struct {
// contains filtered or unexported fields
}
func NewTSSLSocket ¶
func NewTSSLSocket(hostPort string, cfg *tls.Config) (*TSSLSocket, error)
NewTSSLSocket creates a net.Conn-backed TTransport, given a host and port and tls Configuration
Example:
trans, err := thrift.NewTSocket("localhost:9090")
func NewTSSLSocketFromAddrTimeout ¶
func NewTSSLSocketFromAddrTimeout(addr net.Addr, cfg *tls.Config, timeout time.Duration) *TSSLSocket
Creates a TSSLSocket from a net.Addr
func NewTSSLSocketFromConnTimeout ¶
func NewTSSLSocketFromConnTimeout(conn net.Conn, cfg *tls.Config, timeout time.Duration) *TSSLSocket
Creates a TSSLSocket from an existing net.Conn
func NewTSSLSocketTimeout ¶
func NewTSSLSocketTimeout(hostPort string, cfg *tls.Config, timeout time.Duration) (*TSSLSocket, error)
NewTSSLSocketTimeout creates a net.Conn-backed TTransport, given a host and port it also accepts a tls Configuration and a timeout as a time.Duration
func (*TSSLSocket) Close ¶
func (p *TSSLSocket) Close() error
Closes the socket.
func (*TSSLSocket) Conn ¶
func (p *TSSLSocket) Conn() net.Conn
Retreive the underlying net.Conn
func (*TSSLSocket) Flush ¶
func (p *TSSLSocket) Flush() error
func (*TSSLSocket) Interrupt ¶
func (p *TSSLSocket) Interrupt() error
func (*TSSLSocket) IsOpen ¶
func (p *TSSLSocket) IsOpen() bool
Returns true if the connection is open
func (*TSSLSocket) Open ¶
func (p *TSSLSocket) Open() error
Connects the socket, creating a new socket object if necessary.
func (*TSSLSocket) Peek ¶
func (p *TSSLSocket) Peek() bool
func (*TSSLSocket) Read ¶
func (p *TSSLSocket) Read(buf []byte) (int, error)
func (*TSSLSocket) SetTimeout ¶
func (p *TSSLSocket) SetTimeout(timeout time.Duration) error
Sets the socket timeout
func (*TSSLSocket) Write ¶
func (p *TSSLSocket) Write(buf []byte) (int, error)
type TSerializer ¶
type TSerializer struct {
Transport *TMemoryBuffer
Protocol TProtocol
}
func NewTSerializer ¶
func NewTSerializer() *TSerializer
func (*TSerializer) Write ¶
func (t *TSerializer) Write(msg TStruct) (b []byte, err error)
func (*TSerializer) WriteString ¶
func (t *TSerializer) WriteString(msg TStruct) (s string, err error)
type TServer ¶
type TServer interface {
ProcessorFactory() TProcessorFactory
ServerTransport() TServerTransport
InputTransportFactory() TTransportFactory
OutputTransportFactory() TTransportFactory
InputProtocolFactory() TProtocolFactory
OutputProtocolFactory() TProtocolFactory
// Starts the server
Serve() error
// Stops the server. This is optional on a per-implementation basis. Not
// all servers are required to be cleanly stoppable.
Stop() error
}
type TServerSocket ¶
type TServerSocket struct {
//Size of buffer to use for socket. Defaults to 1024.
//Set to 0 to disable bufferring server transport altogether.
BufferSize int
// contains filtered or unexported fields
}
func NewTServerSocket ¶
func NewTServerSocket(listenAddr string) (*TServerSocket, error)
func NewTServerSocketTimeout ¶
func NewTServerSocketTimeout(listenAddr string, clientTimeout time.Duration) (*TServerSocket, error)
func (*TServerSocket) Accept ¶
func (p *TServerSocket) Accept() (TTransport, error)
func (*TServerSocket) Addr ¶
func (p *TServerSocket) Addr() net.Addr
func (*TServerSocket) Close ¶
func (p *TServerSocket) Close() error
func (*TServerSocket) Interrupt ¶
func (p *TServerSocket) Interrupt() error
func (*TServerSocket) IsListening ¶
func (p *TServerSocket) IsListening() bool
Checks whether the socket is listening.
func (*TServerSocket) Listen ¶
func (p *TServerSocket) Listen() error
func (*TServerSocket) Open ¶
func (p *TServerSocket) Open() error
Connects the socket, creating a new socket object if necessary.
type TServerTransport ¶
Server transport. Object which provides client transports.
type TServerTransport interface {
Listen() error
Accept() (TTransport, error)
Close() error
// Optional method implementation. This signals to the server transport
// that it should break out of any accept() or listen() that it is currently
// blocked on. This method, if implemented, MUST be thread safe, as it may
// be called from a different thread context than the other TServerTransport
// methods.
Interrupt() error
}
type TSimpleJSONProtocol ¶
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.
type TSimpleJSONProtocol struct {
// contains filtered or unexported fields
}
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) 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() (byte, 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)
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 byte) 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 ¶
Factory
type TSimpleJSONProtocolFactory struct{}
func NewTSimpleJSONProtocolFactory ¶
func NewTSimpleJSONProtocolFactory() *TSimpleJSONProtocolFactory
func (*TSimpleJSONProtocolFactory) GetProtocol ¶
func (p *TSimpleJSONProtocolFactory) GetProtocol(trans TTransport) TProtocol
type TSimpleServer ¶
Simple, non-concurrent server for testing.
type TSimpleServer struct {
// contains filtered or unexported fields
}
func NewTSimpleServer2 ¶
func NewTSimpleServer2(processor TProcessor, serverTransport TServerTransport) *TSimpleServer
func NewTSimpleServer4 ¶
func NewTSimpleServer4(processor TProcessor, serverTransport TServerTransport, transportFactory TTransportFactory, protocolFactory TProtocolFactory) *TSimpleServer
func NewTSimpleServer6 ¶
func NewTSimpleServer6(processor TProcessor, serverTransport TServerTransport, inputTransportFactory TTransportFactory, outputTransportFactory TTransportFactory, inputProtocolFactory TProtocolFactory, outputProtocolFactory TProtocolFactory) *TSimpleServer
func NewTSimpleServerFactory2 ¶
func NewTSimpleServerFactory2(processorFactory TProcessorFactory, serverTransport TServerTransport) *TSimpleServer
func NewTSimpleServerFactory4 ¶
func NewTSimpleServerFactory4(processorFactory TProcessorFactory, serverTransport TServerTransport, transportFactory TTransportFactory, protocolFactory TProtocolFactory) *TSimpleServer
func NewTSimpleServerFactory6 ¶
func NewTSimpleServerFactory6(processorFactory TProcessorFactory, serverTransport TServerTransport, inputTransportFactory TTransportFactory, outputTransportFactory TTransportFactory, inputProtocolFactory TProtocolFactory, outputProtocolFactory TProtocolFactory) *TSimpleServer
func (*TSimpleServer) AcceptLoop ¶
func (p *TSimpleServer) AcceptLoop() error
func (*TSimpleServer) InputProtocolFactory ¶
func (p *TSimpleServer) InputProtocolFactory() TProtocolFactory
func (*TSimpleServer) InputTransportFactory ¶
func (p *TSimpleServer) InputTransportFactory() TTransportFactory
func (*TSimpleServer) Listen ¶
func (p *TSimpleServer) Listen() error
func (*TSimpleServer) OutputProtocolFactory ¶
func (p *TSimpleServer) OutputProtocolFactory() TProtocolFactory
func (*TSimpleServer) OutputTransportFactory ¶
func (p *TSimpleServer) OutputTransportFactory() TTransportFactory
func (*TSimpleServer) ProcessorFactory ¶
func (p *TSimpleServer) ProcessorFactory() TProcessorFactory
func (*TSimpleServer) Serve ¶
func (p *TSimpleServer) Serve() error
func (*TSimpleServer) ServerTransport ¶
func (p *TSimpleServer) ServerTransport() TServerTransport
func (*TSimpleServer) Stop ¶
func (p *TSimpleServer) Stop() error
type TSocket ¶
type TSocket struct {
// contains filtered or unexported fields
}
func NewTSocket ¶
func NewTSocket(hostPort string) (*TSocket, error)
NewTSocket creates a net.Conn-backed TTransport, given a host and port
Example:
trans, err := thrift.NewTSocket("localhost:9090")
func NewTSocketFromAddrTimeout ¶
func NewTSocketFromAddrTimeout(addr net.Addr, timeout time.Duration) *TSocket
Creates a TSocket from a net.Addr
func NewTSocketFromConnTimeout ¶
func NewTSocketFromConnTimeout(conn net.Conn, timeout time.Duration) *TSocket
Creates a TSocket from an existing net.Conn
func NewTSocketTimeout ¶
func NewTSocketTimeout(hostPort string, timeout time.Duration) (*TSocket, error)
NewTSocketTimeout creates a net.Conn-backed TTransport, given a host and port it also accepts a timeout as a time.Duration
func (*TSocket) Close ¶
func (p *TSocket) Close() error
Closes the socket.
func (*TSocket) Conn ¶
func (p *TSocket) Conn() net.Conn
Retreive the underlying net.Conn
func (*TSocket) Flush ¶
func (p *TSocket) Flush() error
func (*TSocket) Interrupt ¶
func (p *TSocket) Interrupt() error
func (*TSocket) IsOpen ¶
func (p *TSocket) IsOpen() bool
Returns true if the connection is open
func (*TSocket) Open ¶
func (p *TSocket) Open() error
Connects the socket, creating a new socket object if necessary.
func (*TSocket) Peek ¶
func (p *TSocket) Peek() bool
func (*TSocket) Read ¶
func (p *TSocket) Read(buf []byte) (int, error)
func (*TSocket) SetTimeout ¶
func (p *TSocket) SetTimeout(timeout time.Duration) error
Sets the socket timeout
func (*TSocket) Write ¶
func (p *TSocket) Write(buf []byte) (int, error)
type TStruct ¶
type TStruct interface {
Write(p TProtocol) error
Read(p TProtocol) error
}
type TTransport ¶
Encapsulates the I/O layer
type TTransport interface {
io.ReadWriteCloser
Flusher
// Opens the transport for communication
Open() error
// Returns true if the transport is open
IsOpen() bool
}
func NewTHttpClient ¶
func NewTHttpClient(urlstr string, timeout time.Duration) (TTransport, error)
func NewTHttpPostClient ¶
func NewTHttpPostClient(urlstr string, timeout time.Duration) (TTransport, error)
type TTransportException ¶
Thrift Transport exception
type TTransportException interface {
TException
TypeId() int
Err() error
}
func NewTTransportException ¶
func NewTTransportException(t int, e string) TTransportException
func NewTTransportExceptionFromError ¶
func NewTTransportExceptionFromError(e error) TTransportException
type TTransportFactory ¶
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)
type TTransportFactory interface {
GetTransport(trans TTransport) TTransport
}
func NewTFramedTransportFactory ¶
func NewTFramedTransportFactory(factory TTransportFactory) TTransportFactory
func NewTTransportFactory ¶
func NewTTransportFactory() TTransportFactory
type TType ¶
Type constants in the Thrift protocol
type TType byte
func (TType) String ¶
func (p TType) String() string
type TestEnum ¶
type TestEnum int64
const (
TestEnum_FIRST TestEnum = 1
TestEnum_SECOND TestEnum = 2
TestEnum_THIRD TestEnum = 3
TestEnum_FOURTH TestEnum = 4
)
func TestEnumFromString ¶
func TestEnumFromString(s string) (TestEnum, error)
func TestEnumPtr ¶
func TestEnumPtr(v TestEnum) *TestEnum
func (TestEnum) String ¶
func (p TestEnum) String() string
type TestStruct ¶
type TestStruct struct {
On bool `thrift:"on,1"`
B int8 `thrift:"b,2"`
Int16 int16 `thrift:"int16,3"`
Int32 int32 `thrift:"int32,4"`
Int64 int64 `thrift:"int64,5"`
D float64 `thrift:"d,6"`
St string `thrift:"st,7"`
Bin []byte `thrift:"bin,8"`
StringMap map[string]string `thrift:"stringMap,9"`
StringList []string `thrift:"stringList,10"`
StringSet map[string]bool `thrift:"stringSet,11"`
E TestEnum `thrift:"e,12"`
}
func NewTestStruct ¶
func NewTestStruct() *TestStruct
func (*TestStruct) Read ¶
func (p *TestStruct) Read(iprot TProtocol) error
func (*TestStruct) String ¶
func (p *TestStruct) String() string
func (*TestStruct) Write ¶
func (p *TestStruct) Write(oprot TProtocol) error