redisutil

Documentation

Index

• func IndexVacuum(ctx context.Context, c RedisIndexer, indexKey string, dataKeyPrefix Prefix) error
• func JSONGet(ctx context.Context, c RedisGetter, key string, v interface{}) error
• func JSONSet(ctx context.Context, c RedisSetter, key string, v interface{}, ...) error
• type Prefix
  • func (p Prefix) Add(elem ...string) Prefix
  • func (p Prefix) Key(elem ...string) string
  • func (p Prefix) Keys(list []string) []string
• type RedisGetter
• type RedisIndexer
• type RedisSetter

Functions

func IndexVacuum

func IndexVacuum(ctx context.Context, c RedisIndexer, indexKey string, dataKeyPrefix Prefix) error

func JSONGet

func JSONGet(ctx context.Context, c RedisGetter, key string, v interface{}) error

func JSONSet

func JSONSet(ctx context.Context, c RedisSetter, key string, v interface{}, expiration time.Duration) error

Types

type Prefix

type Prefix string

func (Prefix) Add

func (p Prefix) Add(elem ...string) Prefix

func (Prefix) Key

func (p Prefix) Key(elem ...string) string

func (Prefix) Keys

func (p Prefix) Keys(list []string) []string

type RedisGetter

type RedisGetter interface {
	Get(context.Context, string) *redis.StringCmd
}

type RedisIndexer

type RedisIndexer interface {
	SMembers(ctx context.Context, key string) *redis.StringSliceCmd
	MGet(ctx context.Context, keys ...string) *redis.SliceCmd
	SRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd
}

type RedisSetter

type RedisSetter interface {
	Set(context.Context, string, interface{}, time.Duration) *redis.StatusCmd
}