redis

Documentation

Index

• func Get(key string) redis.UniversalClient
• func InitRedises()
• func ListPop(rds redis.UniversalClient, keys []string, timeout, goPoolSize int, ...)
• func ListPush(ctx context.Context, rds redis.UniversalClient, key string, ...) error
• func MqPSubscribe(c context.Context, rds redis.UniversalClient, pChannel string, ...)
• func MqPublish(ctx context.Context, rds redis.UniversalClient, channel string, ...) error
• func RdsAllowActionByMTs(ctx context.Context, rds redis.UniversalClient, actionKey string, ...) (int64, bool)
• func RdsAllowActionWithCD(ctx context.Context, rds redis.UniversalClient, actionKey string, ...) (int, bool)
• func RdsLockResWithCD(ctx context.Context, rds redis.UniversalClient, resKey, resValue string, ...) bool
• 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 ListPop

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

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

func ListPush

func ListPush(ctx context.Context, rds redis.UniversalClient, key string, data ...interface{}) error

func MqPSubscribe

func MqPSubscribe(c context.Context, rds redis.UniversalClient, pChannel string, handler func(channel string, data string),
	goPoolSize int)

func MqPublish

func MqPublish(ctx context.Context, rds redis.UniversalClient, channel string, message interface{}) error

func RdsAllowActionByMTs

func RdsAllowActionByMTs(ctx context.Context, rds redis.UniversalClient, actionKey string, cdMillSeconds, keyTTL int) (int64, bool)

func RdsAllowActionWithCD

func RdsAllowActionWithCD(ctx context.Context, rds redis.UniversalClient, actionKey string, cdSeconds int) (int, bool)

func RdsLockResWithCD

func RdsLockResWithCD(ctx context.Context, rds redis.UniversalClient, resKey, resValue string, cdSeconds int) bool

RdsLockResWithCD(ctx context.Context, rds redis.UniversalClient, resKeyName, config.ServerId, runtimeSeconds*2)

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)