memory

Aug 25, 2022

Changes in this version

type Cache

+ func (c *Cache) BRPopLPush(source string, destination string, timeout time.Duration) string

+ func (c *Cache) LRange(key string, start int64, stop int64) []string

+ func (c *Cache) LRem(key string, count int64, value interface{}) int64

+ func (c *Cache) RPopLPush(source string, destination string) string

+ func (c *Cache) Scan(cursor uint64, match string, count int64) ([]string, uint64)

+ func (c *Cache) SetEX(key string, val interface{}, timeout time.Duration) error

+ func (c *Cache) SetNX(key string, value interface{}, expiration time.Duration) bool

Aug 12, 2022

Changes in this version

type Cache

+ func (c *Cache) HashAll(key string) map[string]string

+ func (c *Cache) HashDel(key string, values ...string) int64

+ func (c *Cache) HashExist(key, values string) bool

+ func (c *Cache) HashGet(key, value string) string

+ func (c *Cache) HashGets(key string, value ...string) []interface{}

+ func (c *Cache) HashKeys(key string) []string

+ func (c *Cache) HashLen(key string) int64

+ func (c *Cache) HashSet(key string, values ...interface{}) int64

Aug 8, 2022

Changes in this version

type Cache

+ func (c *Cache) XAddKey(key, msgId string, trim bool, maxLength int64, vKey string, value interface{}) string

Aug 2, 2022

Changes in this version

type Cache

+ func (c *Cache) Exists(s ...string) int64

+ func (c *Cache) Pipeline() redis.Pipeliner

+ func (c *Cache) XAck(key string, group string, ids ...string) int64

+ func (c *Cache) XClaim(key string, group string, consumer string, id string, msIdle int64) []redis.XMessage

+ func (c *Cache) XGroupCreateMkStream(key string, group string, start string) string

+ func (c *Cache) XGroupDelConsumer(key string, group string, consumer string) int64

+ func (c *Cache) XGroupDestroy(key string, group string) int64

+ func (c *Cache) XGroupSetID(key string, group string, start string) string

+ func (c *Cache) XInfoConsumers(key string, group string) []redis.XInfoConsumer

+ func (c *Cache) XInfoGroups(s string) []redis.XInfoGroup

+ func (c *Cache) XInfoStream(key string) *redis.XInfoStream

+ func (c *Cache) XLen(s string) int64

+ func (c *Cache) XPending(key string, group string) *redis.XPending

+ func (c *Cache) XPendingExt(key string, group string, startId string, endId string, count int64, ...) []redis.XPendingExt

+ func (c *Cache) XRange(key string, start string, stop string) []redis.XMessage

+ func (c *Cache) XRangeN(key string, start string, stop string, count int64) []redis.XMessage

+ func (c *Cache) XReadGroup(key string, group string, consumer string, count int64, block int64, ...) []redis.XMessage

+ func (c *Cache) XTrimMaxLen(key string, maxLen int64) int64

Jun 17, 2022

Changes in this version

type Cache

+ func (c *Cache) ZAdd(s string, f float64, i interface{}) interface{}

+ func (c *Cache) ZRangeByScore(s string, i int64, i2 int64) ([]string, error)

+ func (c *Cache) ZRem(s string, i ...interface{}) error

May 17, 2022

Changes in this version

+ var ErrCacheMiss = fmt.Errorf("item not found")

+ var ErrKeyExists = fmt.Errorf("item already exists")

+ type Cache struct

+ func New(opts ...Option) *Cache

+ func (c *Cache) Decrement(k string, n int64) (int64, error)

+ func (c *Cache) Delete(k string) (int64, error)

+ func (c *Cache) DeleteExpired()

+ func (c *Cache) Flush()

+ func (c *Cache) Get(k string) interface{}

+ func (c *Cache) GetLock(key string, acquireTimeout, lockTimeOut time.Duration) (string, error)

+ func (c *Cache) GetString(k string) (string, error)

+ func (c *Cache) Increment(k string, n int64) (int64, error)

+ func (c *Cache) IncrementFloat(k string, n float64) (float64, error)

+ func (c *Cache) IsExist(k string) bool

+ func (c *Cache) LPush(key string, value interface{}) (int64, error)

+ func (c *Cache) Load(r io.Reader) error

+ func (c *Cache) LoadFile(fname string) error

+ func (c *Cache) RPop(key string) interface{}

+ func (c *Cache) ReleaseLock(key string, value string) bool

+ func (c *Cache) Save(w io.Writer) (err error)

+ func (c *Cache) SaveFile(fname string) error

+ func (c *Cache) Set(key string, value interface{}, timeout time.Duration) error

+ func (c *Cache) WithContext(ctx context.Context) icache.ICache

+ func (c *Cache) WithDB(db int) icache.ICache

+ func (c *Cache) XAdd(key, id string, values []string) (string, error)

+ func (c *Cache) XDel(key string, value string) (int64, error)

+ func (c *Cache) XRead(key string, value int64) (interface{}, error)

+ type Option func(p *config)

+ func WithAttributes(attrs ...string) Option

+ func WithCleanupInterval(cleanupInterval time.Duration) Option

+ func WithDefaultExpiration(defaultExpiration time.Duration) Option

+ func WithLogger(logger glog.ILogger) Option

+ func WithTracer(tracerServer *tracer.Server) Option

+ type ShardedCache struct

+ func (sc *ShardedCache) Decrement(key string, val int64) (int64, error)

+ func (sc *ShardedCache) Delete(key string) (int64, error)

+ func (sc *ShardedCache) DeleteExpired()

+ func (sc *ShardedCache) Flush()

+ func (sc *ShardedCache) Get(key string) interface{}

+ func (sc *ShardedCache) GetLock(lockName string, acquireTimeout, lockTimeOut time.Duration) (string, error)

+ func (sc *ShardedCache) GetString(key string) (string, error)

+ func (sc *ShardedCache) Increment(key string, val int64) (int64, error)

+ func (sc *ShardedCache) IncrementFloat(key string, val float64) (float64, error)

+ func (sc *ShardedCache) IsExist(key string) bool

+ func (sc *ShardedCache) LPush(key string, val interface{}) (int64, error)

+ func (sc *ShardedCache) RPop(key string) interface{}

+ func (sc *ShardedCache) ReleaseLock(key string, val string) bool

+ func (sc *ShardedCache) Set(key string, val interface{}, timeout time.Duration) error

+ func (sc *ShardedCache) WithContext(ctx context.Context) icache.ICache

+ func (sc *ShardedCache) WithDB(db int) icache.ICache

+ func (sc *ShardedCache) XAdd(key, id string, values []string) (string, error)

+ func (sc *ShardedCache) XDel(key string, val string) (int64, error)

+ func (sc *ShardedCache) XRead(key string, val int64) (interface{}, error)