types

package
v1.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2026 License: MIT Imports: 8 Imported by: 0

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

func ModuleTypeNameByID(moduleId uint64) string

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 RedisCmd

type RedisCmd []string

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

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

func (*SetObject) Rewrite

func (o *SetObject) Rewrite() <-chan 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() <-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

Jump to

Keyboard shortcuts

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