Documentation
¶
Index ¶
Constants ¶
View Source
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" )
View Source
const ( BF_MIN_OPTIONS_ENC = 2 BF_MIN_GROWTH_ENC = 4 )
View Source
const ( DUMPED_CHAIN_HEADER_SIZE = 20 DUMPED_CHAIN_LINK_SIZE = 53 DUMPED_CHAIN_HEADER_SIZE_V3 = 16 DUMPED_CHAIN_LINK_SIZE_V3 = 49 )
View Source
const MAX_SCANDUMP_SIZE = 10485760 // 10MB
View Source
const TargetMBbloomVersion = 20203 //在在目标版本(如4.0)和源版本(如7.0)不一致时的兼容问题
Variables ¶
This section is empty.
Functions ¶
func ModuleTypeNameByID ¶
Types ¶
type BloomObject ¶
type BloomObject struct {
// contains filtered or unexported fields
}
BloomObject for MBbloom-- at https://github.com/RedisBloom/RedisBloom
func (*BloomObject) LoadFromBuffer ¶
func (o *BloomObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
func (*BloomObject) Rewrite ¶
func (o *BloomObject) Rewrite() <-chan RedisCmd
type HashObject ¶
type HashObject struct {
// 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() <-chan RedisCmd
type ListObject ¶
type ListObject struct {
// 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() <-chan RedisCmd
type ModuleObject ¶
type ModuleObject interface {
RedisObject
}
func PareseModuleType ¶
func PareseModuleType(rd io.Reader, key string, typeByte byte) ModuleObject
type RedisObject ¶
type RedisObject interface {
LoadFromBuffer(rd io.Reader, key string, typeByte byte)
Rewrite() <-chan 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 {
// contains filtered or unexported fields
}
func (*SetObject) LoadFromBuffer ¶
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() <-chan RedisCmd
type StringObject ¶
type StringObject struct {
// contains filtered or unexported fields
}
func (*StringObject) LoadFromBuffer ¶
func (o *StringObject) LoadFromBuffer(rd io.Reader, key string, _ byte)
func (*StringObject) Rewrite ¶
func (o *StringObject) Rewrite() <-chan RedisCmd
type TairHashObject ¶
type TairHashObject struct {
// contains filtered or unexported fields
}
func (*TairHashObject) LoadFromBuffer ¶
func (o *TairHashObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
func (*TairHashObject) Rewrite ¶
func (o *TairHashObject) Rewrite() <-chan RedisCmd
type TairStringObject ¶
type TairStringObject struct {
// contains filtered or unexported fields
}
func (*TairStringObject) LoadFromBuffer ¶
func (o *TairStringObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
func (*TairStringObject) Rewrite ¶
func (o *TairStringObject) Rewrite() <-chan RedisCmd
type TairZsetObject ¶
type TairZsetObject struct {
// contains filtered or unexported fields
}
func (*TairZsetObject) LoadFromBuffer ¶
func (o *TairZsetObject) LoadFromBuffer(rd io.Reader, key string, typeByte byte)
func (*TairZsetObject) Rewrite ¶
func (o *TairZsetObject) Rewrite() <-chan RedisCmd
type ZsetObject ¶
type ZsetObject struct {
// 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() <-chan RedisCmd
Click to show internal directories.
Click to hide internal directories.