redis

Documentation

Index

• func GenConsumeKey(red *redis.Client, originKey string, suffix string) (string, error)
• func GenTempKey(red *redis.Client, originKey string, suffix string) (string, error)
• func Intersect(red *redis.Client, key string, arr []uint64) ([]uint64, error)
• func Marshal(v interface{}) ([]byte, error)
• func MultiUnmarshal(vals []interface{}, out interface{})
• func MultiUnmarshalStr(vals []string, out interface{})
• func ReleaseTempKey(red *redis.Client, key string) error
• func Setup(settings *Settings) (*redis.Client, error)
• func Unmarshal(data []byte, v interface{}) error
• type Settings

Functions

func GenConsumeKey

func GenConsumeKey(red *redis.Client, originKey string, suffix string) (string, error)

func GenTempKey

func GenTempKey(red *redis.Client, originKey string, suffix string) (string, error)

*

• gen a temp key which in same slot as originKey
• see: https://www.cnblogs.com/Finley/p/10674101.html#%E4%B8%B4%E6%97%B6%E9%94%AE%E7%9A%84%E7%94%9F%E6%88%90

func Intersect

func Intersect(red *redis.Client, key string, arr []uint64) ([]uint64, error)

*

• 与 Redis 中的 Set 取交集
• 将 arr 放入临时键中再使用 SINTER 命令

func Marshal

func Marshal(v interface{}) ([]byte, error)

func MultiUnmarshal

func MultiUnmarshal(vals []interface{}, out interface{})

func MultiUnmarshalStr

func MultiUnmarshalStr(vals []string, out interface{})

func ReleaseTempKey

func ReleaseTempKey(red *redis.Client, key string) error

func Setup

func Setup(settings *Settings) (*redis.Client, error)

func Unmarshal

func Unmarshal(data []byte, v interface{}) error

Types

type Settings

type Settings struct {
	Host        string        `yaml:"host"`
	Password    string        `yaml:"password"`
	DB          int           `yaml:"db"`
	PoolSize    int           `yaml:"pool-size"`
	PoolTimeout time.Duration `yaml:"pool-timeout"`
}