types

Documentation

Index

• Constants
• type HashObject
  • func (o *HashObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
  • func (o *HashObject) Rewrite() []RedisCmd
• type ListObject
  • func (o *ListObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
  • func (o *ListObject) Rewrite() []RedisCmd
• type ModuleObject
  • func (o *ModuleObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
  • func (o *ModuleObject) Rewrite() []RedisCmd
• type RedisCmd
• type RedisObject
  • func ParseObject(rd io.Reader, typeByte byte, key string) RedisObject
• type SetObject
  • func (o *SetObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
  • func (o *SetObject) Rewrite() []RedisCmd
• type StreamObject
  • func (o *StreamObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
  • func (o *StreamObject) Rewrite() []RedisCmd
• type StringObject
  • func (o *StringObject) LoadFromBuffer(rd io.Reader, key string, _ byte)
  • func (o *StringObject) Rewrite() []RedisCmd
• type ZSetEntry
• type ZsetObject
  • func (o *ZsetObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
  • func (o *ZsetObject) Rewrite() []RedisCmd

Constants

const (
	// StringType is redis string
	StringType = "string"
	// ListType is redis list
	ListType = "list"
	// SetType is redis set
	SetType = "set"
	// HashType is redis hash
	HashType = "hash"
	// ZSetType is redis sorted set
	ZSetType = "zset"
	// AuxType is redis metadata key-value pair
	AuxType = "aux"
	// DBSizeType is for _OPCODE_RESIZEDB
	DBSizeType = "dbsize"
)

const (
	RDBTypeString  = 0 // RDB_TYPE_STRING
	RDBTypeList    = 1
	RDBTypeSet     = 2
	RDBTypeZSet    = 3
	RDBTypeHash    = 4 // RDB_TYPE_HASH
	RDBTypeZSet2   = 5 // ZSET version 2 with doubles stored in binary.
	RDBTypeModule  = 6 // RDB_TYPE_MODULE
	RDBTypeModule2 = 7 // RDB_TYPE_MODULE2 Module value with annotations for parsing without the generating module being loaded.

	RDBTypeHashZipmap       = 9
	RDBTypeListZiplist      = 10
	RDBTypeSetIntset        = 11
	RDBTypeZSetZiplist      = 12
	RDBTypeHashZiplist      = 13
	RDBTypeListQuicklist    = 14 // RDB_TYPE_LIST_QUICKLIST
	RDBTypeStreamListpacks  = 15 // RDB_TYPE_STREAM_LISTPACKS
	RDBTypeHashListpack     = 16 // RDB_TYPE_HASH_ZIPLIST
	RDBTypeZSetListpack     = 17 // RDB_TYPE_ZSET_LISTPACK
	RDBTypeListQuicklist2   = 18 // RDB_TYPE_LIST_QUICKLIST_2 https://github.com/redis/redis/pull/9357
	RDBTypeStreamListpacks2 = 19 // RDB_TYPE_STREAM_LISTPACKS2

)

Types

type HashObject

type HashObject struct {
	Value map[string]string
	// contains filtered or unexported fields
}

func (*HashObject) LoadFromBuffer

func (o *HashObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)

func (*HashObject) Rewrite

func (o *HashObject) Rewrite() []RedisCmd

type ListObject

type ListObject struct {
	Elements []string
	// contains filtered or unexported fields
}

func (*ListObject) LoadFromBuffer

func (o *ListObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)

func (*ListObject) Rewrite

func (o *ListObject) Rewrite() []RedisCmd

type ModuleObject

type ModuleObject struct {
}

func (*ModuleObject) LoadFromBuffer

func (o *ModuleObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)

func (*ModuleObject) Rewrite

func (o *ModuleObject) Rewrite() []RedisCmd

type RedisCmd

type RedisCmd []string

type RedisObject

type RedisObject interface {
	LoadFromBuffer(rd io.Reader, key string, typeByte byte)
	Rewrite() []RedisCmd
}

RedisObject is interface for a redis object

func ParseObject

func ParseObject(rd io.Reader, typeByte byte, key string) RedisObject

type SetObject

type SetObject struct {
	Elements []string
	// contains filtered or unexported fields
}

func (*SetObject) LoadFromBuffer

func (o *SetObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)

func (*SetObject) Rewrite

func (o *SetObject) Rewrite() []RedisCmd

type StreamObject

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

func (*StreamObject) LoadFromBuffer

func (o *StreamObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)

func (*StreamObject) Rewrite

func (o *StreamObject) Rewrite() []RedisCmd

type StringObject

type StringObject struct {
	Key   string
	Value string
}

func (*StringObject) LoadFromBuffer

func (o *StringObject) LoadFromBuffer(rd io.Reader, key string, _ byte)

func (*StringObject) Rewrite

func (o *StringObject) Rewrite() []RedisCmd

type ZSetEntry

type ZSetEntry struct {
	Member string
	Score  string
}

type ZsetObject

type ZsetObject struct {
	Elements []ZSetEntry
	// contains filtered or unexported fields
}

func (*ZsetObject) LoadFromBuffer

func (o *ZsetObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)

func (*ZsetObject) Rewrite

func (o *ZsetObject) Rewrite() []RedisCmd