thrift

package module
v2.0.0-...-e0f8636 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 14, 2020 License: Apache-2.0, BSD-3-Clause Imports: 26 Imported by: 1

Documentation

Index

Constants

View Source 
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
	INVALID_TRANSFORM              = 8
	INVALID_PROTOCOL               = 9
	UNSUPPORTED_CLIENT_TYPE        = 10
)
View Source 
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
)
View Source 
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
)
View Source 
const (
	THeaderHeaderMagic  uint32 = 0x0fff0000
	THeaderHeaderMask   uint32 = 0xffff0000
	THeaderFlagsMask    uint32 = 0x0000ffff
	THeaderMaxFrameSize uint32 = 0x3fffffff
)

Constants defined in THeader format: https://github.com/apache/thrift/blob/master/doc/specs/HeaderFormat.md

View Source 
const (
	VERSION_MASK = 0xffff0000
	VERSION_1    = 0x80010000
)
View Source 
const (
	UNKNOWN_PROTOCOL_EXCEPTION = 0
	INVALID_DATA               = 1
	NEGATIVE_SIZE              = 2
	SIZE_LIMIT                 = 3
	BAD_VERSION                = 4
	NOT_IMPLEMENTED            = 5
	DEPTH_LIMIT                = 6
)
View Source 
const (
	UNKNOWN_TRANSPORT_EXCEPTION = 0
	NOT_OPEN                    = 1
	ALREADY_OPEN                = 2
	TIMED_OUT                   = 3
	END_OF_FILE                 = 4
)
View Source 
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
)
View Source 
const DEFAULT_MAX_LENGTH = 16384000
View Source 
const DEFAULT_RECURSION_DEPTH = 64

The maximum recursive depth the skip() function will traverse

View Source 
const MULTIPLEXED_SEPARATOR = ":"
View Source 
const (
	THRIFT_JSON_PROTOCOL_VERSION = 1
)

Variables

View Source 
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
)
View Source 
var DefaultHttpClient *http.Client = http.DefaultClient

Default to using the shared http client. Library users are free to change this global client or specify one through THttpClientOptions.

View Source 
var ErrAbandonRequest = errors.New("request abandoned")

ErrAbandonRequest is a special error server handler implementations can return to indicate that the request has been abandoned.

TSimpleServer will check for this error, and close the client connection instead of writing the response/error back to the client.

It shall only be used when the server handler implementation know that the client already abandoned the request (by checking that the passed in context is already canceled, for example).

View Source 
var ServerConnectivityCheckInterval = time.Millisecond * 5

ServerConnectivityCheckInterval defines the ticker interval used by connectivity check in thrift compiled TProcessorFunc implementations.

It's defined as a variable instead of constant, so that thrift server implementations can change its value to control the behavior.

If it's changed to <=0, the feature will be disabled.

Functions

func AddReadTHeaderToContext 

func AddReadTHeaderToContext(ctx context.Context, headers THeaderMap) context.Context

AddReadTHeaderToContext adds the whole THeader headers into context.

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 GetHeader 

func GetHeader(ctx context.Context, key string) (value string, ok bool)

GetHeader returns a value of the given header from the context.

func GetReadHeaderList 

func GetReadHeaderList(ctx context.Context) []string

GetReadHeaderList returns the key list of read THeaders from the context.

func GetWriteHeaderList 

func GetWriteHeaderList(ctx context.Context) []string

GetWriteHeaderList returns the key list of THeaders to write from the context.

func Int16Ptr 

func Int16Ptr(v int16) *int16

func Int32Ptr 

func Int32Ptr(v int32) *int32

func Int64Ptr 

func Int64Ptr(v int64) *int64

func Int8Ptr 

func Int8Ptr(v int8) *int8

func IntPtr 

func IntPtr(v int) *int

func NewStoredMessageProtocol 

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

func NewThriftHandlerFunc 

func NewThriftHandlerFunc(processor TProcessor,
	inPfactory, outPfactory TProtocolFactory) func(w http.ResponseWriter, r *http.Request)

NewThriftHandlerFunc is a function that create a ready to use Apache Thrift Handler function

func NewTransformWriter 

func NewTransformWriter(baseWriter io.Writer, transforms []THeaderTransformID) (io.WriteCloser, error)

NewTransformWriter creates a new TransformWriter with base writer and transforms.

func NopLogger 

func NopLogger(msg string)

NopLogger is a Logger implementation that does nothing.

func PrependError 

func PrependError(prepend string, err error) error

Prepends additional information to an error without losing the Thrift exception interface

func SetHeader 

func SetHeader(ctx context.Context, key, value string) context.Context

SetHeader sets a header in the context.

func SetReadHeaderList 

func SetReadHeaderList(ctx context.Context, keys []string) context.Context

SetReadHeaderList sets the key list of read THeaders in the context.

func SetResponseHelper 

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

SetResponseHelper injects TResponseHelper into the context object.

func SetWriteHeaderList 

func SetWriteHeaderList(ctx context.Context, keys []string) context.Context

SetWriteHeaderList sets the key list of THeaders to write in the context.

func Skip 

func Skip(ctx context.Context, self TProtocol, fieldType TType, maxDepth int) (err error)

Skips over the next data element from the provided input TProtocol object.

func SkipDefaultDepth 

func SkipDefaultDepth(ctx context.Context, 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

func UnsetHeader 

func UnsetHeader(ctx context.Context, key string) context.Context

UnsetHeader unsets a previously set header in the context.

Types

type ClientMiddleware 

type ClientMiddleware func(TClient) TClient

ClientMiddleware can be passed to WrapClient in order to wrap TClient calls with custom middleware.

type ContextFlusher 

type ContextFlusher interface {
	Flush(ctx context.Context) (err error)
}

type Flusher 

type Flusher interface {
	Flush() (err error)
}

type Logger 

type Logger func(msg string)

Logger is a simple wrapper of a logging function.

In reality the users might actually use different logging libraries, and they are not always compatible with each other.

Logger is meant to be a simple common ground that it's easy to wrap whatever logging library they use into.

See https://issues.apache.org/jira/browse/THRIFT-4985 for the design discussion behind it.

func StdLogger 

func StdLogger(logger *log.Logger) Logger

StdLogger wraps stdlib log package into a Logger.

If logger passed in is nil, it will fallback to use stderr and default flags.

func TestLogger 

func TestLogger(tb testing.TB) Logger

TestLogger is a Logger implementation can be used in test codes.

It fails the test when being called.

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 ProcessorMiddleware 

type ProcessorMiddleware func(name string, next TProcessorFunction) TProcessorFunction

ProcessorMiddleware is a function that can be passed to WrapProcessor to wrap the TProcessorFunctions for that TProcessor.

Middlewares are passed in the name of the function as set in the processor map of the TProcessor.

type ReadSizeProvider 

type ReadSizeProvider interface {
	RemainingBytes() (num_bytes uint64)
}

type RichTransport 

type RichTransport struct {
	TTransport
}

func NewTRichTransport 

func NewTRichTransport(trans TTransport) *RichTransport

Wraps Transport to provide TRichTransport interface

func (*RichTransport) ReadByte 

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

func (*RichTransport) RemainingBytes 

func (r *RichTransport) RemainingBytes() (num_bytes uint64)

func (*RichTransport) WriteByte 

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

func (*RichTransport) WriteString 

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

type StreamTransport 

type StreamTransport struct {
	io.Reader
	io.Writer
	// contains filtered or unexported fields
}

StreamTransport is a Transport made of an io.Reader and/or an io.Writer

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(ctx context.Context) error

Flushes the underlying output stream if not null.

func (*StreamTransport) IsOpen 

func (p *StreamTransport) IsOpen() bool

func (*StreamTransport) Open 

func (p *StreamTransport) Open() error

implicitly opened on creation, can't be reopened once closed

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) RemainingBytes 

func (p *StreamTransport) RemainingBytes() (num_bytes uint64)

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, error)

type TApplicationException 

type TApplicationException interface {
	TException
	TypeId() int32
	Read(ctx context.Context, iprot TProtocol) error
	Write(ctx context.Context, oprot TProtocol) error
}

Application level Thrift exception

func NewTApplicationException 

func NewTApplicationException(type_ int32, message string) TApplicationException

type TBinaryProtocol 

type TBinaryProtocol struct {
	// contains filtered or unexported fields
}

func NewTBinaryProtocol 

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

func NewTBinaryProtocolTransport 

func NewTBinaryProtocolTransport(t TTransport) *TBinaryProtocol

func (*TBinaryProtocol) Flush 

func (p *TBinaryProtocol) Flush(ctx context.Context) (err error)

func (*TBinaryProtocol) ReadBinary 

func (p *TBinaryProtocol) ReadBinary(ctx context.Context) ([]byte, error)

func (*TBinaryProtocol) ReadBool 

func (p *TBinaryProtocol) ReadBool(ctx context.Context) (bool, error)

func (*TBinaryProtocol) ReadByte 

func (p *TBinaryProtocol) ReadByte(ctx context.Context) (int8, error)

func (*TBinaryProtocol) ReadDouble 

func (p *TBinaryProtocol) ReadDouble(ctx context.Context) (value float64, err error)

func (*TBinaryProtocol) ReadFieldBegin 

func (p *TBinaryProtocol) ReadFieldBegin(ctx context.Context) (name string, typeId TType, seqId int16, err error)

func (*TBinaryProtocol) ReadFieldEnd 

func (p *TBinaryProtocol) ReadFieldEnd(ctx context.Context) error

func (*TBinaryProtocol) ReadI16 

func (p *TBinaryProtocol) ReadI16(ctx context.Context) (value int16, err error)

func (*TBinaryProtocol) ReadI32 

func (p *TBinaryProtocol) ReadI32(ctx context.Context) (value int32, err error)

func (*TBinaryProtocol) ReadI64 

func (p *TBinaryProtocol) ReadI64(ctx context.Context) (value int64, err error)

func (*TBinaryProtocol) ReadListBegin 

