Documentation ¶
Index ¶
- type Iterator
- func (iter *Iterator) Discard(ttype protocol.TType)
- func (iter *Iterator) Error() error
- func (iter *Iterator) ReadBinary() []byte
- func (iter *Iterator) ReadBool() bool
- func (iter *Iterator) ReadFloat64() float64
- func (iter *Iterator) ReadInt() int
- func (iter *Iterator) ReadInt16() int16
- func (iter *Iterator) ReadInt32() int32
- func (iter *Iterator) ReadInt64() int64
- func (iter *Iterator) ReadInt8() int8
- func (iter *Iterator) ReadListHeader() (elemType protocol.TType, size int)
- func (iter *Iterator) ReadMapHeader() (keyType protocol.TType, elemType protocol.TType, size int)
- func (iter *Iterator) ReadMessageHeader() protocol.MessageHeader
- func (iter *Iterator) ReadString() string
- func (iter *Iterator) ReadStructField() (fieldType protocol.TType, fieldId protocol.FieldId)
- func (iter *Iterator) ReadStructHeader()
- func (iter *Iterator) ReadUint() uint
- func (iter *Iterator) ReadUint16() uint16
- func (iter *Iterator) ReadUint32() uint32
- func (iter *Iterator) ReadUint64() uint64
- func (iter *Iterator) ReadUint8() uint8
- func (iter *Iterator) ReportError(operation string, err string)
- func (iter *Iterator) Reset(reader io.Reader, buf []byte)
- func (iter *Iterator) Skip(ttype protocol.TType, space []byte) []byte
- func (iter *Iterator) SkipBinary(space []byte) []byte
- func (iter *Iterator) SkipList(space []byte) []byte
- func (iter *Iterator) SkipMap(space []byte) []byte
- func (iter *Iterator) SkipMessageHeader(space []byte) []byte
- func (iter *Iterator) SkipStruct(space []byte) []byte
- func (iter *Iterator) Spawn() spi.Iterator
- type Stream
- func (stream *Stream) Buffer() []byte
- func (stream *Stream) Error() error
- func (stream *Stream) Flush()
- func (stream *Stream) ReportError(operation string, err string)
- func (stream *Stream) Reset(writer io.Writer)
- func (stream *Stream) Spawn() spi.Stream
- func (stream *Stream) Write(buf []byte) error
- func (stream *Stream) WriteBinary(val []byte)
- func (stream *Stream) WriteBool(val bool)
- func (stream *Stream) WriteFloat64(val float64)
- func (stream *Stream) WriteInt(val int)
- func (stream *Stream) WriteInt16(val int16)
- func (stream *Stream) WriteInt32(val int32)
- func (stream *Stream) WriteInt64(val int64)
- func (stream *Stream) WriteInt8(val int8)
- func (stream *Stream) WriteListHeader(elemType protocol.TType, length int)
- func (stream *Stream) WriteMapHeader(keyType protocol.TType, elemType protocol.TType, length int)
- func (stream *Stream) WriteMessageHeader(header protocol.MessageHeader)
- func (stream *Stream) WriteString(val string)
- func (stream *Stream) WriteStructField(fieldType protocol.TType, fieldId protocol.FieldId)
- func (stream *Stream) WriteStructFieldStop()
- func (stream *Stream) WriteStructHeader()
- func (stream *Stream) WriteUint(val uint)
- func (stream *Stream) WriteUint16(val uint16)
- func (stream *Stream) WriteUint32(val uint32)
- func (stream *Stream) WriteUint64(val uint64)
- func (stream *Stream) WriteUint8(val uint8)
- type TCompactType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Iterator ¶
type Iterator struct { spi.ValDecoderProvider // contains filtered or unexported fields }
func NewIterator ¶
func (*Iterator) ReadBinary ¶
func (*Iterator) ReadFloat64 ¶
func (*Iterator) ReadListHeader ¶
func (*Iterator) ReadMapHeader ¶
func (*Iterator) ReadMessageHeader ¶
func (iter *Iterator) ReadMessageHeader() protocol.MessageHeader
func (*Iterator) ReadString ¶
func (*Iterator) ReadStructField ¶
func (*Iterator) ReadStructHeader ¶
func (iter *Iterator) ReadStructHeader()
func (*Iterator) ReadUint16 ¶
func (*Iterator) ReadUint32 ¶
func (*Iterator) ReadUint64 ¶
func (*Iterator) ReportError ¶
func (*Iterator) SkipBinary ¶
func (*Iterator) SkipMessageHeader ¶
func (*Iterator) SkipStruct ¶
type Stream ¶
type Stream struct { spi.ValEncoderProvider // contains filtered or unexported fields }
func (*Stream) ReportError ¶
func (*Stream) WriteBinary ¶
func (*Stream) WriteFloat64 ¶
func (*Stream) WriteInt16 ¶
func (*Stream) WriteInt32 ¶
func (*Stream) WriteInt64 ¶
func (*Stream) WriteListHeader ¶
func (*Stream) WriteMapHeader ¶
func (*Stream) WriteMessageHeader ¶
func (stream *Stream) WriteMessageHeader(header protocol.MessageHeader)
func (*Stream) WriteString ¶
func (*Stream) WriteStructField ¶
func (*Stream) WriteStructFieldStop ¶
func (stream *Stream) WriteStructFieldStop()
func (*Stream) WriteStructHeader ¶
func (stream *Stream) WriteStructHeader()
func (*Stream) WriteUint16 ¶
func (*Stream) WriteUint32 ¶
func (*Stream) WriteUint64 ¶
func (*Stream) WriteUint8 ¶
type TCompactType ¶
type TCompactType byte
const ( TypeStop TCompactType = 0x00 TypeBooleanTrue TCompactType = 0x01 TypeBooleanFalse TCompactType = 0x02 TypeByte TCompactType = 0x03 TypeI16 TCompactType = 0x04 TypeI32 TCompactType = 0x05 TypeI64 TCompactType = 0x06 TypeDouble TCompactType = 0x07 TypeBinary TCompactType = 0x08 TypeList TCompactType = 0x09 TypeSet TCompactType = 0x0A TypeMap TCompactType = 0x0B TypeStruct TCompactType = 0x0C )
Click to show internal directories.
Click to hide internal directories.