thrift

package

Go to main page

Versions in this module

v0

v0.31.0

Aug 24, 2015

v0.30.0

Aug 17, 2015

v0.29.0

Aug 5, 2015

v0.28.0

Jun 24, 2015

v0.27.0

Jun 11, 2015

v0.26.0

May 29, 2015

Changes in this version

+ const COMPACT_TYPE_BITS

+ const DEFAULT_MAX_LENGTH

+ const DEPTH_LIMIT

+ const MULTIPLEXED_SEPARATOR

+ var GoUnusedProtection__ int

+ func BoolPtr(v bool) *bool

+ func ByteSlicePtr(v []byte) *[]byte

+ func Float32Ptr(v float32) *float32

+ func Float64Ptr(v float64) *float64

+ func Int32Ptr(v int32) *int32

+ func Int64Ptr(v int64) *int64

+ func IntPtr(v int) *int

+ func NewStoredMessageProtocol(protocol TProtocol, name string, typeId TMessageType, seqid int32) *storedMessageProtocol

+ func PrependError(prepend string, err error) error

+ func StringPtr(v string) *string

+ func Uint32Ptr(v uint32) *uint32

+ func Uint64Ptr(v uint64) *uint64

+ type RichTransport struct

+ func NewTRichTransport(trans TTransport) *RichTransport

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

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

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

type StreamTransport

+ func (p *StreamTransport) ReadByte() (c byte, err error)

+ func (p *StreamTransport) WriteByte(c byte) (err error)

+ func (p *StreamTransport) WriteString(s string) (n int, err error)

+ type TDebugProtocol struct

+ Delegate TProtocol

+ LogPrefix string

+ func (tdp *TDebugProtocol) Flush() (err error)

+ func (tdp *TDebugProtocol) ReadBinary() (value []byte, err error)

+ func (tdp *TDebugProtocol) ReadBool() (value bool, err error)

+ func (tdp *TDebugProtocol) ReadByte() (value byte, err error)

+ func (tdp *TDebugProtocol) ReadDouble() (value float64, err error)

+ func (tdp *TDebugProtocol) ReadFieldBegin() (name string, typeId TType, id int16, err error)

+ func (tdp *TDebugProtocol) ReadFieldEnd() (err error)

+ func (tdp *TDebugProtocol) ReadI16() (value int16, err error)

+ func (tdp *TDebugProtocol) ReadI32() (value int32, err error)

+ func (tdp *TDebugProtocol) ReadI64() (value int64, err error)

+ func (tdp *TDebugProtocol) ReadListBegin() (elemType TType, size int, err error)

+ func (tdp *TDebugProtocol) ReadListEnd() (err error)

+ func (tdp *TDebugProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, err error)

+ func (tdp *TDebugProtocol) ReadMapEnd() (err error)

+ func (tdp *TDebugProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqid int32, err error)

+ func (tdp *TDebugProtocol) ReadMessageEnd() (err error)

+ func (tdp *TDebugProtocol) ReadSetBegin() (elemType TType, size int, err error)

+ func (tdp *TDebugProtocol) ReadSetEnd() (err error)

+ func (tdp *TDebugProtocol) ReadString() (value string, err error)

+ func (tdp *TDebugProtocol) ReadStructBegin() (name string, err error)

+ func (tdp *TDebugProtocol) ReadStructEnd() (err error)

+ func (tdp *TDebugProtocol) Skip(fieldType TType) (err error)

+ func (tdp *TDebugProtocol) Transport() TTransport

+ func (tdp *TDebugProtocol) WriteBinary(value []byte) error

+ func (tdp *TDebugProtocol) WriteBool(value bool) error

+ func (tdp *TDebugProtocol) WriteByte(value byte) error

+ func (tdp *TDebugProtocol) WriteDouble(value float64) error

