cache

func (*Memory) Decrease ¶

func (m *Memory) Decrease(key string) error

func (*Memory) Del ¶

func (m *Memory) Del(key string) error

func (*Memory) Expire ¶

func (m *Memory) Expire(key string, dur time.Duration) error

func (*Memory) Get ¶

func (m *Memory) Get(key string) (string, error)

func (*Memory) HashDel ¶

func (m *Memory) HashDel(hk, key string) error

func (*Memory) HashGet ¶

func (m *Memory) HashGet(hk, key string) (string, error)

func (*Memory) HashMGet ¶ added in v1.10.9

func (m *Memory) HashMGet(hk string, fields ...string) ([]interface{}, error)

func (*Memory) HashMSet ¶ added in v1.10.9

func (m *Memory) HashMSet(hk string, mapVal map[string]interface{}) error

func (*Memory) HashSet ¶ added in v1.10.9

func (m *Memory) HashSet(hk, key string, val interface{}) error

func (*Memory) Increase ¶

func (m *Memory) Increase(key string) error

func (*Memory) SAdd ¶ added in v1.11.7

func (m *Memory) SAdd(key string, members ...interface{}) (int64, error)

func (*Memory) SIsMember ¶ added in v1.11.7

func (m *Memory) SIsMember(key string, member string) (bool, error)

func (*Memory) SMembers ¶ added in v1.11.7

func (m *Memory) SMembers(key string) ([]string, error)

func (*Memory) SMove ¶ added in v1.11.7

func (m *Memory) SMove(source, destination string, member interface{}) (bool, error)

func (*Memory) SRem ¶ added in v1.11.7

func (m *Memory) SRem(key string, members ...interface{}) (int64, error)

func (*Memory) Set ¶

func (m *Memory) Set(key string, val interface{}, expire int) error

func (*Memory) String ¶

func (*Memory) String() string

func (*Message) GetID ¶

func (m *Message) GetID() string

func (*Message) GetPrefix ¶

func (m *Message) GetPrefix() (prefix string)

func (*Message) GetStream ¶

func (m *Message) GetStream() string

func (*Message) GetValues ¶

func (m *Message) GetValues() map[string]interface{}

func (*Message) SetID ¶

func (m *Message) SetID(id string)

func (*Message) SetPrefix ¶

func (m *Message) SetPrefix(prefix string)

func (*Message) SetStream ¶

func (m *Message) SetStream(stream string)

func (*Message) SetValues ¶

func (m *Message) SetValues(values map[string]interface{})

func (*Redis) Decrease ¶

func (r *Redis) Decrease(key string) error

func (*Redis) Del ¶

func (r *Redis) Del(key string) error

Del delete key in redis

func (*Redis) Expire ¶

func (r *Redis) Expire(key string, dur time.Duration) error

Set ttl

func (*Redis) Get ¶

func (r *Redis) Get(key string) (string, error)

Get from key

func (*Redis) GetClient ¶

func (r *Redis) GetClient() *redis.Client

GetClient 暴露原生client

func (*Redis) HashDel ¶

func (r *Redis) HashDel(hk, key string) error

HashDel delete key in specify redis's hashtable

func (*Redis) HashGet ¶

func (r *Redis) HashGet(hk, key string) (string, error)

HashGet from key

func (*Redis) HashMGet ¶ added in v1.10.8

func (r *Redis) HashMGet(hk string, fields ...string) ([]interface{}, error)

HashMGet from key

func (*Redis) HashMSet ¶ added in v1.10.8

func (r *Redis) HashMSet(hk string, mapVal map[string]interface{}) error

HashMSet from key

func (*Redis) HashSet ¶ added in v1.10.8

func (r *Redis) HashSet(hk, key string, val interface{}) error

HashSet from key

func (*Redis) Increase ¶

func (r *Redis) Increase(key string) error

Increase

func (*Redis) SAdd ¶ added in v1.11.7

func (r *Redis) SAdd(key string, members ...interface{}) (int64, error)

sadd

func (*Redis) SIsMember ¶ added in v1.11.7

func (r *Redis) SIsMember(key string, member string) (bool, error)

SIsMember(判断 member 元素是否是集合 key 的成员)

func (*Redis) SMembers ¶ added in v1.11.7

func (r *Redis) SMembers(key string) ([]string, error)

smembers

func (*Redis) SMove ¶ added in v1.11.7

func (r *Redis) SMove(source, destination string, member interface{}) (bool, error)

SMove(将 member 元素从 source 集合移动到 destination 集合)

func (*Redis) SRem ¶ added in v1.11.7

func (r *Redis) SRem(key string, members ...interface{}) (int64, error)

SRem(移除集合中一个或多个成员)

func (*Redis) Set ¶

func (r *Redis) Set(key string, val interface{}, expire int) error

Set value with key and expire time

func (*Redis) String ¶

func (*Redis) String() string