redis

func AcquireLock(key string, value interface{}, expiration time.Duration) (bool, error)

func BGSave() error

func Delete(key string) error

func ExtendLock(key string, expiration time.Duration) error

func Get(key string) (string, error)

func GetRedis() *redis.Client

func GetRedisCluster() *redis.ClusterClient

func GetUniversalClient() redis.Cmdable

func HGet(key, field string) (string, error)

func HGetAll(key string) (map[string]string, error)

func HSet(key string, field string, value interface{}) error

func HSetMap(key string, fields map[string]interface{}) error

func IsAlive() bool

func LPush(key string, values ...interface{}) error

func LRange(key string, start, stop int64) ([]string, error)

func MGet(keys ...string) ([]string, error)

func MSet(pairs map[string]interface{}) error

func Pipeline(f func(pipe redis.Pipeliner)) error

func PipelineSet(keyValues map[string]interface{}, expiration time.Duration) error

func PublishMessage(channel, message string) error

func RPop(key string) (string, error)

func ReleaseLock(key string) error

func SAdd(key string, members ...interface{}) error

func SMembers(key string) ([]string, error)

func SRem(key string, members ...interface{}) error

func Save() error

func ScanKeys(pattern string, count int64) ([]string, error)

func Set(key string, value interface{}, expiration time.Duration) error

func Setup() error

func SubscribeToChannel(channel string, handler func(message string)) error