Versions in this module Expand all Collapse all v0 v0.1.0 Sep 25, 2019 Changes in this version + type DummyStore struct + func (DummyStore) AppendSlice(key string, values ...interface{}) error + func (DummyStore) Close() error + func (DummyStore) Delete(key string) error + func (DummyStore) DeleteMap(key string, fields ...string) error + func (DummyStore) Exists(key string) (bool, error) + func (DummyStore) Flush() error + func (DummyStore) Get(key string) (interface{}, error) + func (DummyStore) GetMap(key string) (map[string]interface{}, error) + func (DummyStore) GetMaps(keys []string) (map[string]map[string]interface{}, error) + func (DummyStore) GetSlice(key string) ([]interface{}, error) + func (DummyStore) Keys(pattern string) ([]interface{}, error) + func (DummyStore) MGet(keys []string) (map[string]interface{}, error) + func (DummyStore) Set(key string, value interface{}) error + func (DummyStore) SetMap(key string, value map[string]interface{}) error + func (DummyStore) SetMaps(maps map[string]map[string]interface{}) error + func (DummyStore) SetSlice(key string, value []interface{}) error + func (DummyStore) SetWithExpiration(key string, value interface{}, expiration time.Duration) error + type KVStore interface + AppendSlice func(key string, values ...interface{}) error + Close func() error + Delete func(key string) error + DeleteMap func(key string, fields ...string) error + Exists func(key string) (bool, error) + Flush func() error + Get func(key string) (interface{}, error) + GetMap func(key string) (map[string]interface{}, error) + GetMaps func(keys []string) (map[string]map[string]interface{}, error) + GetSlice func(key string) ([]interface{}, error) + Keys func(pattern string) ([]interface{}, error) + MGet func(keys []string) (map[string]interface{}, error) + Set func(key string, value interface{}) error + SetMap func(key string, value map[string]interface{}) error + SetMaps func(maps map[string]map[string]interface{}) error + SetSlice func(key string, value []interface{}) error + SetWithExpiration func(key string, value interface{}, expiration time.Duration) error + func NewMemoryStore(expiration time.Duration, cleanupInterval time.Duration) (KVStore, error) + func NewRedisClientStore(options *RedisClientOptions, expiration time.Duration) (KVStore, error) + func NewRedisClusterStore(options *RedisClusterOptions, expiration time.Duration) (KVStore, error) + type MemoryStore struct + func (c *MemoryStore) AppendSlice(key string, values ...interface{}) error + func (c *MemoryStore) Close() error + func (c *MemoryStore) Delete(key string) error + func (c *MemoryStore) DeleteMap(key string, fields ...string) error + func (c *MemoryStore) Exists(key string) (bool, error) + func (c *MemoryStore) Flush() error + func (c *MemoryStore) Get(key string) (interface{}, error) + func (c *MemoryStore) GetMap(key string) (map[string]interface{}, error) + func (c *MemoryStore) GetMaps(keys []string) (map[string]map[string]interface{}, error) + func (c *MemoryStore) GetSlice(key string) ([]interface{}, error) + func (c *MemoryStore) Keys(pattern string) ([]interface{}, error) + func (c *MemoryStore) MGet(keys []string) (map[string]interface{}, error) + func (c *MemoryStore) Set(key string, value interface{}) error + func (c *MemoryStore) SetMap(key string, value map[string]interface{}) error + func (c *MemoryStore) SetMaps(maps map[string]map[string]interface{}) error + func (c *MemoryStore) SetSlice(key string, value []interface{}) error + func (c *MemoryStore) SetWithExpiration(key string, value interface{}, expiration time.Duration) error + type RedisClient interface + Close func() error + Del func(keys ...string) *redis.IntCmd + Exists func(key string) *redis.BoolCmd + FlushDb func() *redis.StatusCmd + Get func(key string) *redis.StringCmd + HDel func(key string, fields ...string) *redis.IntCmd + HGetAll func(key string) *redis.StringStringMapCmd + HMSet func(key string, fields map[string]string) *redis.StatusCmd + Keys func(pattern string) *redis.StringSliceCmd + MGet func(keys ...string) *redis.SliceCmd + Ping func() *redis.StatusCmd + Pipeline func() *redis.Pipeline + Process func(cmd redis.Cmder) error + SAdd func(key string, members ...interface{}) *redis.IntCmd + SMembers func(key string) *redis.StringSliceCmd + Set func(key string, value interface{}, expiration time.Duration) *redis.StatusCmd + type RedisClientOptions struct + Addr string + DB int + DialTimeout time.Duration + Dialer func() (net.Conn, error) + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxRetries int + Network string + Password string + PoolSize int + PoolTimeout time.Duration + ReadOnly bool + ReadTimeout time.Duration + WriteTimeout time.Duration + type RedisClusterOptions struct + Addrs []string + DialTimeout time.Duration + IdleCheckFrequency time.Duration + IdleTimeout time.Duration + MaxRedirects int + Password string + PoolSize int + PoolTimeout time.Duration + ReadOnly bool + ReadTimeout time.Duration + RouteByLatency bool + WriteTimeout time.Duration + type RedisPipeline struct + func (r RedisPipeline) Close() error + func (r RedisPipeline) Del(keys ...string) *redis.IntCmd + func (r RedisPipeline) Exists(key string) *redis.BoolCmd + func (r RedisPipeline) FlushDb() *redis.StatusCmd + func (r RedisPipeline) Get(key string) *redis.StringCmd + func (r RedisPipeline) HDel(key string, fields ...string) *redis.IntCmd + func (r RedisPipeline) HGetAll(key string) *redis.StringStringMapCmd + func (r RedisPipeline) HMSet(key string, fields map[string]string) *redis.StatusCmd + func (r RedisPipeline) Keys(pattern string) *redis.StringSliceCmd + func (r RedisPipeline) MGet(keys ...string) *redis.SliceCmd + func (r RedisPipeline) Ping() *redis.StatusCmd + func (r RedisPipeline) Pipeline() *redis.Pipeline + func (r RedisPipeline) Process(cmd redis.Cmder) error + func (r RedisPipeline) SAdd(key string, members ...interface{}) *redis.IntCmd + func (r RedisPipeline) SMembers(key string) *redis.StringSliceCmd + func (r RedisPipeline) Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd + type RedisStore struct + func (r *RedisStore) AppendSlice(key string, values ...interface{}) error + func (r *RedisStore) Close() error + func (r *RedisStore) Delete(key string) error + func (r *RedisStore) DeleteMap(key string, fields ...string) error + func (r *RedisStore) Exists(key string) (bool, error) + func (r *RedisStore) Flush() error + func (r *RedisStore) Get(key string) (interface{}, error) + func (r *RedisStore) GetMap(key string) (map[string]interface{}, error) + func (r *RedisStore) GetMaps(keys []string) (map[string]map[string]interface{}, error) + func (r *RedisStore) GetSlice(key string) ([]interface{}, error) + func (r *RedisStore) Keys(pattern string) ([]interface{}, error) + func (r *RedisStore) MGet(keys []string) (map[string]interface{}, error) + func (r *RedisStore) Pipeline(f func(r *RedisStore) error) ([]redis.Cmder, error) + func (r *RedisStore) Set(key string, value interface{}) error + func (r *RedisStore) SetMap(key string, values map[string]interface{}) error + func (r *RedisStore) SetMaps(maps map[string]map[string]interface{}) error + func (r *RedisStore) SetSlice(key string, values []interface{}) error + func (r *RedisStore) SetWithExpiration(key string, value interface{}, expiration time.Duration) error