+ func (tdp *TDebugProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (tdp *TDebugProtocol) WriteFieldEnd() error

+ func (tdp *TDebugProtocol) WriteFieldStop() error

+ func (tdp *TDebugProtocol) WriteI16(value int16) error

+ func (tdp *TDebugProtocol) WriteI32(value int32) error

+ func (tdp *TDebugProtocol) WriteI64(value int64) error

+ func (tdp *TDebugProtocol) WriteListBegin(elemType TType, size int) error

+ func (tdp *TDebugProtocol) WriteListEnd() error

+ func (tdp *TDebugProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error

+ func (tdp *TDebugProtocol) WriteMapEnd() error

+ func (tdp *TDebugProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error

+ func (tdp *TDebugProtocol) WriteMessageEnd() error

+ func (tdp *TDebugProtocol) WriteSetBegin(elemType TType, size int) error

+ func (tdp *TDebugProtocol) WriteSetEnd() error

+ func (tdp *TDebugProtocol) WriteString(value string) error

+ func (tdp *TDebugProtocol) WriteStructBegin(name string) error

+ func (tdp *TDebugProtocol) WriteStructEnd() error

+ type TDebugProtocolFactory struct

+ LogPrefix string

+ Underlying TProtocolFactory

+ func NewTDebugProtocolFactory(underlying TProtocolFactory, logPrefix string) *TDebugProtocolFactory

+ func (t *TDebugProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TDeserializer struct

+ Protocol TProtocol

+ Transport TTransport

+ func NewTDeserializer() *TDeserializer

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

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

type TFramedTransport

+ func NewTFramedTransportMaxLength(transport TTransport, maxLength int) *TFramedTransport

+ func (p *TFramedTransport) ReadByte() (c byte, err error)

+ func (p *TFramedTransport) WriteByte(c byte) error

+ func (p *TFramedTransport) WriteString(s string) (n int, err error)

type THttpClient

+ func (p *THttpClient) DelHeader(key string)

+ func (p *THttpClient) GetHeader(key string) string

+ func (p *THttpClient) ReadByte() (c byte, err error)

+ func (p *THttpClient) SetHeader(key string, value string)

+ func (p *THttpClient) WriteByte(c byte) error

+ func (p *THttpClient) WriteString(s string) (n int, err error)

+ type TMultiplexedProcessor struct

+ DefaultProcessor TProcessor

+ func NewTMultiplexedProcessor() *TMultiplexedProcessor

+ func (t *TMultiplexedProcessor) Process(in, out TProtocol) (bool, TException)

+ func (t *TMultiplexedProcessor) RegisterDefault(processor TProcessor)

+ func (t *TMultiplexedProcessor) RegisterProcessor(name string, processor TProcessor)

+ type TMultiplexedProtocol struct

+ func NewTMultiplexedProtocol(protocol TProtocol, serviceName string) *TMultiplexedProtocol

+ func (t *TMultiplexedProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error

+ type TRichTransport interface

+ type TSSLServerSocket struct

+ func NewTSSLServerSocket(listenAddr string, cfg *tls.Config) (*TSSLServerSocket, error)

+ func NewTSSLServerSocketTimeout(listenAddr string, cfg *tls.Config, clientTimeout time.Duration) (*TSSLServerSocket, error)

+ func (p *TSSLServerSocket) Accept() (TTransport, error)

+ func (p *TSSLServerSocket) Addr() net.Addr

+ func (p *TSSLServerSocket) Close() error

+ func (p *TSSLServerSocket) Interrupt() error

+ func (p *TSSLServerSocket) IsListening() bool

+ func (p *TSSLServerSocket) Listen() error

+ func (p *TSSLServerSocket) Open() error

+ type TSSLSocket struct

+ func NewTSSLSocket(hostPort string, cfg *tls.Config) (*TSSLSocket, error)

+ func NewTSSLSocketFromAddrTimeout(addr net.Addr, cfg *tls.Config, timeout time.Duration) *TSSLSocket

+ func NewTSSLSocketFromConnTimeout(conn net.Conn, cfg *tls.Config, timeout time.Duration) *TSSLSocket

+ func NewTSSLSocketTimeout(hostPort string, cfg *tls.Config, timeout time.Duration) (*TSSLSocket, error)

+ func (p *TSSLSocket) Close() error

+ func (p *TSSLSocket) Conn() net.Conn

+ func (p *TSSLSocket) Flush() error

+ func (p *TSSLSocket) Interrupt() error

+ func (p *TSSLSocket) IsOpen() bool

+ func (p *TSSLSocket) Open() error

+ func (p *TSSLSocket) Read(buf []byte) (int, error)

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

+ func (p *TSSLSocket) Write(buf []byte) (int, error)

+ type TSerializer struct

+ Protocol TProtocol

+ Transport *TMemoryBuffer

+ func NewTSerializer() *TSerializer

+ func (t *TSerializer) Write(msg TStruct) (b []byte, err error)

+ func (t *TSerializer) WriteString(msg TStruct) (s string, err error)

type TSimpleServer

+ func (p *TSimpleServer) AcceptLoop() error

+ func (p *TSimpleServer) Listen() error

type TSocket

+ func (p *TSocket) Addr() net.Addr

+ type TStruct interface

+ Read func(p TProtocol) error

+ Write func(p TProtocol) error

type TTransportException

+ Err func() error

+ type TestEnum int64

+ const TestEnum_FIRST

+ const TestEnum_FOURTH

+ const TestEnum_SECOND

+ const TestEnum_THIRD

+ func TestEnumFromString(s string) (TestEnum, error)

+ func TestEnumPtr(v TestEnum) *TestEnum

+ func (p TestEnum) String() string

+ type TestStruct struct

+ B int8

+ Bin []byte

+ D float64

+ E TestEnum

+ Int16 int16

+ Int32 int32

+ Int64 int64

+ On bool

+ St string

+ StringList []string

+ StringMap map[string]string

+ StringSet map[string]bool

+ func NewTestStruct() *TestStruct

+ func (p *TestStruct) GetB() int8

+ func (p *TestStruct) GetBin() []byte

+ func (p *TestStruct) GetD() float64

+ func (p *TestStruct) GetE() TestEnum

+ func (p *TestStruct) GetInt16() int16

+ func (p *TestStruct) GetInt32() int32

+ func (p *TestStruct) GetInt64() int64

+ func (p *TestStruct) GetOn() bool

+ func (p *TestStruct) GetSt() string

+ func (p *TestStruct) GetStringList() []string

+ func (p *TestStruct) GetStringMap() map[string]string

+ func (p *TestStruct) GetStringSet() map[string]bool

+ func (p *TestStruct) Read(iprot TProtocol) error

+ func (p *TestStruct) ReadField1(iprot TProtocol) error

+ func (p *TestStruct) ReadField10(iprot TProtocol) error

+ func (p *TestStruct) ReadField11(iprot TProtocol) error

+ func (p *TestStruct) ReadField12(iprot TProtocol) error

+ func (p *TestStruct) ReadField2(iprot TProtocol) error

+ func (p *TestStruct) ReadField3(iprot TProtocol) error

+ func (p *TestStruct) ReadField4(iprot TProtocol) error

+ func (p *TestStruct) ReadField5(iprot TProtocol) error

+ func (p *TestStruct) ReadField6(iprot TProtocol) error

+ func (p *TestStruct) ReadField7(iprot TProtocol) error

+ func (p *TestStruct) ReadField8(iprot TProtocol) error

+ func (p *TestStruct) ReadField9(iprot TProtocol) error

+ func (p *TestStruct) String() string

+ func (p *TestStruct) Write(oprot TProtocol) error

v0.25.0

Apr 29, 2015

v0.24.0

Mar 26, 2015

v0.20.0

Feb 4, 2015

Changes in this version

+ const ALREADY_OPEN

+ const BAD_SEQUENCE_ID

+ const BAD_VERSION

+ const BINARY

+ const BOOL

+ const BYTE

+ const COMPACT_BINARY

+ const COMPACT_BOOLEAN_FALSE

+ const COMPACT_BOOLEAN_TRUE

+ const COMPACT_BYTE

+ const COMPACT_DOUBLE

+ const COMPACT_I16

+ const COMPACT_I32

+ const COMPACT_I64

+ const COMPACT_LIST

+ const COMPACT_MAP

+ const COMPACT_PROTOCOL_ID

+ const COMPACT_SET

+ const COMPACT_STRUCT

+ const COMPACT_TYPE_MASK

+ const COMPACT_TYPE_SHIFT_AMOUNT

+ const COMPACT_VERSION

+ const COMPACT_VERSION_MASK

+ const DOUBLE

+ const END_OF_FILE

+ const I08

+ const I16

+ const I32

+ const I64

+ const INTERNAL_ERROR

+ const INVALID_DATA

+ const INVALID_MESSAGE_TYPE_EXCEPTION

+ const LIST

+ const MAP

+ const MISSING_RESULT

+ const NEGATIVE_SIZE

+ const NOT_IMPLEMENTED

+ const NOT_OPEN

+ const PROTOCOL_ERROR

+ const SET

+ const SIZE_LIMIT

+ const STOP

+ const STRING

+ const STRUCT

+ const THRIFT_JSON_PROTOCOL_VERSION

+ const TIMED_OUT

+ const UNKNOWN_APPLICATION_EXCEPTION

+ const UNKNOWN_METHOD

+ const UNKNOWN_PROTOCOL_EXCEPTION

+ const UNKNOWN_TRANSPORT_EXCEPTION

+ const UTF16

+ const UTF7

+ const UTF8

+ const VERSION_1

+ const VERSION_MASK

+ const VOID

+ const WRONG_METHOD_NAME

+ var ANONYMOUS_FIELD *field

+ var JSON_COLON []byte

+ var JSON_COMMA []byte

+ var JSON_FALSE []byte

+ var JSON_INFINITY string

+ var JSON_INFINITY_BYTES []byte

+ var JSON_LBRACE []byte

+ var JSON_LBRACKET []byte

+ var JSON_NAN string

+ var JSON_NAN_BYTES []byte

+ var JSON_NEGATIVE_INFINITY string

+ var JSON_NEGATIVE_INFINITY_BYTES []byte

+ var JSON_NULL []byte

+ var JSON_QUOTE byte

+ var JSON_QUOTE_BYTES []byte

+ var JSON_RBRACE []byte

+ var JSON_RBRACKET []byte

+ var JSON_TRUE []byte

+ var MaxSkipDepth = 1<<31 - 1

+ func Skip(self TProtocol, fieldType TType, maxDepth int) (err error)

+ func SkipDefaultDepth(prot TProtocol, typeId TType) (err error)

+ type Flusher interface

+ Flush func() (err error)

+ type Numeric interface

+ Byte func() byte

+ Float32 func() float32

+ Float64 func() float64

+ Int func() int

+ Int16 func() int16

+ Int32 func() int32

+ Int64 func() int64

+ String func() string

+ var INFINITY Numeric

+ var NAN Numeric

+ var NEGATIVE_INFINITY Numeric

+ var NUMERIC_NULL Numeric

+ var ZERO Numeric

+ func NewNullNumeric() Numeric

+ func NewNumericFromDouble(dValue float64) Numeric

+ func NewNumericFromI32(iValue int32) Numeric

+ func NewNumericFromI64(iValue int64) Numeric

+ func NewNumericFromJSONString(sValue string, isNull bool) Numeric

+ func NewNumericFromString(sValue string) Numeric

+ type StreamTransport struct

+ Reader io.Reader

+ Writer io.Writer

+ func NewStreamTransport(r io.Reader, w io.Writer) *StreamTransport

+ func NewStreamTransportR(r io.Reader) *StreamTransport

+ func NewStreamTransportRW(rw io.ReadWriter) *StreamTransport

+ func NewStreamTransportW(w io.Writer) *StreamTransport

+ func (p *StreamTransport) Close() error

+ func (p *StreamTransport) Flush() error

+ func (p *StreamTransport) IsOpen() bool

+ func (p *StreamTransport) Open() error

+ func (p *StreamTransport) Peek() bool

+ func (p *StreamTransport) Read(buf []byte) (int, error)

+ func (p *StreamTransport) Write(buf []byte) (int, error)

+ type StreamTransportFactory struct

+ Reader io.Reader

+ Writer io.Writer

+ func NewStreamTransportFactory(reader io.Reader, writer io.Writer, isReadWriter bool) *StreamTransportFactory

+ func (p *StreamTransportFactory) GetTransport(trans TTransport) TTransport

+ type TApplicationException interface

+ Read func(iprot TProtocol) (TApplicationException, error)

+ TypeId func() int32

+ Write func(oprot TProtocol) error

+ func NewTApplicationException(type_ int32, message string) TApplicationException

+ type TBinaryProtocol struct

+ func NewTBinaryProtocol(t TTransport, strictRead, strictWrite bool) *TBinaryProtocol

+ func NewTBinaryProtocolTransport(t TTransport) *TBinaryProtocol

+ func (p *TBinaryProtocol) Flush() (err error)

+ func (p *TBinaryProtocol) ReadBinary() ([]byte, error)

+ func (p *TBinaryProtocol) ReadBool() (bool, error)

+ func (p *TBinaryProtocol) ReadByte() (value byte, err 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 byte) error

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

+ func (p *TBinaryProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TBinaryProtocol) WriteFieldEnd() error

+ func (p *TBinaryProtocol) WriteFieldStop() error

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

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

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

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

+ func (p *TBinaryProtocol) WriteListEnd() error

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

+ func (p *TBinaryProtocol) WriteMapEnd() error

+ func (p *TBinaryProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error

+ func (p *TBinaryProtocol) WriteMessageEnd() error

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

+ func (p *TBinaryProtocol) WriteSetEnd() error

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

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

+ func (p *TBinaryProtocol) WriteStructEnd() error

+ type TBinaryProtocolFactory struct

+ func NewTBinaryProtocolFactory(strictRead, strictWrite bool) *TBinaryProtocolFactory

+ func NewTBinaryProtocolFactoryDefault() *TBinaryProtocolFactory

+ func (p *TBinaryProtocolFactory) GetProtocol(t TTransport) TProtocol

+ type TBuffer struct

+ type TBufferedTransport struct

+ func NewTBufferedTransport(trans TTransport, bufferSize int) *TBufferedTransport

+ func (p *TBufferedTransport) Close() (err error)

+ func (p *TBufferedTransport) Flush() error

+ func (p *TBufferedTransport) IsOpen() bool

+ func (p *TBufferedTransport) Open() (err error)

+ func (p *TBufferedTransport) Peek() bool

+ func (p *TBufferedTransport) Read(buf []byte) (n int, err error)

+ func (p *TBufferedTransport) Write(buf []byte) (n int, err error)

+ type TBufferedTransportFactory struct

+ func NewTBufferedTransportFactory(bufferSize int) *TBufferedTransportFactory

+ func (p *TBufferedTransportFactory) GetTransport(trans TTransport) TTransport

+ type TCompactProtocol struct

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

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

+ func (p *TCompactProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TCompactProtocol) WriteFieldEnd() error

+ func (p *TCompactProtocol) WriteFieldStop() error

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

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

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

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

+ func (p *TCompactProtocol) WriteListEnd() error

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

+ func (p *TCompactProtocol) WriteMapEnd() error

+ func (p *TCompactProtocol) WriteMessageBegin(name string, typeId TMessageType, seqid int32) error

+ func (p *TCompactProtocol) WriteMessageEnd() error

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

+ func (p *TCompactProtocol) WriteSetEnd() error

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

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

+ func (p *TCompactProtocol) WriteStructEnd() error

+ type TCompactProtocolFactory struct

+ func NewTCompactProtocolFactory() *TCompactProtocolFactory

+ func (p *TCompactProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TException interface

+ type TFramedTransport struct

+ func NewTFramedTransport(transport TTransport) *TFramedTransport

+ func (p *TFramedTransport) Close() error

+ func (p *TFramedTransport) Flush() error

+ func (p *TFramedTransport) IsOpen() bool

+ func (p *TFramedTransport) Open() error

+ func (p *TFramedTransport) Peek() bool

+ func (p *TFramedTransport) Read(buf []byte) (int, error)

+ func (p *TFramedTransport) Write(buf []byte) (int, error)

+ type THttpClient struct

+ func (p *THttpClient) Close() error

+ func (p *THttpClient) Flush() error

+ func (p *THttpClient) IsOpen() bool

+ func (p *THttpClient) Open() error

+ func (p *THttpClient) Peek() bool

+ func (p *THttpClient) Read(buf []byte) (int, error)

+ func (p *THttpClient) Write(buf []byte) (int, error)

+ type THttpClientTransportFactory struct

+ func NewTHttpClientTransportFactory(url string) *THttpClientTransportFactory

+ func NewTHttpPostClientTransportFactory(url string) *THttpClientTransportFactory

+ func (p *THttpClientTransportFactory) GetTransport(trans TTransport) TTransport

+ type TJSONProtocol struct

+ func NewTJSONProtocol(t TTransport) *TJSONProtocol

+ func (p *TJSONProtocol) Flush() (err error)

+ func (p *TJSONProtocol) OutputElemListBegin(elemType TType, size int) error

+ func (p *TJSONProtocol) ParseElemListBegin() (elemType TType, size int, e error)

+ func (p *TJSONProtocol) ReadBinary() ([]byte, error)

+ func (p *TJSONProtocol) ReadBool() (bool, error)

+ func (p *TJSONProtocol) ReadByte() (byte, error)

+ func (p *TJSONProtocol) ReadDouble() (float64, error)

+ func (p *TJSONProtocol) ReadFieldBegin() (string, TType, int16, error)

+ func (p *TJSONProtocol) ReadFieldEnd() error

+ func (p *TJSONProtocol) ReadI16() (int16, error)

+ func (p *TJSONProtocol) ReadI32() (int32, error)

+ func (p *TJSONProtocol) ReadI64() (int64, error)

+ func (p *TJSONProtocol) ReadListBegin() (elemType TType, size int, e error)

+ func (p *TJSONProtocol) ReadListEnd() error

+ func (p *TJSONProtocol) ReadMapBegin() (keyType TType, valueType TType, size int, e error)

+ func (p *TJSONProtocol) ReadMapEnd() error

+ func (p *TJSONProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error)

+ func (p *TJSONProtocol) ReadMessageEnd() error

+ func (p *TJSONProtocol) ReadSetBegin() (elemType TType, size int, e error)

+ func (p *TJSONProtocol) ReadSetEnd() error

+ func (p *TJSONProtocol) ReadString() (string, error)

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

+ func (p *TJSONProtocol) ReadStructEnd() error

+ func (p *TJSONProtocol) Skip(fieldType TType) (err error)

+ func (p *TJSONProtocol) StringToTypeId(fieldType string) TType

+ func (p *TJSONProtocol) Transport() TTransport

+ func (p *TJSONProtocol) TypeIdToString(fieldType TType) string

+ func (p *TJSONProtocol) WriteBinary(v []byte) error

+ func (p *TJSONProtocol) WriteBool(b bool) error

+ func (p *TJSONProtocol) WriteByte(b byte) error

+ func (p *TJSONProtocol) WriteDouble(v float64) error

+ func (p *TJSONProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TJSONProtocol) WriteFieldEnd() error

+ func (p *TJSONProtocol) WriteFieldStop() error

+ func (p *TJSONProtocol) WriteI16(v int16) error

+ func (p *TJSONProtocol) WriteI32(v int32) error

+ func (p *TJSONProtocol) WriteI64(v int64) error

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

+ func (p *TJSONProtocol) WriteListEnd() error

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

+ func (p *TJSONProtocol) WriteMapEnd() error

+ func (p *TJSONProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error

+ func (p *TJSONProtocol) WriteMessageEnd() error

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

+ func (p *TJSONProtocol) WriteSetEnd() error

+ func (p *TJSONProtocol) WriteString(v string) error

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

+ func (p *TJSONProtocol) WriteStructEnd() error

+ type TJSONProtocolFactory struct

+ func NewTJSONProtocolFactory() *TJSONProtocolFactory

+ func (p *TJSONProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TMemoryBuffer struct

+ func NewTMemoryBuffer() *TMemoryBuffer

+ func NewTMemoryBufferLen(size int) *TMemoryBuffer

+ func (p *TMemoryBuffer) Close() error

+ func (p *TMemoryBuffer) Flush() error

+ func (p *TMemoryBuffer) IsOpen() bool

+ func (p *TMemoryBuffer) Open() error

+ func (p *TMemoryBuffer) Peek() bool

+ type TMemoryBufferTransportFactory struct

+ func NewTMemoryBufferTransportFactory(size int) *TMemoryBufferTransportFactory

+ func (p *TMemoryBufferTransportFactory) GetTransport(trans TTransport) TTransport

+ type TMessageType int32

+ const CALL

+ const EXCEPTION

+ const INVALID_TMESSAGE_TYPE

+ const ONEWAY

+ const REPLY

+ type TProcessor interface

+ Process func(in, out TProtocol) (bool, TException)

+ type TProcessorFactory interface

+ GetProcessor func(trans TTransport) TProcessor

+ func NewTProcessorFactory(p TProcessor) TProcessorFactory

+ type TProcessorFunction interface

+ Process func(seqId int32, in, out TProtocol) (bool, TException)

+ type TProcessorFunctionFactory interface

+ GetProcessorFunction func(trans TTransport) TProcessorFunction

+ func NewTProcessorFunctionFactory(p TProcessorFunction) TProcessorFunctionFactory

+ type TProtocol interface

+ Flush func() (err error)

+ ReadBinary func() (value []byte, err error)

+ ReadBool func() (value bool, err error)

+ ReadByte func() (value byte, err error)

+ ReadDouble func() (value float64, err error)

+ ReadFieldBegin func() (name string, typeId TType, id int16, err error)

+ ReadFieldEnd func() error

+ ReadI16 func() (value int16, err error)

+ ReadI32 func() (value int32, err error)

+ ReadI64 func() (value int64, err error)

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

+ ReadListEnd func() error

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

+ ReadMapEnd func() error

+ ReadMessageBegin func() (name string, typeId TMessageType, seqid int32, err error)

+ ReadMessageEnd func() error

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

+ ReadSetEnd func() error

+ ReadString func() (value string, err error)

+ ReadStructBegin func() (name string, err error)

+ ReadStructEnd func() error

+ Skip func(fieldType TType) (err error)

+ Transport func() TTransport

+ WriteBinary func(value []byte) error

+ WriteBool func(value bool) error

+ WriteByte func(value byte) error

+ WriteDouble func(value float64) error

+ WriteFieldBegin func(name string, typeId TType, id int16) error

+ WriteFieldEnd func() error

+ WriteFieldStop func() error

+ WriteI16 func(value int16) error

+ WriteI32 func(value int32) error

+ WriteI64 func(value int64) error

+ WriteListBegin func(elemType TType, size int) error

+ WriteListEnd func() error

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

+ WriteMapEnd func() error

+ WriteMessageBegin func(name string, typeId TMessageType, seqid int32) error

+ WriteMessageEnd func() error

+ WriteSetBegin func(elemType TType, size int) error

+ WriteSetEnd func() error

+ WriteString func(value string) error

+ WriteStructBegin func(name string) error

+ WriteStructEnd func() error

+ type TProtocolException interface

+ TypeId func() int

+ func NewTProtocolException(err error) TProtocolException

+ func NewTProtocolExceptionWithType(errType int, err error) TProtocolException

+ type TProtocolFactory interface

+ GetProtocol func(trans TTransport) TProtocol

+ type TServer interface

+ InputProtocolFactory func() TProtocolFactory

+ InputTransportFactory func() TTransportFactory

+ OutputProtocolFactory func() TProtocolFactory

+ OutputTransportFactory func() TTransportFactory

+ ProcessorFactory func() TProcessorFactory

+ Serve func() error

+ ServerTransport func() TServerTransport

+ Stop func() error

+ type TServerSocket struct

+ func NewTServerSocket(listenAddr string) (*TServerSocket, error)

+ func NewTServerSocketTimeout(listenAddr string, clientTimeout time.Duration) (*TServerSocket, error)

+ func (p *TServerSocket) Accept() (TTransport, error)

+ func (p *TServerSocket) Addr() net.Addr

+ func (p *TServerSocket) Close() error

+ func (p *TServerSocket) Interrupt() error

+ func (p *TServerSocket) IsListening() bool

+ func (p *TServerSocket) Listen() error

+ func (p *TServerSocket) Open() error

+ type TServerTransport interface

+ Accept func() (TTransport, error)

+ Close func() error

+ Interrupt func() error

+ Listen func() error

+ type TSimpleJSONProtocol struct

+ func NewTSimpleJSONProtocol(t TTransport) *TSimpleJSONProtocol

+ func (p *TSimpleJSONProtocol) Flush() (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() (byte, 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 byte) error

+ func (p *TSimpleJSONProtocol) WriteDouble(v float64) error

+ func (p *TSimpleJSONProtocol) WriteFieldBegin(name string, typeId TType, id int16) error

+ func (p *TSimpleJSONProtocol) WriteFieldEnd() error

+ func (p *TSimpleJSONProtocol) WriteFieldStop() error

+ func (p *TSimpleJSONProtocol) WriteI16(v int16) error

+ func (p *TSimpleJSONProtocol) WriteI32(v int32) error

+ func (p *TSimpleJSONProtocol) WriteI64(v int64) error

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

+ func (p *TSimpleJSONProtocol) WriteListEnd() error

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

+ func (p *TSimpleJSONProtocol) WriteMapEnd() error

+ func (p *TSimpleJSONProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error

+ func (p *TSimpleJSONProtocol) WriteMessageEnd() error

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

+ func (p *TSimpleJSONProtocol) WriteSetEnd() error

+ func (p *TSimpleJSONProtocol) WriteString(v string) error

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

+ func (p *TSimpleJSONProtocol) WriteStructEnd() error

+ type TSimpleJSONProtocolFactory struct

+ func NewTSimpleJSONProtocolFactory() *TSimpleJSONProtocolFactory

+ func (p *TSimpleJSONProtocolFactory) GetProtocol(trans TTransport) TProtocol

+ type TSimpleServer struct

+ func NewTSimpleServer2(processor TProcessor, serverTransport TServerTransport) *TSimpleServer

+ func NewTSimpleServer4(processor TProcessor, serverTransport TServerTransport, ...) *TSimpleServer

+ func NewTSimpleServer6(processor TProcessor, serverTransport TServerTransport, ...) *TSimpleServer

+ func NewTSimpleServerFactory2(processorFactory TProcessorFactory, serverTransport TServerTransport) *TSimpleServer

+ func NewTSimpleServerFactory4(processorFactory TProcessorFactory, serverTransport TServerTransport, ...) *TSimpleServer

+ func NewTSimpleServerFactory6(processorFactory TProcessorFactory, serverTransport TServerTransport, ...) *TSimpleServer

+ func (p *TSimpleServer) InputProtocolFactory() TProtocolFactory

+ func (p *TSimpleServer) InputTransportFactory() TTransportFactory

+ func (p *TSimpleServer) OutputProtocolFactory() TProtocolFactory

+ func (p *TSimpleServer) OutputTransportFactory() TTransportFactory

+ func (p *TSimpleServer) ProcessorFactory() TProcessorFactory

+ func (p *TSimpleServer) Serve() error

+ func (p *TSimpleServer) ServerTransport() TServerTransport

+ func (p *TSimpleServer) Stop() error

+ type TSocket struct

+ func NewTSocket(hostPort string) (*TSocket, error)

+ func NewTSocketFromAddrTimeout(addr net.Addr, timeout time.Duration) *TSocket

+ func NewTSocketFromConnTimeout(conn net.Conn, timeout time.Duration) *TSocket

+ func NewTSocketTimeout(hostPort string, timeout time.Duration) (*TSocket, error)

+ func (p *TSocket) Close() error

+ func (p *TSocket) Conn() net.Conn

+ func (p *TSocket) Flush() error

+ func (p *TSocket) Interrupt() error

+ func (p *TSocket) IsOpen() bool

+ func (p *TSocket) Open() error

+ func (p *TSocket) Peek() bool

+ func (p *TSocket) Read(buf []byte) (int, error)

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

+ func (p *TSocket) Write(buf []byte) (int, error)

+ type TTransport interface

+ IsOpen func() bool

+ Open func() error

+ Peek func() bool

+ func NewTHttpClient(urlstr string) (TTransport, error)

+ func NewTHttpPostClient(urlstr string) (TTransport, error)

+ type TTransportException interface

+ TypeId func() int

+ func NewTTransportException(t int, m string) TTransportException

+ func NewTTransportExceptionFromError(e error) TTransportException

+ type TTransportFactory interface

+ GetTransport func(trans TTransport) TTransport

+ func NewTFramedTransportFactory(factory TTransportFactory) TTransportFactory

+ func NewTTransportFactory() TTransportFactory

+ type TType byte

+ func (p TType) String() string

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