rdb

Documentation

Index

• Constants
• Variables
• func DecodeDump(p []byte) (interface{}, error)
• func EncodeDump(obj interface{}) ([]byte, error)
• func NewRdbReader(r io.Reader) *rdbReader
• func NewSliceBuffer(s []byte) *sliceBuffer
• type BinEntry
  • func (e *BinEntry) ObjEntry() (*ObjEntry, error)
• type Encoder
  • func NewEncoder(w io.Writer) *Encoder
  • func (e *Encoder) EncodeFooter() error
  • func (e *Encoder) EncodeHeader() error
  • func (e *Encoder) EncodeObject(db uint32, key []byte, expireat uint64, obj interface{}) error
• type HSortByField
  • func (by HSortByField) Less(i, j int) bool
• type Hash
  • func (hash Hash) Len() int
  • func (hash Hash) Swap(i, j int)
• type HashElement
• type List
• type Loader
  • func NewLoader(r io.Reader) *Loader
  • func (r Loader) CountZipmapItems(buf *sliceBuffer) (int, error)
  • func (l *Loader) Footer() error
  • func (l *Loader) Header() error
  • func (l *Loader) NextBinEntry() (*BinEntry, error)
  • func (r Loader) Read(p []byte) (int, error)
  • func (r Loader) ReadByte() (byte, error)
  • func (r Loader) ReadBytes(n int) ([]byte, error)
  • func (r Loader) ReadDouble() (float64, error)
  • func (r Loader) ReadFloat() (float64, error)
  • func (r Loader) ReadLength() (uint32, error)
  • func (r Loader) ReadString() ([]byte, error)
  • func (r Loader) ReadZiplistEntry(buf *sliceBuffer) ([]byte, error)
  • func (r Loader) ReadZiplistLength(buf *sliceBuffer) (int64, error)
  • func (r Loader) ReadZipmapItem(buf *sliceBuffer, readFree bool) ([]byte, error)
• type ObjEntry
  • func (e *ObjEntry) BinEntry() (*BinEntry, error)
• type Set
• type String
• type ZSet
  • func (zset ZSet) Len() int
  • func (zset ZSet) Swap(i, j int)
• type ZSetElement
• type ZSortByMember
  • func (by ZSortByMember) Less(i, j int) bool
• type ZSortByScore
  • func (by ZSortByScore) Less(i, j int) bool

Constants

const (
	RdbTypeString = 0
	RdbTypeList   = 1
	RdbTypeSet    = 2
	RdbTypeZSet   = 3
	RdbTypeHash   = 4
	RdbTypeZSet2  = 5

	RdbTypeHashZipmap      = 9
	RdbTypeListZiplist     = 10
	RdbTypeSetIntset       = 11
	RdbTypeZSetZiplist     = 12
	RdbTypeHashZiplist     = 13
	RdbTypeQuicklist       = 14
	RDBTypeStreamListPacks = 15 // stream

	RdbFlagAUX = 0xfa
)

Variables

var FromVersion int64 = 9

var ToVersion int64 = 6

Functions

func DecodeDump

func DecodeDump(p []byte) (interface{}, error)

func EncodeDump

func EncodeDump(obj interface{}) ([]byte, error)

func NewRdbReader

func NewRdbReader(r io.Reader) *rdbReader

func NewSliceBuffer

func NewSliceBuffer(s []byte) *sliceBuffer

Types

type BinEntry

type BinEntry struct {
	DB              uint32
	Key             []byte
	Type            byte
	Value           []byte
	ExpireAt        uint64
	RealMemberCount uint32
	NeedReadLen     byte
	IdleTime        uint32
	Freq            uint8
}

func (*BinEntry) ObjEntry

func (e *BinEntry) ObjEntry() (*ObjEntry, error)

type Encoder

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

func NewEncoder

func NewEncoder(w io.Writer) *Encoder

func (*Encoder) EncodeFooter

func (e *Encoder) EncodeFooter() error

func (*Encoder) EncodeHeader

func (e *Encoder) EncodeHeader() error

func (*Encoder) EncodeObject

func (e *Encoder) EncodeObject(db uint32, key []byte, expireat uint64, obj interface{}) error

type HSortByField

type HSortByField struct{ Hash }

func (HSortByField) Less

func (by HSortByField) Less(i, j int) bool

type Hash

type Hash []*HashElement

func (Hash) Len

func (hash Hash) Len() int

func (Hash) Swap

func (hash Hash) Swap(i, j int)

type HashElement

type HashElement struct {
	Field, Value []byte
}

type List

type List [][]byte

type Loader

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

func NewLoader

func NewLoader(r io.Reader) *Loader

func (Loader) CountZipmapItems

func (r Loader) CountZipmapItems(buf *sliceBuffer) (int, error)

func (*Loader) Footer

func (l *Loader) Footer() error

func (*Loader) Header

func (l *Loader) Header() error

func (*Loader) NextBinEntry

func (l *Loader) NextBinEntry() (*BinEntry, error)

func (Loader) Read

func (r Loader) Read(p []byte) (int, error)

func (Loader) ReadByte

func (r Loader) ReadByte() (byte, error)

func (Loader) ReadBytes

func (r Loader) ReadBytes(n int) ([]byte, error)

func (Loader) ReadDouble

func (r Loader) ReadDouble() (float64, error)

func (Loader) ReadFloat

func (r Loader) ReadFloat() (float64, error)

func (Loader) ReadLength

func (r Loader) ReadLength() (uint32, error)

func (Loader) ReadString

func (r Loader) ReadString() ([]byte, error)

func (Loader) ReadZiplistEntry

func (r Loader) ReadZiplistEntry(buf *sliceBuffer) ([]byte, error)

func (Loader) ReadZiplistLength

func (r Loader) ReadZiplistLength(buf *sliceBuffer) (int64, error)

func (Loader) ReadZipmapItem

func (r Loader) ReadZipmapItem(buf *sliceBuffer, readFree bool) ([]byte, error)

type ObjEntry

type ObjEntry struct {
	DB              uint32
	Key             []byte
	Type            byte
	Value           interface{}
	ExpireAt        uint64
	RealMemberCount uint32
	NeedReadLen     byte
}

func (*ObjEntry) BinEntry

func (e *ObjEntry) BinEntry() (*BinEntry, error)

type Set

type Set [][]byte

type String

type String []byte

type ZSet

type ZSet []*ZSetElement

func (ZSet) Len

func (zset ZSet) Len() int

func (ZSet) Swap

func (zset ZSet) Swap(i, j int)

type ZSetElement

type ZSetElement struct {
	Member []byte
	Score  float64
}

type ZSortByMember

type ZSortByMember struct{ ZSet }

func (ZSortByMember) Less

func (by ZSortByMember) Less(i, j int) bool

type ZSortByScore

type ZSortByScore struct{ ZSet }

func (ZSortByScore) Less

func (by ZSortByScore) Less(i, j int) bool