core

Jan 4, 2024

Changes in this version

type ModuleTypeHandler

+ ReadFloat32 func() (float32, error)

Jun 10, 2023

Changes in this version

+ const ModuleTypeNameCharSet

type Decoder

+ func (dec *Decoder) WithSpecialType(moduleType string, f ModuleTypeHandleFunc) *Decoder

+ type ModuleTypeHandleFunc func(handler ModuleTypeHandler, encVersion int) (interface{}, error)

+ type ModuleTypeHandler interface

+ ReadByte func() (byte, error)

+ ReadDouble func() (float64, error)

+ ReadFull func(buf []byte) error

+ ReadLength func() (uint64, bool, error)

+ ReadOpcode func() (Opcode, error)

+ ReadSInt func() (int64, error)

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

+ ReadUInt func() (uint64, error)

+ type Opcode uint8

+ const ModuleOpcodeDouble

+ const ModuleOpcodeEOF

+ const ModuleOpcodeFloat

+ const ModuleOpcodeSInt

+ const ModuleOpcodeString

+ const ModuleOpcodeUInt

Apr 16, 2023

Changes in this version

+ const StreamItemFlagDeleted

+ const StreamItemFlagNone

+ const StreamItemFlagSameFields

Apr 8, 2023

Changes in this version

type Decoder

+ func (dec *Decoder) GetReadCount() int

Sep 24, 2022

Changes in this version

+ const QuicklistNodeContainerPacked

+ const QuicklistNodeContainerPlain

May 22, 2022

Changes in this version

+ func RandString(n int) string

type Decoder

+ func (dec *Decoder) WithSpecialOpCode() *Decoder

+ type Encoder struct

+ func NewEncoder(writer io.Writer) *Encoder

+ func (enc *Encoder) EnableCompress() *Encoder

+ func (enc *Encoder) SetHashZipListOpt(maxValue, maxEntries int) *Encoder

+ func (enc *Encoder) SetListZipListOpt(maxValue, maxEntries int) *Encoder

+ func (enc *Encoder) SetZSetZipListOpt(maxValue, maxEntries int) *Encoder

+ func (enc *Encoder) WriteAux(key, value string) error

+ func (enc *Encoder) WriteDBHeader(dbIndex uint, keyCount, ttlCount uint64) error

+ func (enc *Encoder) WriteEnd() error

+ func (enc *Encoder) WriteHashMapObject(key string, hash map[string][]byte, options ...interface{}) error

+ func (enc *Encoder) WriteHeader() error

+ func (enc *Encoder) WriteListObject(key string, values [][]byte, options ...interface{}) error

+ func (enc *Encoder) WriteSetObject(key string, values [][]byte, options ...interface{}) error

+ func (enc *Encoder) WriteStringObject(key string, value []byte, options ...interface{}) error

+ func (enc *Encoder) WriteZSetObject(key string, entries []*model.ZSetEntry, options ...interface{}) error

+ type TTLOption uint64

+ func WithTTL(expirationMs uint64) TTLOption

Mar 28, 2022

Changes in this version

+ type Decoder struct

+ func NewDecoder(reader io.Reader) *Decoder

+ func (dec *Decoder) Parse(cb func(object model.RedisObject) bool) error