func (p *TBinaryProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

func (*TBinaryProtocol) ReadListEnd 

func (p *TBinaryProtocol) ReadListEnd(ctx context.Context) error

func (*TBinaryProtocol) ReadMapBegin 

func (p *TBinaryProtocol) ReadMapBegin(ctx context.Context) (kType, vType TType, size int, err error)

func (*TBinaryProtocol) ReadMapEnd 

func (p *TBinaryProtocol) ReadMapEnd(ctx context.Context) error

func (*TBinaryProtocol) ReadMessageBegin 

func (p *TBinaryProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error)

func (*TBinaryProtocol) ReadMessageEnd 

func (p *TBinaryProtocol) ReadMessageEnd(ctx context.Context) error

func (*TBinaryProtocol) ReadSetBegin 

func (p *TBinaryProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

func (*TBinaryProtocol) ReadSetEnd 

func (p *TBinaryProtocol) ReadSetEnd(ctx context.Context) error

func (*TBinaryProtocol) ReadString 

func (p *TBinaryProtocol) ReadString(ctx context.Context) (value string, err error)

func (*TBinaryProtocol) ReadStructBegin 

func (p *TBinaryProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

func (*TBinaryProtocol) ReadStructEnd 

func (p *TBinaryProtocol) ReadStructEnd(ctx context.Context) error

func (*TBinaryProtocol) Skip 

func (p *TBinaryProtocol) Skip(ctx context.Context, fieldType TType) (err error)

func (*TBinaryProtocol) Transport 

func (p *TBinaryProtocol) Transport() TTransport

func (*TBinaryProtocol) WriteBinary 

func (p *TBinaryProtocol) WriteBinary(ctx context.Context, value []byte) error

func (*TBinaryProtocol) WriteBool 

func (p *TBinaryProtocol) WriteBool(ctx context.Context, value bool) error

func (*TBinaryProtocol) WriteByte 

func (p *TBinaryProtocol) WriteByte(ctx context.Context, value int8) error

func (*TBinaryProtocol) WriteDouble 

func (p *TBinaryProtocol) WriteDouble(ctx context.Context, value float64) error

func (*TBinaryProtocol) WriteFieldBegin 

func (p *TBinaryProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error

func (*TBinaryProtocol) WriteFieldEnd 

func (p *TBinaryProtocol) WriteFieldEnd(ctx context.Context) error

func (*TBinaryProtocol) WriteFieldStop 

func (p *TBinaryProtocol) WriteFieldStop(ctx context.Context) error

func (*TBinaryProtocol) WriteI16 

func (p *TBinaryProtocol) WriteI16(ctx context.Context, value int16) error

func (*TBinaryProtocol) WriteI32 

func (p *TBinaryProtocol) WriteI32(ctx context.Context, value int32) error

func (*TBinaryProtocol) WriteI64 

func (p *TBinaryProtocol) WriteI64(ctx context.Context, value int64) error

func (*TBinaryProtocol) WriteListBegin 

func (p *TBinaryProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

func (*TBinaryProtocol) WriteListEnd 

func (p *TBinaryProtocol) WriteListEnd(ctx context.Context) error

func (*TBinaryProtocol) WriteMapBegin 

func (p *TBinaryProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

func (*TBinaryProtocol) WriteMapEnd 

func (p *TBinaryProtocol) WriteMapEnd(ctx context.Context) error

func (*TBinaryProtocol) WriteMessageBegin 

func (p *TBinaryProtocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error

func (*TBinaryProtocol) WriteMessageEnd 

func (p *TBinaryProtocol) WriteMessageEnd(ctx context.Context) error

func (*TBinaryProtocol) WriteSetBegin 

func (p *TBinaryProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

func (*TBinaryProtocol) WriteSetEnd 

func (p *TBinaryProtocol) WriteSetEnd(ctx context.Context) error

func (*TBinaryProtocol) WriteString 

func (p *TBinaryProtocol) WriteString(ctx context.Context, value string) error

func (*TBinaryProtocol) WriteStructBegin 

func (p *TBinaryProtocol) WriteStructBegin(ctx context.Context, name string) error

func (*TBinaryProtocol) WriteStructEnd 

func (p *TBinaryProtocol) WriteStructEnd(ctx context.Context) 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(ctx context.Context) error

func (*TBufferedTransport) IsOpen 

func (p *TBufferedTransport) IsOpen() bool

func (*TBufferedTransport) Open 

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

func (*TBufferedTransport) Read 

func (p *TBufferedTransport) Read(b []byte) (int, error)

func (*TBufferedTransport) RemainingBytes 

func (p *TBufferedTransport) RemainingBytes() (num_bytes uint64)

func (*TBufferedTransport) Write 

func (p *TBufferedTransport) Write(b []byte) (int, 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, error)

type TClient 

type TClient interface {
	Call(ctx context.Context, method string, args, result TStruct) error
}

func WrapClient 

func WrapClient(client TClient, middlewares ...ClientMiddleware) TClient

WrapClient wraps the given TClient in the given middlewares.

Middlewares will be called in the order that they are defined:

  1. Middlewares[0]
  2. Middlewares[1] ... N. Middlewares[n]

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(ctx context.Context) (err error)

func (*TCompactProtocol) ReadBinary 

func (p *TCompactProtocol) ReadBinary(ctx context.Context) (value []byte, err error)

Read a []byte from the wire.

func (*TCompactProtocol) ReadBool 

func (p *TCompactProtocol) ReadBool(ctx context.Context) (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(ctx context.Context) (int8, error)

Read a single byte off the wire. Nothing interesting here.

func (*TCompactProtocol) ReadDouble 

func (p *TCompactProtocol) ReadDouble(ctx context.Context) (value float64, err error)

No magic here - just read a double off the wire.

func (*TCompactProtocol) ReadFieldBegin 

func (p *TCompactProtocol) ReadFieldBegin(ctx context.Context) (name string, typeId TType, id int16, err error)

Read a field header off the wire.

func (*TCompactProtocol) ReadFieldEnd 

func (p *TCompactProtocol) ReadFieldEnd(ctx context.Context) error

func (*TCompactProtocol) ReadI16 

func (p *TCompactProtocol) ReadI16(ctx context.Context) (value int16, err error)

Read an i16 from the wire as a zigzag varint.

func (*TCompactProtocol) ReadI32 

func (p *TCompactProtocol) ReadI32(ctx context.Context) (value int32, err error)

Read an i32 from the wire as a zigzag varint.

func (*TCompactProtocol) ReadI64 

func (p *TCompactProtocol) ReadI64(ctx context.Context) (value int64, err error)

Read an i64 from the wire as a zigzag varint.

func (*TCompactProtocol) ReadListBegin 

func (p *TCompactProtocol) ReadListBegin(ctx context.Context) (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(ctx context.Context) error

func (*TCompactProtocol) ReadMapBegin 

func (p *TCompactProtocol) ReadMapBegin(ctx context.Context) (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(ctx context.Context) error

func (*TCompactProtocol) ReadMessageBegin 

func (p *TCompactProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error)

Read a message header.

func (*TCompactProtocol) ReadMessageEnd 

func (p *TCompactProtocol) ReadMessageEnd(ctx context.Context) error

func (*TCompactProtocol) ReadSetBegin 

func (p *TCompactProtocol) ReadSetBegin(ctx context.Context) (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(ctx context.Context) error

func (*TCompactProtocol) ReadString 

func (p *TCompactProtocol) ReadString(ctx context.Context) (value string, err error)

Reads a []byte (via readBinary), and then UTF-8 decodes it.

func (*TCompactProtocol) ReadStructBegin 

func (p *TCompactProtocol) ReadStructBegin(ctx context.Context) (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(ctx context.Context) 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(ctx context.Context, fieldType TType) (err error)

func (*TCompactProtocol) Transport 

func (p *TCompactProtocol) Transport() TTransport

func (*TCompactProtocol) WriteBinary 

func (p *TCompactProtocol) WriteBinary(ctx context.Context, bin []byte) error

Write a byte array, using a varint for the size.

func (*TCompactProtocol) WriteBool 

func (p *TCompactProtocol) WriteBool(ctx context.Context, value bool) error

func (*TCompactProtocol) WriteByte 

func (p *TCompactProtocol) WriteByte(ctx context.Context, value int8) error

Write a byte. Nothing to see here!

func (*TCompactProtocol) WriteDouble 

func (p *TCompactProtocol) WriteDouble(ctx context.Context, value float64) error

Write a double to the wire as 8 bytes.

func (*TCompactProtocol) WriteFieldBegin 

func (p *TCompactProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error

func (*TCompactProtocol) WriteFieldEnd 

func (p *TCompactProtocol) WriteFieldEnd(ctx context.Context) error

func (*TCompactProtocol) WriteFieldStop 

func (p *TCompactProtocol) WriteFieldStop(ctx context.Context) error

func (*TCompactProtocol) WriteI16 

func (p *TCompactProtocol) WriteI16(ctx context.Context, value int16) error

Write an I16 as a zigzag varint.

func (*TCompactProtocol) WriteI32 

func (p *TCompactProtocol) WriteI32(ctx context.Context, value int32) error

Write an i32 as a zigzag varint.

func (*TCompactProtocol) WriteI64 

func (p *TCompactProtocol) WriteI64(ctx context.Context, value int64) error

Write an i64 as a zigzag varint.

func (*TCompactProtocol) WriteListBegin 

func (p *TCompactProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

Write a list header.

func (*TCompactProtocol) WriteListEnd 

func (p *TCompactProtocol) WriteListEnd(ctx context.Context) error

func (*TCompactProtocol) WriteMapBegin 

func (p *TCompactProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

func (*TCompactProtocol) WriteMapEnd 

func (p *TCompactProtocol) WriteMapEnd(ctx context.Context) error

func (*TCompactProtocol) WriteMessageBegin 

func (p *TCompactProtocol) WriteMessageBegin(ctx context.Context, 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(ctx context.Context) error

func (*TCompactProtocol) WriteSetBegin 

func (p *TCompactProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

Write a set header.

func (*TCompactProtocol) WriteSetEnd 

func (p *TCompactProtocol) WriteSetEnd(ctx context.Context) error

func (*TCompactProtocol) WriteString 

func (p *TCompactProtocol) WriteString(ctx context.Context, value string) error

Write a string to the wire with a varint size preceding.

func (*TCompactProtocol) WriteStructBegin 

func (p *TCompactProtocol) WriteStructBegin(ctx context.Context, 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(ctx context.Context) 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 {
	// Required. The actual TProtocol to do the read/write.
	Delegate TProtocol

	// Optional. The logger and prefix to log all the args/return values
	// from Delegate TProtocol calls.
	//
	// If Logger is nil, StdLogger using stdlib log package with os.Stderr
	// will be used. If disable logging is desired, set Logger to NopLogger
	// explicitly instead of leaving it as nil/unset.
	Logger    Logger
	LogPrefix string

	// Optional. An TProtocol to duplicate everything read/written from Delegate.
	//
	// A typical use case of this is to use TSimpleJSONProtocol wrapping
	// TMemoryBuffer in a middleware to json logging requests/responses.
	//
	// This feature is not available from TDebugProtocolFactory. In order to
	// use it you have to construct TDebugProtocol directly, or set DuplicateTo
	// field after getting a TDebugProtocol from the factory.
	DuplicateTo TProtocol
}

func (*TDebugProtocol) Flush 

func (tdp *TDebugProtocol) Flush(ctx context.Context) (err error)

func (*TDebugProtocol) ReadBinary 

func (tdp *TDebugProtocol) ReadBinary(ctx context.Context) (value []byte, err error)

func (*TDebugProtocol) ReadBool 

func (tdp *TDebugProtocol) ReadBool(ctx context.Context) (value bool, err error)

func (*TDebugProtocol) ReadByte 

func (tdp *TDebugProtocol) ReadByte(ctx context.Context) (value int8, err error)

func (*TDebugProtocol) ReadDouble 

func (tdp *TDebugProtocol) ReadDouble(ctx context.Context) (value float64, err error)

func (*TDebugProtocol) ReadFieldBegin 

func (tdp *TDebugProtocol) ReadFieldBegin(ctx context.Context) (name string, typeId TType, id int16, err error)

func (*TDebugProtocol) ReadFieldEnd 

func (tdp *TDebugProtocol) ReadFieldEnd(ctx context.Context) (err error)

func (*TDebugProtocol) ReadI16 

func (tdp *TDebugProtocol) ReadI16(ctx context.Context) (value int16, err error)

func (*TDebugProtocol) ReadI32 

func (tdp *TDebugProtocol) ReadI32(ctx context.Context) (value int32, err error)

func (*TDebugProtocol) ReadI64 

func (tdp *TDebugProtocol) ReadI64(ctx context.Context) (value int64, err error)

func (*TDebugProtocol) ReadListBegin 

func (tdp *TDebugProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

func (*TDebugProtocol) ReadListEnd 

func (tdp *TDebugProtocol) ReadListEnd(ctx context.Context) (err error)

func (*TDebugProtocol) ReadMapBegin 

func (tdp *TDebugProtocol) ReadMapBegin(ctx context.Context) (keyType TType, valueType TType, size int, err error)

func (*TDebugProtocol) ReadMapEnd 

func (tdp *TDebugProtocol) ReadMapEnd(ctx context.Context) (err error)

func (*TDebugProtocol) ReadMessageBegin 

func (tdp *TDebugProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqid int32, err error)

func (*TDebugProtocol) ReadMessageEnd 

func (tdp *TDebugProtocol) ReadMessageEnd(ctx context.Context) (err error)

func (*TDebugProtocol) ReadSetBegin 

func (tdp *TDebugProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

func (*TDebugProtocol) ReadSetEnd 

func (tdp *TDebugProtocol) ReadSetEnd(ctx context.Context) (err error)

func (*TDebugProtocol) ReadString 

func (tdp *TDebugProtocol) ReadString(ctx context.Context) (value string, err error)

func (*TDebugProtocol) ReadStructBegin 

func (tdp *TDebugProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

func (*TDebugProtocol) ReadStructEnd 

func (tdp *TDebugProtocol) ReadStructEnd(ctx context.Context) (err error)

func (*TDebugProtocol) Skip 

func (tdp *TDebugProtocol) Skip(ctx context.Context, fieldType TType) (err error)

func (*TDebugProtocol) Transport 

func (tdp *TDebugProtocol) Transport() TTransport

func (*TDebugProtocol) WriteBinary 

func (tdp *TDebugProtocol) WriteBinary(ctx context.Context, value []byte) error

func (*TDebugProtocol) WriteBool 

func (tdp *TDebugProtocol) WriteBool(ctx context.Context, value bool) error

func (*TDebugProtocol) WriteByte 

func (tdp *TDebugProtocol) WriteByte(ctx context.Context, value int8) error

func (*TDebugProtocol) WriteDouble 

func (tdp *TDebugProtocol) WriteDouble(ctx context.Context, value float64) error

func (*TDebugProtocol) WriteFieldBegin 

func (tdp *TDebugProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error

func (*TDebugProtocol) WriteFieldEnd 

func (tdp *TDebugProtocol) WriteFieldEnd(ctx context.Context) error

func (*TDebugProtocol) WriteFieldStop 

func (tdp *TDebugProtocol) WriteFieldStop(ctx context.Context) error

func (*TDebugProtocol) WriteI16 

func (tdp *TDebugProtocol) WriteI16(ctx context.Context, value int16) error

func (*TDebugProtocol) WriteI32 

func (tdp *TDebugProtocol) WriteI32(ctx context.Context, value int32) error

func (*TDebugProtocol) WriteI64 

func (tdp *TDebugProtocol) WriteI64(ctx context.Context, value int64) error

func (*TDebugProtocol) WriteListBegin 

func (tdp *TDebugProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

func (*TDebugProtocol) WriteListEnd 

func (tdp *TDebugProtocol) WriteListEnd(ctx context.Context) error

func (*TDebugProtocol) WriteMapBegin 

func (tdp *TDebugProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

func (*TDebugProtocol) WriteMapEnd 

func (tdp *TDebugProtocol) WriteMapEnd(ctx context.Context) error

func (*TDebugProtocol) WriteMessageBegin 

func (tdp *TDebugProtocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqid int32) error

func (*TDebugProtocol) WriteMessageEnd 

func (tdp *TDebugProtocol) WriteMessageEnd(ctx context.Context) error

func (*TDebugProtocol) WriteSetBegin 

func (tdp *TDebugProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

func (*TDebugProtocol) WriteSetEnd 

func (tdp *TDebugProtocol) WriteSetEnd(ctx context.Context) error

func (*TDebugProtocol) WriteString 

func (tdp *TDebugProtocol) WriteString(ctx context.Context, value string) error

func (*TDebugProtocol) WriteStructBegin 

func (tdp *TDebugProtocol) WriteStructBegin(ctx context.Context, name string) error

func (*TDebugProtocol) WriteStructEnd 

func (tdp *TDebugProtocol) WriteStructEnd(ctx context.Context) error

type TDebugProtocolFactory 

type TDebugProtocolFactory struct {
	Underlying TProtocolFactory
	LogPrefix  string
	Logger     Logger
}

func NewTDebugProtocolFactory deprecated 

func NewTDebugProtocolFactory(underlying TProtocolFactory, logPrefix string) *TDebugProtocolFactory

NewTDebugProtocolFactory creates a TDebugProtocolFactory.

Deprecated: Please use NewTDebugProtocolFactoryWithLogger or the struct itself instead. This version will use the default logger from standard library.

func NewTDebugProtocolFactoryWithLogger 

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

NewTDebugProtocolFactoryWithLogger creates a TDebugProtocolFactory.

func (*TDebugProtocolFactory) GetProtocol 

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

type TDeserializer 

type TDeserializer struct {
	Transport *TMemoryBuffer
	Protocol  TProtocol
}

func NewTDeserializer 

func NewTDeserializer() *TDeserializer

func (*TDeserializer) Read 

func (t *TDeserializer) Read(ctx context.Context, msg TStruct, b []byte) (err error)

func (*TDeserializer) ReadString 

func (t *TDeserializer) ReadString(ctx context.Context, msg TStruct, s string) (err error)

type TDeserializerPool 

type TDeserializerPool struct {
	// contains filtered or unexported fields
}

TDeserializerPool is the thread-safe version of TDeserializer, it uses resource pool of TDeserializer under the hood.

It must be initialized with either NewTDeserializerPool or NewTDeserializerPoolSizeFactory.

func NewTDeserializerPool 

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

NewTDeserializerPool creates a new TDeserializerPool.

NewTDeserializer can be used as the arg here.

func NewTDeserializerPoolSizeFactory 

func NewTDeserializerPoolSizeFactory(size int, factory TProtocolFactory) *TDeserializerPool

NewTDeserializerPoolSizeFactory creates a new TDeserializerPool with the given size and protocol factory.

Note that the size is not the limit. The TMemoryBuffer underneath can grow larger than that. It just dictates the initial size.

func (*TDeserializerPool) Read 

func (t *TDeserializerPool) Read(ctx context.Context, msg TStruct, b []byte) error

func (*TDeserializerPool) ReadString 

func (t *TDeserializerPool) ReadString(ctx context.Context, msg TStruct, s string) error

type TException 

type TException interface {
	error
}

Generic Thrift exception

type TFramedTransport 

type TFramedTransport struct {
	// contains filtered or unexported fields
}

func NewTFramedTransport 

func NewTFramedTransport(transport TTransport) *TFramedTransport

func NewTFramedTransportMaxLength 

func NewTFramedTransportMaxLength(transport TTransport, maxLength uint32) *TFramedTransport

func (*TFramedTransport) Close 

func (p *TFramedTransport) Close() error

func (*TFramedTransport) Flush 

func (p *TFramedTransport) Flush(ctx context.Context) 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) (read int, err error)

func (*TFramedTransport) ReadByte 

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

func (*TFramedTransport) RemainingBytes 

func (p *TFramedTransport) RemainingBytes() (num_bytes uint64)

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 THeaderInfoType 

type THeaderInfoType int32

THeaderInfoType is the type id of the info headers. 

const (
	InfoKeyValue THeaderInfoType // 1

)

Supported THeaderInfoType values.

type THeaderMap 

type THeaderMap map[string]string

THeaderMap is the type of the header map in THeader transport.

func GetResponseHeadersFromClient 

func GetResponseHeadersFromClient(c TClient) THeaderMap

GetResponseHeadersFromClient is a helper function to get the read THeaderMap from the last response received from the given client.

If the last response was not sent over THeader protocol, a nil map will be returned.

type THeaderProtocol 

type THeaderProtocol struct {
	// contains filtered or unexported fields
}

THeaderProtocol is a thrift protocol that implements THeader: https://github.com/apache/thrift/blob/master/doc/specs/HeaderFormat.md

It supports either binary or compact protocol as the wrapped protocol.

Most of the THeader handlings are happening inside THeaderTransport.

func NewTHeaderProtocol 

func NewTHeaderProtocol(trans TTransport) *THeaderProtocol

NewTHeaderProtocol creates a new THeaderProtocol from the underlying transport with default protocol ID.

The passed in transport will be wrapped with THeaderTransport.

Note that THeaderTransport handles frame and zlib by itself, so the underlying transport should be a raw socket transports (TSocket or TSSLSocket), instead of rich transports like TZlibTransport or TFramedTransport.

func (*THeaderProtocol) AddTransform 

func (p *THeaderProtocol) AddTransform(transform THeaderTransformID) error

AddTransform add a transform for writing.

func (*THeaderProtocol) ClearWriteHeaders 

func (p *THeaderProtocol) ClearWriteHeaders()

ClearWriteHeaders clears all write headers previously set.

func (*THeaderProtocol) Flush 

func (p *THeaderProtocol) Flush(ctx context.Context) error

func (*THeaderProtocol) GetReadHeaders 

func (p *THeaderProtocol) GetReadHeaders() THeaderMap

GetReadHeaders returns the THeaderMap read from transport.

func (*THeaderProtocol) ReadBinary 

func (p *THeaderProtocol) ReadBinary(ctx context.Context) (value []byte, err error)

func (*THeaderProtocol) ReadBool 

func (p *THeaderProtocol) ReadBool(ctx context.Context) (value bool, err error)

func (*THeaderProtocol) ReadByte 

func (p *THeaderProtocol) ReadByte(ctx context.Context) (value int8, err error)

func (*THeaderProtocol) ReadDouble 

func (p *THeaderProtocol) ReadDouble(ctx context.Context) (value float64, err error)

func (*THeaderProtocol) ReadFieldBegin 

func (p *THeaderProtocol) ReadFieldBegin(ctx context.Context) (name string, typeID TType, id int16, err error)

func (*THeaderProtocol) ReadFieldEnd 

func (p *THeaderProtocol) ReadFieldEnd(ctx context.Context) error

func (*THeaderProtocol) ReadFrame 

func (p *THeaderProtocol) ReadFrame(ctx context.Context) error

ReadFrame calls underlying THeaderTransport's ReadFrame function.

func (*THeaderProtocol) ReadI16 

func (p *THeaderProtocol) ReadI16(ctx context.Context) (value int16, err error)

func (*THeaderProtocol) ReadI32 

func (p *THeaderProtocol) ReadI32(ctx context.Context) (value int32, err error)

func (*THeaderProtocol) ReadI64 

func (p *THeaderProtocol) ReadI64(ctx context.Context) (value int64, err error)

func (*THeaderProtocol) ReadListBegin 

func (p *THeaderProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error)

func (*THeaderProtocol) ReadListEnd 

func (p *THeaderProtocol) ReadListEnd(ctx context.Context) error

func (*THeaderProtocol) ReadMapBegin 

func (p *THeaderProtocol) ReadMapBegin(ctx context.Context) (keyType TType, valueType TType, size int, err error)

func (*THeaderProtocol) ReadMapEnd 

func (p *THeaderProtocol) ReadMapEnd(ctx context.Context) error

func (*THeaderProtocol) ReadMessageBegin 

func (p *THeaderProtocol) ReadMessageBegin(ctx context.Context) (name string, typeID TMessageType, seqID int32, err error)

func (*THeaderProtocol) ReadMessageEnd 

func (p *THeaderProtocol) ReadMessageEnd(ctx context.Context) error

func (*THeaderProtocol) ReadSetBegin 

func (p *THeaderProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)

func (*THeaderProtocol) ReadSetEnd 

func (p *THeaderProtocol) ReadSetEnd(ctx context.Context) error

func (*THeaderProtocol) ReadString 

func (p *THeaderProtocol) ReadString(ctx context.Context) (value string, err error)

func (*THeaderProtocol) ReadStructBegin 

func (p *THeaderProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

func (*THeaderProtocol) ReadStructEnd 

func (p *THeaderProtocol) ReadStructEnd(ctx context.Context) error

func (*THeaderProtocol) SetWriteHeader 

func (p *THeaderProtocol) SetWriteHeader(key, value string)

SetWriteHeader sets a header for write.

func (*THeaderProtocol) Skip 

func (p *THeaderProtocol) Skip(ctx context.Context, fieldType TType) error

func (*THeaderProtocol) Transport 

func (p *THeaderProtocol) Transport() TTransport

Transport returns the underlying transport.

It's guaranteed to be of type *THeaderTransport.

func (*THeaderProtocol) WriteBinary 

func (p *THeaderProtocol) WriteBinary(ctx context.Context, value []byte) error

func (*THeaderProtocol) WriteBool 

func (p *THeaderProtocol) WriteBool(ctx context.Context, value bool) error

func (*THeaderProtocol) WriteByte 

func (p *THeaderProtocol) WriteByte(ctx context.Context, value int8) error

func (*THeaderProtocol) WriteDouble 

func (p *THeaderProtocol) WriteDouble(ctx context.Context, value float64) error

func (*THeaderProtocol) WriteFieldBegin 

func (p *THeaderProtocol) WriteFieldBegin(ctx context.Context, name string, typeID TType, id int16) error

func (*THeaderProtocol) WriteFieldEnd 

func (p *THeaderProtocol) WriteFieldEnd(ctx context.Context) error

func (*THeaderProtocol) WriteFieldStop 

func (p *THeaderProtocol) WriteFieldStop(ctx context.Context) error

func (*THeaderProtocol) WriteI16 

func (p *THeaderProtocol) WriteI16(ctx context.Context, value int16) error

func (*THeaderProtocol) WriteI32 

func (p *THeaderProtocol) WriteI32(ctx context.Context, value int32) error

func (*THeaderProtocol) WriteI64 

func (p *THeaderProtocol) WriteI64(ctx context.Context, value int64) error

func (*THeaderProtocol) WriteListBegin 

func (p *THeaderProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

func (*THeaderProtocol) WriteListEnd 

func (p *THeaderProtocol) WriteListEnd(ctx context.Context) error

func (*THeaderProtocol) WriteMapBegin 

func (p *THeaderProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

func (*THeaderProtocol) WriteMapEnd 

func (p *THeaderProtocol) WriteMapEnd(ctx context.Context) error

func (*THeaderProtocol) WriteMessageBegin 

func (p *THeaderProtocol) WriteMessageBegin(ctx context.Context, name string, typeID TMessageType, seqID int32) error

func (*THeaderProtocol) WriteMessageEnd 

func (p *THeaderProtocol) WriteMessageEnd(ctx context.Context) error

func (*THeaderProtocol) WriteSetBegin 

func (p *THeaderProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

func (*THeaderProtocol) WriteSetEnd 

func (p *THeaderProtocol) WriteSetEnd(ctx context.Context) error

func (*THeaderProtocol) WriteString 

func (p *THeaderProtocol) WriteString(ctx context.Context, value string) error

func (*THeaderProtocol) WriteStructBegin 

func (p *THeaderProtocol) WriteStructBegin(ctx context.Context, name string) error

func (*THeaderProtocol) WriteStructEnd 

func (p *THeaderProtocol) WriteStructEnd(ctx context.Context) error

type THeaderProtocolID 

type THeaderProtocolID int32

THeaderProtocolID is the wrapped protocol id used in THeader. 

const (
	THeaderProtocolBinary  THeaderProtocolID = 0x00
	THeaderProtocolCompact THeaderProtocolID = 0x02
	THeaderProtocolDefault                   = THeaderProtocolBinary
)

Supported THeaderProtocolID values.

func (THeaderProtocolID) GetProtocol 

func (id THeaderProtocolID) GetProtocol(trans TTransport) (TProtocol, error)

GetProtocol gets the corresponding TProtocol from the wrapped protocol id.

func (THeaderProtocolID) Validate 

func (id THeaderProtocolID) Validate() error

Validate checks whether the THeaderProtocolID is a valid/supported one.

type THeaderResponseHelper 

type THeaderResponseHelper struct {
	// contains filtered or unexported fields
}

THeaderResponseHelper defines THeader related TResponseHelper functions.

The zero value of *THeaderResponseHelper is valid with all helper functions being no-op.

func NewTHeaderResponseHelper 

func NewTHeaderResponseHelper(proto TProtocol) *THeaderResponseHelper

NewTHeaderResponseHelper creates a new THeaderResponseHelper from the underlying TProtocol.

func (*THeaderResponseHelper) ClearHeaders 

func (h *THeaderResponseHelper) ClearHeaders()

ClearHeaders clears all the response headers previously set.

It's no-op if the underlying protocol/transport does not support THeader.

func (*THeaderResponseHelper) SetHeader 

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

SetHeader sets a response header.

It's no-op if the underlying protocol/transport does not support THeader.

type THeaderTransformID 

type THeaderTransformID int32

THeaderTransformID defines the numeric id of the transform used. 

const (
	TransformNone THeaderTransformID = iota // 0, no special handling
	TransformZlib                           // 1, zlib
)

THeaderTransformID values.

Values not defined here are not currently supported, namely HMAC and Snappy.

type THeaderTransport 

type THeaderTransport struct {
	SequenceID int32
	Flags      uint32
	// contains filtered or unexported fields
}

THeaderTransport is a Transport mode that implements THeader.

Note that THeaderTransport handles frame and zlib by itself, so the underlying transport should be a raw socket transports (TSocket or TSSLSocket), instead of rich transports like TZlibTransport or TFramedTransport.

func NewTHeaderTransport 

func NewTHeaderTransport(trans TTransport) *THeaderTransport

NewTHeaderTransport creates THeaderTransport from the underlying transport.

Please note that THeaderTransport handles framing and zlib by itself, so the underlying transport should be the raw socket transports (TSocket or TSSLSocket), instead of rich transports like TZlibTransport or TFramedTransport.

If trans is already a *THeaderTransport, it will be returned as is.

func NewTHeaderTransportWithProtocolID 

func NewTHeaderTransportWithProtocolID(trans TTransport, protoID THeaderProtocolID) (*THeaderTransport, error)

NewTHeaderTransportWithProtocolID creates THeaderTransport from the underlying transport, with given protocol ID set.

If trans is already a *THeaderTransport, it will be returned as is, but with protocol ID overridden by the value passed in.

If the passed in protocol ID is an invalid/unsupported one, this function returns error.

The protocol ID overridden is only useful for client transports. For servers, the protocol ID will be overridden again to the one set by the client, to ensure that servers always speak the same dialect as the client.

func (*THeaderTransport) AddTransform 

func (t *THeaderTransport) AddTransform(transform THeaderTransformID) error

AddTransform add a transform for writing.

func (*THeaderTransport) ClearWriteHeaders 

func (t *THeaderTransport) ClearWriteHeaders()

ClearWriteHeaders clears all write headers previously set.

func (*THeaderTransport) Close 

func (t *THeaderTransport) Close() error

Close closes the transport, along with its underlying transport.

func (*THeaderTransport) Flush 

func (t *THeaderTransport) Flush(ctx context.Context) error

Flush writes the appropriate header and the write buffer to the underlying transport.

func (*THeaderTransport) GetReadHeaders 

func (t *THeaderTransport) GetReadHeaders() THeaderMap

GetReadHeaders returns the THeaderMap read from transport.

func (*THeaderTransport) IsOpen 

func (t *THeaderTransport) IsOpen() bool

IsOpen calls the underlying transport's IsOpen function.

func (*THeaderTransport) Open 

func (t *THeaderTransport) Open() error

Open calls the underlying transport's Open function.

func (*THeaderTransport) Protocol 

func (t *THeaderTransport) Protocol() THeaderProtocolID

Protocol returns the wrapped protocol id used in this THeaderTransport.

func (*THeaderTransport) Read 

func (t *THeaderTransport) Read(p []byte) (read int, err error)

func (*THeaderTransport) ReadFrame 

func (t *THeaderTransport) ReadFrame(ctx context.Context) error

ReadFrame tries to read the frame header, guess the client type, and handle unframed clients.

func (*THeaderTransport) RemainingBytes 

func (t *THeaderTransport) RemainingBytes() uint64

RemainingBytes calls underlying transport's RemainingBytes.

Even in framed cases, because of all the possible compression transforms involved, the remaining frame size is likely to be different from the actual remaining readable bytes, so we don't bother to keep tracking the remaining frame size by ourselves and just use the underlying transport's RemainingBytes directly.

func (*THeaderTransport) SetWriteHeader 

func (t *THeaderTransport) SetWriteHeader(key, value string)

SetWriteHeader sets a header for write.

func (*THeaderTransport) Write 

func (t *THeaderTransport) Write(p []byte) (int, error)

Write writes data to the write buffer.

You need to call Flush to actually write them to the transport.

type THeaderTransportFactory 

type THeaderTransportFactory struct {
	// The underlying factory, could be nil.
	Factory TTransportFactory
}

THeaderTransportFactory is a TTransportFactory implementation to create THeaderTransport.

func (*THeaderTransportFactory) GetTransport 

func (f *THeaderTransportFactory) GetTransport(trans TTransport) (TTransport, error)

GetTransport implements TTransportFactory.

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(ctx context.Context) 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) Read 

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

func (*THttpClient) ReadByte 

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

func (*THttpClient) RemainingBytes 

func (p *THttpClient) RemainingBytes() (num_bytes uint64)

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 THttpClientOptions 

type THttpClientOptions struct {
	// If nil, DefaultHttpClient is used
	Client *http.Client
}

type THttpClientTransportFactory 

type THttpClientTransportFactory struct {
	// contains filtered or unexported fields
}

func NewTHttpClientTransportFactory 

func NewTHttpClientTransportFactory(url string) *THttpClientTransportFactory

func NewTHttpClientTransportFactoryWithOptions 

func NewTHttpClientTransportFactoryWithOptions(url string, options THttpClientOptions) *THttpClientTransportFactory

func NewTHttpPostClientTransportFactory deprecated 

func NewTHttpPostClientTransportFactory(url string) *THttpClientTransportFactory

Deprecated: Use NewTHttpClientTransportFactory instead.

func NewTHttpPostClientTransportFactoryWithOptions deprecated 

func NewTHttpPostClientTransportFactoryWithOptions(url string, options THttpClientOptions) *THttpClientTransportFactory

Deprecated: Use NewTHttpClientTransportFactoryWithOptions instead.

func (*THttpClientTransportFactory) GetTransport 

func (p *THttpClientTransportFactory) GetTransport(trans TTransport) (TTransport, error)

type TJSONProtocol 

type TJSONProtocol struct {
	*TSimpleJSONProtocol
}

JSON protocol implementation for thrift. Utilizes Simple JSON protocol

func NewTJSONProtocol 

func NewTJSONProtocol(t TTransport) *TJSONProtocol

Constructor

func (*TJSONProtocol) Flush 

func (p *TJSONProtocol) Flush(ctx context.Context) (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(ctx context.Context) ([]byte, error)

func (*TJSONProtocol) ReadBool 

func (p *TJSONProtocol) ReadBool(ctx context.Context) (bool, error)

func (*TJSONProtocol) ReadByte 

func (p *TJSONProtocol) ReadByte(ctx context.Context) (int8, error)

func (*TJSONProtocol) ReadDouble 

func (p *TJSONProtocol) ReadDouble(ctx context.Context) (float64, error)

func (*TJSONProtocol) ReadFieldBegin 

func (p *TJSONProtocol) ReadFieldBegin(ctx context.Context) (string, TType, int16, error)

func (*TJSONProtocol) ReadFieldEnd 

func (p *TJSONProtocol) ReadFieldEnd(ctx context.Context) error

func (*TJSONProtocol) ReadI16 

func (p *TJSONProtocol) ReadI16(ctx context.Context) (int16, error)

func (*TJSONProtocol) ReadI32 

func (p *TJSONProtocol) ReadI32(ctx context.Context) (int32, error)

func (*TJSONProtocol) ReadI64 

func (p *TJSONProtocol) ReadI64(ctx context.Context) (int64, error)

func (*TJSONProtocol) ReadListBegin 

func (p *TJSONProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, e error)

func (*TJSONProtocol) ReadListEnd 

func (p *TJSONProtocol) ReadListEnd(ctx context.Context) error

func (*TJSONProtocol) ReadMapBegin 

func (p *TJSONProtocol) ReadMapBegin(ctx context.Context) (keyType TType, valueType TType, size int, e error)

func (*TJSONProtocol) ReadMapEnd 

func (p *TJSONProtocol) ReadMapEnd(ctx context.Context) error

func (*TJSONProtocol) ReadMessageBegin 

func (p *TJSONProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error)

Reading methods.

func (*TJSONProtocol) ReadMessageEnd 

func (p *TJSONProtocol) ReadMessageEnd(ctx context.Context) error

func (*TJSONProtocol) ReadSetBegin 

func (p *TJSONProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, e error)

func (*TJSONProtocol) ReadSetEnd 

func (p *TJSONProtocol) ReadSetEnd(ctx context.Context) error

func (*TJSONProtocol) ReadString 

func (p *TJSONProtocol) ReadString(ctx context.Context) (string, error)

func (*TJSONProtocol) ReadStructBegin 

func (p *TJSONProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

func (*TJSONProtocol) ReadStructEnd 

func (p *TJSONProtocol) ReadStructEnd(ctx context.Context) error

func (*TJSONProtocol) Skip 

func (p *TJSONProtocol) Skip(ctx context.Context, 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(ctx context.Context, v []byte) error

func (*TJSONProtocol) WriteBool 

func (p *TJSONProtocol) WriteBool(ctx context.Context, b bool) error

func (*TJSONProtocol) WriteByte 

func (p *TJSONProtocol) WriteByte(ctx context.Context, b int8) error

func (*TJSONProtocol) WriteDouble 

func (p *TJSONProtocol) WriteDouble(ctx context.Context, v float64) error

func (*TJSONProtocol) WriteFieldBegin 

func (p *TJSONProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error

func (*TJSONProtocol) WriteFieldEnd 

func (p *TJSONProtocol) WriteFieldEnd(ctx context.Context) error

func (*TJSONProtocol) WriteFieldStop 

func (p *TJSONProtocol) WriteFieldStop(ctx context.Context) error

func (*TJSONProtocol) WriteI16 

func (p *TJSONProtocol) WriteI16(ctx context.Context, v int16) error

func (*TJSONProtocol) WriteI32 

func (p *TJSONProtocol) WriteI32(ctx context.Context, v int32) error

func (*TJSONProtocol) WriteI64 

func (p *TJSONProtocol) WriteI64(ctx context.Context, v int64) error

func (*TJSONProtocol) WriteListBegin 

func (p *TJSONProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

func (*TJSONProtocol) WriteListEnd 

func (p *TJSONProtocol) WriteListEnd(ctx context.Context) error

func (*TJSONProtocol) WriteMapBegin 

func (p *TJSONProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

func (*TJSONProtocol) WriteMapEnd 

func (p *TJSONProtocol) WriteMapEnd(ctx context.Context) error

func (*TJSONProtocol) WriteMessageBegin 

func (p *TJSONProtocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error

func (*TJSONProtocol) WriteMessageEnd 

func (p *TJSONProtocol) WriteMessageEnd(ctx context.Context) error

func (*TJSONProtocol) WriteSetBegin 

func (p *TJSONProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

func (*TJSONProtocol) WriteSetEnd 

func (p *TJSONProtocol) WriteSetEnd(ctx context.Context) error

func (*TJSONProtocol) WriteString 

func (p *TJSONProtocol) WriteString(ctx context.Context, v string) error

func (*TJSONProtocol) WriteStructBegin 

func (p *TJSONProtocol) WriteStructBegin(ctx context.Context, name string) error

func (*TJSONProtocol) WriteStructEnd 

func (p *TJSONProtocol) WriteStructEnd(ctx context.Context) error

type TJSONProtocolFactory 

type TJSONProtocolFactory struct{}

Factory

func NewTJSONProtocolFactory 

func NewTJSONProtocolFactory() *TJSONProtocolFactory

func (*TJSONProtocolFactory) GetProtocol 

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

type TMemoryBuffer 

type TMemoryBuffer struct {
	*bytes.Buffer
	// contains filtered or unexported fields
}

Memory buffer-based implementation of the TTransport interface.

func NewTMemoryBuffer 

func NewTMemoryBuffer() *TMemoryBuffer

func NewTMemoryBufferLen 

func NewTMemoryBufferLen(size int) *TMemoryBuffer

func (*TMemoryBuffer) Close 

func (p *TMemoryBuffer) Close() error

func (*TMemoryBuffer) Flush 

func (p *TMemoryBuffer) Flush(ctx context.Context) error

Flushing a memory buffer is a no-op

func (*TMemoryBuffer) IsOpen 

func (p *TMemoryBuffer) IsOpen() bool

func (*TMemoryBuffer) Open 

func (p *TMemoryBuffer) Open() error

func (*TMemoryBuffer) RemainingBytes 

func (p *TMemoryBuffer) RemainingBytes() (num_bytes uint64)

type TMemoryBufferTransportFactory 

type TMemoryBufferTransportFactory struct {
	// contains filtered or unexported fields
}

func NewTMemoryBufferTransportFactory 

func NewTMemoryBufferTransportFactory(size int) *TMemoryBufferTransportFactory

func (*TMemoryBufferTransportFactory) GetTransport 

func (p *TMemoryBufferTransportFactory) GetTransport(trans TTransport) (TTransport, error)

type TMessageType 

type TMessageType int32

Message type constants in the Thrift protocol. 

const (
	INVALID_TMESSAGE_TYPE TMessageType = 0
	CALL                  TMessageType = 1
	REPLY                 TMessageType = 2
	EXCEPTION             TMessageType = 3
	ONEWAY                TMessageType = 4
)

type TMultiplexedProcessor 

type TMultiplexedProcessor struct {
	DefaultProcessor TProcessor
	// contains filtered or unexported fields
}

func NewTMultiplexedProcessor 

func NewTMultiplexedProcessor() *TMultiplexedProcessor

func (*TMultiplexedProcessor) AddToProcessorMap 

func (t *TMultiplexedProcessor) AddToProcessorMap(name string, processorFunc TProcessorFunction)

AddToProcessorMap updates the underlying TProcessor ProccessorMaps depending on the format of "name".

If "name" is in the format "{ProcessorName}{MULTIPLEXED_SEPARATOR}{FunctionName}", then it sets the given TProcessorFunction on the inner TProcessor with the ProcessorName component using the FunctionName component.

If "name" is just in the format "{FunctionName}", that is to say there is no MULTIPLEXED_SEPARATOR, and the TMultiplexedProcessor has a DefaultProcessor configured, then it will set the given TProcessorFunction on the DefaultProcessor using the given name.

If there is not a TProcessor available for the given name, then this function does nothing. This can happen when there is no TProcessor registered for the given ProcessorName or if all that is given is the FunctionName and there is no DefaultProcessor set.

func (*TMultiplexedProcessor) Process 

func (t *TMultiplexedProcessor) Process(ctx context.Context, in, out TProtocol) (bool, TException)

func (*TMultiplexedProcessor) ProcessorMap 

func (t *TMultiplexedProcessor) ProcessorMap() map[string]TProcessorFunction

ProcessorMap returns a mapping of "{ProcessorName}{MULTIPLEXED_SEPARATOR}{FunctionName}" to TProcessorFunction for any registered processors. If there is also a DefaultProcessor, the keys for the methods on that processor will simply be "{FunctionName}". If the TMultiplexedProcessor has both a DefaultProcessor and other registered processors, then the keys will be a mix of both formats.

The implementation differs with other TProcessors in that the map returned is a new map, while most TProcessors just return their internal mapping directly. This means that edits to the map returned by this implementation of ProcessorMap will not affect the underlying mapping within the TMultiplexedProcessor.

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(ctx context.Context, name string, typeId TMessageType, seqid int32) error

type TProcessor 

type TProcessor interface {
	Process(ctx context.Context, in, out TProtocol) (bool, TException)

	// ProcessorMap returns a map of thrift method names to TProcessorFunctions.
	ProcessorMap() map[string]TProcessorFunction

	// AddToProcessorMap adds the given TProcessorFunction to the internal
	// processor map at the given key.
	//
	// If one is already set at the given key, it will be replaced with the new
	// TProcessorFunction.
	AddToProcessorMap(string, TProcessorFunction)
}

A processor is a generic object which operates upon an input stream and writes to some output stream.

func WrapProcessor 

func WrapProcessor(processor TProcessor, middlewares ...ProcessorMiddleware) TProcessor

WrapProcessor takes an existing TProcessor and wraps each of its inner TProcessorFunctions with the middlewares passed in and returns it.

Middlewares will be called in the order that they are defined:

  1. Middlewares[0]
  2. Middlewares[1] ... N. Middlewares[n]

type TProcessorFactory 

type TProcessorFactory interface {
	GetProcessor(trans TTransport) TProcessor
}

The default processor factory just returns a singleton instance.

func NewTProcessorFactory 

func NewTProcessorFactory(p TProcessor) TProcessorFactory

type TProcessorFunction 

type TProcessorFunction interface {
	Process(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException)
}

type TProcessorFunctionFactory 

type TProcessorFunctionFactory interface {
	GetProcessorFunction(trans TTransport) TProcessorFunction
}

*

  • The default processor factory just returns a singleton
  • instance.

func NewTProcessorFunctionFactory 

func NewTProcessorFunctionFactory(p TProcessorFunction) TProcessorFunctionFactory

type TProtocol 

type TProtocol interface {
	WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqid int32) error
	WriteMessageEnd(ctx context.Context) error
	WriteStructBegin(ctx context.Context, name string) error
	WriteStructEnd(ctx context.Context) error
	WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error
	WriteFieldEnd(ctx context.Context) error
	WriteFieldStop(ctx context.Context) error
	WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error
	WriteMapEnd(ctx context.Context) error
	WriteListBegin(ctx context.Context, elemType TType, size int) error
	WriteListEnd(ctx context.Context) error
	WriteSetBegin(ctx context.Context, elemType TType, size int) error
	WriteSetEnd(ctx context.Context) error
	WriteBool(ctx context.Context, value bool) error
	WriteByte(ctx context.Context, value int8) error
	WriteI16(ctx context.Context, value int16) error
	WriteI32(ctx context.Context, value int32) error
	WriteI64(ctx context.Context, value int64) error
	WriteDouble(ctx context.Context, value float64) error
	WriteString(ctx context.Context, value string) error
	WriteBinary(ctx context.Context, value []byte) error

	ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqid int32, err error)
	ReadMessageEnd(ctx context.Context) error
	ReadStructBegin(ctx context.Context) (name string, err error)
	ReadStructEnd(ctx context.Context) error
	ReadFieldBegin(ctx context.Context) (name string, typeId TType, id int16, err error)
	ReadFieldEnd(ctx context.Context) error
	ReadMapBegin(ctx context.Context) (keyType TType, valueType TType, size int, err error)
	ReadMapEnd(ctx context.Context) error
	ReadListBegin(ctx context.Context) (elemType TType, size int, err error)
	ReadListEnd(ctx context.Context) error
	ReadSetBegin(ctx context.Context) (elemType TType, size int, err error)
	ReadSetEnd(ctx context.Context) error
	ReadBool(ctx context.Context) (value bool, err error)
	ReadByte(ctx context.Context) (value int8, err error)
	ReadI16(ctx context.Context) (value int16, err error)
	ReadI32(ctx context.Context) (value int32, err error)
	ReadI64(ctx context.Context) (value int64, err error)
	ReadDouble(ctx context.Context) (value float64, err error)
	ReadString(ctx context.Context) (value string, err error)
	ReadBinary(ctx context.Context) (value []byte, err error)

	Skip(ctx context.Context, fieldType TType) (err error)
	Flush(ctx context.Context) (err error)

	Transport() TTransport
}

type TProtocolException 

type TProtocolException interface {
	TException
	TypeId() int
}

Thrift Protocol exception

func NewTProtocolException 

func NewTProtocolException(err error) TProtocolException

func NewTProtocolExceptionWithType 

func NewTProtocolExceptionWithType(errType int, err error) TProtocolException

type TProtocolFactory 

type TProtocolFactory interface {
	GetProtocol(trans TTransport) TProtocol
}

Factory interface for constructing protocol instances.

func NewTHeaderProtocolFactory 

func NewTHeaderProtocolFactory() TProtocolFactory

NewTHeaderProtocolFactory creates a factory for THeader with default protocol ID.

It's a wrapper for NewTHeaderProtocol

func NewTHeaderProtocolFactoryWithProtocolID 

func NewTHeaderProtocolFactoryWithProtocolID(protoID THeaderProtocolID) (TProtocolFactory, error)

NewTHeaderProtocolFactoryWithProtocolID creates a factory for THeader with given protocol ID.

type TResponseHelper 

type TResponseHelper struct {
	// THeader related functions
	*THeaderResponseHelper
}

TResponseHelper defines a object with a set of helper functions that can be retrieved from the context object passed into server handler functions.

Use GetResponseHelper to retrieve the injected TResponseHelper implementation from the context object.

The zero value of TResponseHelper is valid with all helper functions being no-op.

func GetResponseHelper 

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

GetResponseHelper retrieves the TResponseHelper implementation injected into the context object.

If no helper was found in the context object, a nop helper with ok == false will be returned.

type TRichTransport 

type TRichTransport interface {
	io.ReadWriter
	io.ByteReader
	io.ByteWriter

	ContextFlusher
	ReadSizeProvider
	// contains filtered or unexported methods
}

This is "enchanced" transport with extra capabilities. You need to use one of these to construct protocol. Notably, TSocket does not implement this interface, and it is always a mistake to use TSocket directly in protocol.

type 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.NewTSSLSocket("localhost:9090", nil)

func NewTSSLSocketFromAddrTimeout 

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

Creates a TSSLSocket from a net.Addr

func NewTSSLSocketFromConnTimeout 

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

Creates a TSSLSocket from an existing net.Conn

func NewTSSLSocketTimeout 

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

NewTSSLSocketTimeout creates a net.Conn-backed TTransport, given a host and port it also accepts a tls Configuration and connect/socket timeouts as time.Duration

func (*TSSLSocket) Close 

func (p *TSSLSocket) Close() error

Closes the socket.

func (*TSSLSocket) Conn 

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

Retrieve the underlying net.Conn

func (*TSSLSocket) Flush 

func (p *TSSLSocket) Flush(ctx context.Context) 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) Read 

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

func (*TSSLSocket) RemainingBytes 

func (p *TSSLSocket) RemainingBytes() (num_bytes uint64)

func (*TSSLSocket) SetConnTimeout 

func (p *TSSLSocket) SetConnTimeout(timeout time.Duration) error

Sets the connect timeout

func (*TSSLSocket) SetSocketTimeout 

func (p *TSSLSocket) SetSocketTimeout(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(ctx context.Context, msg TStruct) (b []byte, err error)

func (*TSerializer) WriteString 

func (t *TSerializer) WriteString(ctx context.Context, msg TStruct) (s string, err error)

type TSerializerPool 

type TSerializerPool struct {
	// contains filtered or unexported fields
}

TSerializerPool is the thread-safe version of TSerializer, it uses resource pool of TSerializer under the hood.

It must be initialized with either NewTSerializerPool or NewTSerializerPoolSizeFactory.

func NewTSerializerPool 

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

NewTSerializerPool creates a new TSerializerPool.

NewTSerializer can be used as the arg here.

func NewTSerializerPoolSizeFactory 

func NewTSerializerPoolSizeFactory(size int, factory TProtocolFactory) *TSerializerPool

NewTSerializerPoolSizeFactory creates a new TSerializerPool with the given size and protocol factory.

Note that the size is not the limit. The TMemoryBuffer underneath can grow larger than that. It just dictates the initial size.

func (*TSerializerPool) Write 

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

func (*TSerializerPool) WriteString 

func (t *TSerializerPool) WriteString(ctx context.Context, msg TStruct) (string, 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 {
	// contains filtered or unexported fields
}

func NewTServerSocket 

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

func NewTServerSocketFromAddrTimeout 

func NewTServerSocketFromAddrTimeout(addr net.Addr, clientTimeout time.Duration) *TServerSocket

Creates a TServerSocket from a net.Addr

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 

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
}

Server transport. Object which provides client transports.

type TSimpleJSONProtocol 

type TSimpleJSONProtocol struct {
	// contains filtered or unexported fields
}

Simple JSON protocol implementation for thrift.

This protocol produces/consumes a simple output format suitable for parsing by scripting languages. It should not be confused with the full-featured TJSONProtocol.

func NewTSimpleJSONProtocol 

func NewTSimpleJSONProtocol(t TTransport) *TSimpleJSONProtocol

Constructor

func (*TSimpleJSONProtocol) Flush 

func (p *TSimpleJSONProtocol) Flush(ctx context.Context) (err error)

func (*TSimpleJSONProtocol) OutputBool 

func (p *TSimpleJSONProtocol) OutputBool(value bool) error

func (*TSimpleJSONProtocol) OutputElemListBegin 

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

func (*TSimpleJSONProtocol) OutputF64 

func (p *TSimpleJSONProtocol) OutputF64(value float64) error

func (*TSimpleJSONProtocol) OutputI64 

func (p *TSimpleJSONProtocol) OutputI64(value int64) error

func (*TSimpleJSONProtocol) OutputListBegin 

func (p *TSimpleJSONProtocol) OutputListBegin() error

func (*TSimpleJSONProtocol) OutputListEnd 

func (p *TSimpleJSONProtocol) OutputListEnd() error

func (*TSimpleJSONProtocol) OutputNull 

func (p *TSimpleJSONProtocol) OutputNull() error

func (*TSimpleJSONProtocol) OutputObjectBegin 

func (p *TSimpleJSONProtocol) OutputObjectBegin() error

func (*TSimpleJSONProtocol) OutputObjectEnd 

func (p *TSimpleJSONProtocol) OutputObjectEnd() error

func (*TSimpleJSONProtocol) OutputPostValue 

func (p *TSimpleJSONProtocol) OutputPostValue() error

func (*TSimpleJSONProtocol) OutputPreValue 

func (p *TSimpleJSONProtocol) OutputPreValue() error

func (*TSimpleJSONProtocol) OutputString 

func (p *TSimpleJSONProtocol) OutputString(s string) error

func (*TSimpleJSONProtocol) OutputStringData 

func (p *TSimpleJSONProtocol) OutputStringData(s string) error

func (*TSimpleJSONProtocol) ParseBase64EncodedBody 

func (p *TSimpleJSONProtocol) ParseBase64EncodedBody() ([]byte, error)

func (*TSimpleJSONProtocol) ParseElemListBegin 

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

func (*TSimpleJSONProtocol) ParseF64 

func (p *TSimpleJSONProtocol) ParseF64() (float64, bool, error)

func (*TSimpleJSONProtocol) ParseI64 

func (p *TSimpleJSONProtocol) ParseI64() (int64, bool, error)

func (*TSimpleJSONProtocol) ParseListBegin 

func (p *TSimpleJSONProtocol) ParseListBegin() (isNull bool, err error)

func (*TSimpleJSONProtocol) ParseListEnd 

func (p *TSimpleJSONProtocol) ParseListEnd() error

func (*TSimpleJSONProtocol) ParseObjectEnd 

func (p *TSimpleJSONProtocol) ParseObjectEnd() error

func (*TSimpleJSONProtocol) ParseObjectStart 

func (p *TSimpleJSONProtocol) ParseObjectStart() (bool, error)

func (*TSimpleJSONProtocol) ParsePostValue 

func (p *TSimpleJSONProtocol) ParsePostValue() error

func (*TSimpleJSONProtocol) ParsePreValue 

func (p *TSimpleJSONProtocol) ParsePreValue() error

func (*TSimpleJSONProtocol) ParseQuotedStringBody 

func (p *TSimpleJSONProtocol) ParseQuotedStringBody() (string, error)

func (*TSimpleJSONProtocol) ParseStringBody 

func (p *TSimpleJSONProtocol) ParseStringBody() (string, error)

func (*TSimpleJSONProtocol) ReadBinary 

func (p *TSimpleJSONProtocol) ReadBinary(ctx context.Context) ([]byte, error)

func (*TSimpleJSONProtocol) ReadBool 

func (p *TSimpleJSONProtocol) ReadBool(ctx context.Context) (bool, error)

func (*TSimpleJSONProtocol) ReadByte 

func (p *TSimpleJSONProtocol) ReadByte(ctx context.Context) (int8, error)

func (*TSimpleJSONProtocol) ReadDouble 

func (p *TSimpleJSONProtocol) ReadDouble(ctx context.Context) (float64, error)

func (*TSimpleJSONProtocol) ReadFieldBegin 

func (p *TSimpleJSONProtocol) ReadFieldBegin(ctx context.Context) (string, TType, int16, error)

func (*TSimpleJSONProtocol) ReadFieldEnd 

func (p *TSimpleJSONProtocol) ReadFieldEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) ReadI16 

func (p *TSimpleJSONProtocol) ReadI16(ctx context.Context) (int16, error)

func (*TSimpleJSONProtocol) ReadI32 

func (p *TSimpleJSONProtocol) ReadI32(ctx context.Context) (int32, error)

func (*TSimpleJSONProtocol) ReadI64 

func (p *TSimpleJSONProtocol) ReadI64(ctx context.Context) (int64, error)

func (*TSimpleJSONProtocol) ReadListBegin 

func (p *TSimpleJSONProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, e error)

func (*TSimpleJSONProtocol) ReadListEnd 

func (p *TSimpleJSONProtocol) ReadListEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) ReadMapBegin 

func (p *TSimpleJSONProtocol) ReadMapBegin(ctx context.Context) (keyType TType, valueType TType, size int, e error)

func (*TSimpleJSONProtocol) ReadMapEnd 

func (p *TSimpleJSONProtocol) ReadMapEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) ReadMessageBegin 

func (p *TSimpleJSONProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error)

Reading methods.

func (*TSimpleJSONProtocol) ReadMessageEnd 

func (p *TSimpleJSONProtocol) ReadMessageEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) ReadSetBegin 

func (p *TSimpleJSONProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, e error)

func (*TSimpleJSONProtocol) ReadSetEnd 

func (p *TSimpleJSONProtocol) ReadSetEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) ReadString 

func (p *TSimpleJSONProtocol) ReadString(ctx context.Context) (string, error)

func (*TSimpleJSONProtocol) ReadStructBegin 

func (p *TSimpleJSONProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

func (*TSimpleJSONProtocol) ReadStructEnd 

func (p *TSimpleJSONProtocol) ReadStructEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) Skip 

func (p *TSimpleJSONProtocol) Skip(ctx context.Context, fieldType TType) (err error)

func (*TSimpleJSONProtocol) Transport 

func (p *TSimpleJSONProtocol) Transport() TTransport

func (*TSimpleJSONProtocol) WriteBinary 

func (p *TSimpleJSONProtocol) WriteBinary(ctx context.Context, v []byte) error

func (*TSimpleJSONProtocol) WriteBool 

func (p *TSimpleJSONProtocol) WriteBool(ctx context.Context, b bool) error

func (*TSimpleJSONProtocol) WriteByte 

func (p *TSimpleJSONProtocol) WriteByte(ctx context.Context, b int8) error

func (*TSimpleJSONProtocol) WriteDouble 

func (p *TSimpleJSONProtocol) WriteDouble(ctx context.Context, v float64) error

func (*TSimpleJSONProtocol) WriteFieldBegin 

func (p *TSimpleJSONProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error

func (*TSimpleJSONProtocol) WriteFieldEnd 

func (p *TSimpleJSONProtocol) WriteFieldEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) WriteFieldStop 

func (p *TSimpleJSONProtocol) WriteFieldStop(ctx context.Context) error

func (*TSimpleJSONProtocol) WriteI16 

func (p *TSimpleJSONProtocol) WriteI16(ctx context.Context, v int16) error

func (*TSimpleJSONProtocol) WriteI32 

func (p *TSimpleJSONProtocol) WriteI32(ctx context.Context, v int32) error

func (*TSimpleJSONProtocol) WriteI64 

func (p *TSimpleJSONProtocol) WriteI64(ctx context.Context, v int64) error

func (*TSimpleJSONProtocol) WriteListBegin 

func (p *TSimpleJSONProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error

func (*TSimpleJSONProtocol) WriteListEnd 

func (p *TSimpleJSONProtocol) WriteListEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) WriteMapBegin 

func (p *TSimpleJSONProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error

func (*TSimpleJSONProtocol) WriteMapEnd 

func (p *TSimpleJSONProtocol) WriteMapEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) WriteMessageBegin 

func (p *TSimpleJSONProtocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error

func (*TSimpleJSONProtocol) WriteMessageEnd 

func (p *TSimpleJSONProtocol) WriteMessageEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) WriteSetBegin 

func (p *TSimpleJSONProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error

func (*TSimpleJSONProtocol) WriteSetEnd 

func (p *TSimpleJSONProtocol) WriteSetEnd(ctx context.Context) error

func (*TSimpleJSONProtocol) WriteString 

func (p *TSimpleJSONProtocol) WriteString(ctx context.Context, v string) error

func (*TSimpleJSONProtocol) WriteStructBegin 

func (p *TSimpleJSONProtocol) WriteStructBegin(ctx context.Context, name string) error

func (*TSimpleJSONProtocol) WriteStructEnd 

func (p *TSimpleJSONProtocol) WriteStructEnd(ctx context.Context) error

type TSimpleJSONProtocolFactory 

type TSimpleJSONProtocolFactory struct{}

Factory

func NewTSimpleJSONProtocolFactory 

func NewTSimpleJSONProtocolFactory() *TSimpleJSONProtocolFactory

func (*TSimpleJSONProtocolFactory) GetProtocol 

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

type TSimpleServer 

type TSimpleServer struct {
	// contains filtered or unexported fields
}

* This is not a typical TSimpleServer as it is not blocked after accept a socket. * It is more like a TThreadedServer that can handle different connections in different goroutines. * This will work if golang user implements a conn-pool like thing in client side.

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) SetForwardHeaders 

func (p *TSimpleServer) SetForwardHeaders(headers []string)

SetForwardHeaders sets the list of header keys that will be auto forwarded while using THeaderProtocol.

"forward" means that when the server is also a client to other upstream thrift servers, the context object user gets in the processor functions will have both read and write headers set, with write headers being forwarded. Users can always override the write headers by calling SetWriteHeaderList before calling thrift client functions.

func (*TSimpleServer) SetLogger 

func (p *TSimpleServer) SetLogger(logger Logger)

SetLogger sets the logger used by this TSimpleServer.

If no logger was set before Serve is called, a default logger using standard log library will be used.

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, connTimeout time.Duration, soTimeout time.Duration) *TSocket

Creates a TSocket from a net.Addr

func NewTSocketFromConnTimeout 

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

Creates a TSocket from an existing net.Conn

func NewTSocketTimeout 

func NewTSocketTimeout(hostPort string, connTimeout time.Duration, soTimeout 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) Addr 

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

Returns the remote address of the socket.

func (*TSocket) Close 

func (p *TSocket) Close() error

Closes the socket.

func (*TSocket) Conn 

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

Retrieve the underlying net.Conn

func (*TSocket) Flush 

func (p *TSocket) Flush(ctx context.Context) 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) Read 

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

func (*TSocket) RemainingBytes 

func (p *TSocket) RemainingBytes() (num_bytes uint64)

func (*TSocket) SetConnTimeout 

func (p *TSocket) SetConnTimeout(timeout time.Duration) error

Sets the connect timeout

func (*TSocket) SetSocketTimeout 

func (p *TSocket) SetSocketTimeout(timeout time.Duration) error

Sets the socket timeout

func (*TSocket) Write 

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

type TStandardClient 

type TStandardClient struct {
	// contains filtered or unexported fields
}

func NewTStandardClient 

func NewTStandardClient(inputProtocol, outputProtocol TProtocol) *TStandardClient

TStandardClient implements TClient, and uses the standard message format for Thrift. It is not safe for concurrent use.

func (*TStandardClient) Call 

func (p *TStandardClient) Call(ctx context.Context, method string, args, result TStruct) error

func (*TStandardClient) Recv 

func (p *TStandardClient) Recv(ctx context.Context, iprot TProtocol, seqId int32, method string, result TStruct) error

func (*TStandardClient) Send 

func (p *TStandardClient) Send(ctx context.Context, oprot TProtocol, seqId int32, method string, args TStruct) error

type TStruct 

type TStruct interface {
	Write(ctx context.Context, p TProtocol) error
	Read(ctx context.Context, p TProtocol) error
}

type TTransport 

type TTransport interface {
	io.ReadWriteCloser
	ContextFlusher
	ReadSizeProvider

	// Opens the transport for communication
	Open() error

	// Returns true if the transport is open
	IsOpen() bool
}

Encapsulates the I/O layer

func NewTHttpClient 

func NewTHttpClient(urlstr string) (TTransport, error)

func NewTHttpClientWithOptions 

func NewTHttpClientWithOptions(urlstr string, options THttpClientOptions) (TTransport, error)

func NewTHttpPostClient deprecated 

func NewTHttpPostClient(urlstr string) (TTransport, error)

Deprecated: Use NewTHttpClient instead.

func NewTHttpPostClientWithOptions deprecated 

func NewTHttpPostClientWithOptions(urlstr string, options THttpClientOptions) (TTransport, error)

Deprecated: Use NewTHttpClientWithOptions instead.

type TTransportException 

type TTransportException interface {
	TException
	TypeId() int
	Err() error
}

Thrift Transport exception

func NewTTransportException 

func NewTTransportException(t int, e string) TTransportException

func NewTTransportExceptionFromError 

func NewTTransportExceptionFromError(e error) TTransportException

type TTransportFactory 

type TTransportFactory interface {
	GetTransport(trans TTransport) (TTransport, error)
}

Factory class used to create wrapped instance of Transports. This is used primarily in servers, which get Transports from a ServerTransport and then may want to mutate them (i.e. create a BufferedTransport from the underlying base transport)

func NewTFramedTransportFactory 

func NewTFramedTransportFactory(factory TTransportFactory) TTransportFactory

func NewTFramedTransportFactoryMaxLength 

func NewTFramedTransportFactoryMaxLength(factory TTransportFactory, maxLength uint32) TTransportFactory

func NewTHeaderTransportFactory 

func NewTHeaderTransportFactory(factory TTransportFactory) TTransportFactory

NewTHeaderTransportFactory creates a new *THeaderTransportFactory.

func NewTTransportFactory 

func NewTTransportFactory() TTransportFactory

type TType 

type TType byte

Type constants in the Thrift protocol

func (TType) String 

func (p TType) String() string

type TZlibTransport 

type TZlibTransport struct {
	// contains filtered or unexported fields
}

TZlibTransport is a TTransport implementation that makes use of zlib compression.

func NewTZlibTransport 

func NewTZlibTransport(trans TTransport, level int) (*TZlibTransport, error)

NewTZlibTransport constructs a new instance of TZlibTransport

func (*TZlibTransport) Close 

func (z *TZlibTransport) Close() error

Close closes the reader and writer (flushing any unwritten data) and closes the underlying transport.

func (*TZlibTransport) Flush 

func (z *TZlibTransport) Flush(ctx context.Context) error

Flush flushes the writer and its underlying transport.

func (*TZlibTransport) IsOpen 

func (z *TZlibTransport) IsOpen() bool

IsOpen returns true if the transport is open

func (*TZlibTransport) Open 

func (z *TZlibTransport) Open() error

Open opens the transport for communication

func (*TZlibTransport) Read 

func (z *TZlibTransport) Read(p []byte) (int, error)

func (*TZlibTransport) RemainingBytes 

func (z *TZlibTransport) RemainingBytes() uint64

RemainingBytes returns the size in bytes of the data that is still to be read.

func (*TZlibTransport) Write 

func (z *TZlibTransport) Write(p []byte) (int, error)

type TZlibTransportFactory 

type TZlibTransportFactory struct {
	// contains filtered or unexported fields
}

TZlibTransportFactory is a factory for TZlibTransport instances

func NewTZlibTransportFactory 

func NewTZlibTransportFactory(level int) *TZlibTransportFactory

NewTZlibTransportFactory constructs a new instance of NewTZlibTransportFactory

func NewTZlibTransportFactoryWithFactory 

func NewTZlibTransportFactoryWithFactory(level int, factory TTransportFactory) *TZlibTransportFactory

NewTZlibTransportFactory constructs a new instance of TZlibTransportFactory as a wrapper over existing transport factory

func (*TZlibTransportFactory) GetTransport 

func (p *TZlibTransportFactory) GetTransport(trans TTransport) (TTransport, error)

GetTransport constructs a new instance of NewTZlibTransport

type TransformReader 

type TransformReader struct {
	io.Reader
	// contains filtered or unexported fields
}

TransformReader is an io.ReadCloser that handles transforms reading.

func NewTransformReaderWithCapacity 

func NewTransformReaderWithCapacity(baseReader io.Reader, capacity int) *TransformReader

NewTransformReaderWithCapacity initializes a TransformReader with expected closers capacity.

If you don't know the closers capacity beforehand, just use 

&TransformReader{Reader: baseReader}

instead would be sufficient.

func (*TransformReader) AddTransform 

func (tr *TransformReader) AddTransform(id THeaderTransformID) error

AddTransform adds a transform.

func (*TransformReader) Close 

func (tr *TransformReader) Close() error

Close calls the underlying closers in appropriate order, stops at and returns the first error encountered.

type TransformWriter 

type TransformWriter struct {
	io.Writer
	// contains filtered or unexported fields
}

TransformWriter is an io.WriteCloser that handles transforms writing.

func (*TransformWriter) AddTransform 

func (tw *TransformWriter) AddTransform(id THeaderTransformID) error

AddTransform adds a transform.

func (*TransformWriter) Close 

func (tw *TransformWriter) Close() error

Close calls the underlying closers in appropriate order, stops at and returns the first error encountered.

type WrappedTClient 

type WrappedTClient struct {
	Wrapped func(ctx context.Context, method string, args, result TStruct) error
}

WrappedTClient is a convenience struct that implements the TClient interface using inner Wrapped function.

This is provided to aid in developing ClientMiddleware.

func (WrappedTClient) Call 

func (c WrappedTClient) Call(ctx context.Context, method string, args, result TStruct) error

Call implements the TClient interface by calling and returning c.Wrapped.

type WrappedTProcessorFunction 

type WrappedTProcessorFunction struct {
	// Wrapped is called by WrappedTProcessorFunction.Process and should be a
	// "wrapped" call to a base TProcessorFunc.Process call.
	Wrapped func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException)
}

WrappedTProcessorFunction is a convenience struct that implements the TProcessorFunction interface that can be used when implementing custom Middleware.

func (WrappedTProcessorFunction) Process 

func (p WrappedTProcessorFunction) Process(ctx context.Context, seqID int32, in, out TProtocol) (bool, TException)

Process implements the TProcessorFunction interface using p.Wrapped.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.