spi

Documentation

Index

• func DiscardList(iter Iterator)
• func DiscardMap(iter Iterator)
• func DiscardStruct(iter Iterator)
• type DummyExtension
  • func (extension *DummyExtension) DecoderOf(valType reflect.Type) ValDecoder
  • func (extension *DummyExtension) EncoderOf(valType reflect.Type) ValEncoder
• type Extension
• type Extensions
  • func (extensions Extensions) DecoderOf(valType reflect.Type) ValDecoder
  • func (extensions Extensions) EncoderOf(valType reflect.Type) ValEncoder
• type Iterator
• type Stream
• type ValDecoder
• type ValDecoderProvider
• type ValEncoder
• type ValEncoderProvider

Functions

func DiscardList

func DiscardList(iter Iterator)

func DiscardMap

func DiscardMap(iter Iterator)

func DiscardStruct

func DiscardStruct(iter Iterator)

Types

type DummyExtension

type DummyExtension struct {
}

func (*DummyExtension) DecoderOf

func (extension *DummyExtension) DecoderOf(valType reflect.Type) ValDecoder

func (*DummyExtension) EncoderOf

func (extension *DummyExtension) EncoderOf(valType reflect.Type) ValEncoder

type Extension

type Extension interface {
	DecoderOf(valType reflect.Type) ValDecoder
	EncoderOf(valType reflect.Type) ValEncoder
}

type Extensions

type Extensions []Extension

func (Extensions) DecoderOf

func (extensions Extensions) DecoderOf(valType reflect.Type) ValDecoder

func (Extensions) EncoderOf

func (extensions Extensions) EncoderOf(valType reflect.Type) ValEncoder

type Iterator

type Iterator interface {
	ValDecoderProvider
	Spawn() Iterator
	Error() error
	Reset(reader io.Reader, buf []byte)
	ReportError(operation string, err string)
	ReadMessageHeader() protocol.MessageHeader
	SkipMessageHeader(space []byte) []byte
	ReadStructHeader()
	ReadStructField() (fieldType protocol.TType, fieldId protocol.FieldId)
	SkipStruct(space []byte) []byte
	ReadListHeader() (elemType protocol.TType, size int)
	SkipList(space []byte) []byte
	ReadMapHeader() (keyType protocol.TType, elemType protocol.TType, size int)
	SkipMap(space []byte) []byte
	ReadBool() bool
	ReadInt() int
	ReadUint() uint
	ReadInt8() int8
	ReadUint8() uint8
	ReadInt16() int16
	ReadUint16() uint16
	ReadInt32() int32
	ReadUint32() uint32
	ReadInt64() int64
	ReadUint64() uint64
	ReadFloat64() float64
	ReadString() string
	ReadBinary() []byte
	SkipBinary(space []byte) []byte
	Skip(ttype protocol.TType, space []byte) []byte
	Discard(ttype protocol.TType)
}

type Stream

type Stream interface {
	ValEncoderProvider
	Spawn() Stream
	Error() error
	ReportError(operation string, err string)
	Reset(writer io.Writer)
	Flush()
	Buffer() []byte
	Write(buf []byte) error
	WriteMessageHeader(header protocol.MessageHeader)
	WriteListHeader(elemType protocol.TType, length int)
	WriteStructHeader()
	WriteStructField(fieldType protocol.TType, fieldId protocol.FieldId)
	WriteStructFieldStop()
	WriteMapHeader(keyType protocol.TType, elemType protocol.TType, length int)
	WriteBool(val bool)
	WriteInt(val int)
	WriteUint(val uint)
	WriteInt8(val int8)
	WriteUint8(val uint8)
	WriteInt16(val int16)
	WriteUint16(val uint16)
	WriteInt32(val int32)
	WriteUint32(val uint32)
	WriteInt64(val int64)
	WriteUint64(val uint64)
	WriteFloat64(val float64)
	WriteBinary(val []byte)
	WriteString(val string)
}

type ValDecoder

type ValDecoder interface {
	Decode(val interface{}, iter Iterator)
}

type ValDecoderProvider

type ValDecoderProvider interface {
	PrepareDecoder(valType reflect.Type)
	GetDecoder(decoderName string) ValDecoder
}

type ValEncoder

type ValEncoder interface {
	Encode(val interface{}, stream Stream)
	ThriftType() protocol.TType
}

type ValEncoderProvider

type ValEncoderProvider interface {
	PrepareEncoder(valType reflect.Type)
	GetEncoder(encoderName string) ValEncoder
}