encoding

package

Go to main page

Versions in this module

v0

v0.6.0

May 9, 2024

Changes in this version

+ func BytesToInt64(src []byte) int64

+ func BytesToInt64List(dst []int64, src []byte, mt EncodeType, firstValue int64, itemsCount int) ([]int64, error)

+ func BytesToUint16(src []byte) uint16

+ func BytesToUint32(src []byte) uint32

+ func BytesToUint64(src []byte) uint64

+ func BytesToVarInt64(src []byte) ([]byte, int64, error)

+ func BytesToVarInt64List(dst []int64, src []byte) ([]byte, error)

+ func BytesToVarUint64(src []byte) ([]byte, uint64, error)

+ func BytesToVarUint64s(dst []uint64, src []byte) ([]byte, error)

+ func DecodeBytes(src []byte) ([]byte, []byte, error)

+ func EncodeBytes(dst, b []byte) []byte

+ func EncodeBytesBlock(dst []byte, a [][]byte) []byte

+ func Int64ToBytes(dst []byte, v int64) []byte

+ func ReleaseInt64List(is *Int64List)

+ func ReleaseUint64List(is *Uint64List)

+ func Uint16ToBytes(dst []byte, u uint16) []byte

+ func Uint32ToBytes(dst []byte, u uint32) []byte

+ func Uint64ToBytes(dst []byte, u uint64) []byte

+ func VarInt64ListToBytes(dst []byte, vs []int64) []byte

+ func VarInt64ToBytes(dst []byte, v int64) []byte

+ func VarUint64ToBytes(dst []byte, u uint64) []byte

+ func VarUint64sToBytes(dst []byte, us []uint64) []byte

+ type BytesBlockDecoder struct

+ func (bbd *BytesBlockDecoder) Decode(dst [][]byte, src []byte, itemsCount uint64) ([][]byte, error)

+ func (bbd *BytesBlockDecoder) Reset()

+ type EncodeType byte

+ const EncodeTypeConst

+ const EncodeTypeDelta

+ const EncodeTypeDeltaConst

+ const EncodeTypeDeltaOfDelta

+ const EncodeTypeUnknown

+ const EncodeTypeXOR

+ func Int64ListToBytes(dst []byte, a []int64) (result []byte, mt EncodeType, firstValue int64)

+ type Int64List struct

+ L []int64

+ func GenerateInt64List(size int) *Int64List

+ type Uint64List struct

+ L []uint64

+ func GenerateUint64List(size int) *Uint64List

v0.5.0

Oct 17, 2023

v0.4.0

Jun 28, 2023

v0.3.1

Feb 21, 2023

v0.3.0

Feb 6, 2023

Changes in this version

+ type BufferWriter interface

+ Bytes func() []byte

+ Write func(data []byte) (n int, err error)

+ WriteByte func(b byte) error

+ type Packer struct

+ func NewPacker(buf BufferWriter) *Packer

+ func (w *Packer) Bytes() []byte

+ func (w *Packer) PutUint16(v uint16)

+ func (w *Packer) PutUint32(v uint32)

+ func (w *Packer) PutUint64(v uint64)

+ func (w *Packer) Write(p []byte)

+ type Reader struct

+ func NewReader(in io.ByteReader) *Reader

+ func (r *Reader) ReadBits(numBits int) (uint64, error)

+ func (r *Reader) ReadBool() (bool, error)

+ func (r *Reader) ReadByte() (byte, error)

+ func (r *Reader) Reset()

type SeriesDecoder

+ Range func() (start, end uint64)

type SeriesDecoderPool

+ func NewDecoderPool(name string, size int, fn ParseInterval) SeriesDecoderPool

type SeriesEncoderPool

+ func NewEncoderPool(name string, size int, fn ParseInterval) SeriesEncoderPool

+ type Writer struct

+ func NewWriter() *Writer

+ func (w *Writer) Flush()

+ func (w *Writer) Reset(buffer BufferWriter)

+ func (w *Writer) WriteBits(u uint64, numBits int)

+ func (w *Writer) WriteBool(b bool)

+ func (w *Writer) WriteByte(b byte) error

v0.2.0

Nov 5, 2022

v0.1.0

Jun 2, 2022

Changes in this version

+ const TsLen

+ var ErrEncodeEmpty = errors.New("encode an empty value")

+ var ErrInvalidValue = errors.New("invalid encoded value")

+ type ParseInterval = func(key []byte) time.Duration

+ type SeriesDecoder interface

+ Decode func(key, data []byte) error

+ Get func(ts uint64) ([]byte, error)

+ IsFull func() bool

+ Iterator func() SeriesIterator

+ Len func() int

+ type SeriesDecoderPool interface

+ Get func(metadata []byte) SeriesDecoder

+ Put func(encoder SeriesDecoder)

+ func NewIntDecoderPool(size int, fn ParseInterval) SeriesDecoderPool

+ func NewPlainDecoderPool(size int) SeriesDecoderPool

+ type SeriesEncoder interface

+ Append func(ts uint64, value []byte)

+ Encode func() ([]byte, error)

+ IsFull func() bool

+ Reset func(key []byte)

+ StartTime func() uint64

+ type SeriesEncoderPool interface

+ Get func(metadata []byte) SeriesEncoder

+ Put func(encoder SeriesEncoder)

+ func NewIntEncoderPool(size int, fn ParseInterval) SeriesEncoderPool

+ func NewPlainEncoderPool(size int) SeriesEncoderPool

+ type SeriesIterator interface

+ Error func() error

+ Next func() bool

+ Time func() uint64

+ Val func() []byte

+ type XORDecoder struct

+ func NewXORDecoder(br *bit.Reader) *XORDecoder

+ func (d *XORDecoder) Err() error

+ func (d *XORDecoder) Next() bool

+ func (d *XORDecoder) Reset()

+ func (d *XORDecoder) Value() uint64

+ type XOREncoder struct

+ func NewXOREncoder(bw *bit.Writer) *XOREncoder

+ func (e *XOREncoder) Write(val uint64)

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