redis

Documentation

Index

• func Get(key string) redis.UniversalClient
• func InitRedises()
• func MqLsPop(rds redis.UniversalClient, keys []string, timeout int, ...)
• func MqLsPush(ctx context.Context, dbKey string, key string, data ...interface{})
• func ZBatchAdd(ctx context.Context, rds redis.UniversalClient, keyName string, ...) error
• func ZDescartes(ctx context.Context, rds redis.UniversalClient, dimValues [][]string, ...) error
• type ZDescartesFilter

Functions

func Get

func Get(key string) redis.UniversalClient

func InitRedises

func InitRedises()

func MqLsPop

func MqLsPop(rds redis.UniversalClient, keys []string, timeout int, handler func(key, data string), goPoolSize int)

list结构主要用来做异步操作,相当于一对一发送接收

func MqLsPush

func MqLsPush(ctx context.Context, dbKey string, key string, data ...interface{})

func ZBatchAdd

func ZBatchAdd(ctx context.Context, rds redis.UniversalClient, keyName string, members []*redis.Z, ttl, batchSize int) error

func ZDescartes

func ZDescartes(ctx context.Context, rds redis.UniversalClient, dimValues [][]string, filter ZDescartesFilter,
	ttl, batchSize int) error

Types

type ZDescartesFilter

type ZDescartesFilter func([]string) (string, map[string]int64)