internal

Aug 11, 2020

Changes in this version

+ func AddCleanTask(task func() error, keys ...string)

+ func TotalWeights(c []NodeConf) int

+ type Cache interface

+ DelCache func(keys ...string) error

+ GetCache func(key string, v interface{}) error

+ SetCache func(key string, v interface{}) error

+ SetCacheWithExpire func(key string, v interface{}, expire time.Duration) error

+ Take func(v interface{}, key string, query func(v interface{}) error) error

+ TakeWithExpire func(v interface{}, key string, ...) error

+ func NewCache(c ClusterConf, barrier syncx.SharedCalls, st *CacheStat, errNotFound error, ...) Cache

+ func NewCacheNode(rds *redis.Redis, barrier syncx.SharedCalls, st *CacheStat, errNotFound error, ...) Cache

+ type CacheStat struct

+ DbFails uint64

+ Hit uint64

+ Miss uint64

+ Total uint64

+ func NewCacheStat(name string) *CacheStat

+ func (cs *CacheStat) IncrementDbFails()

+ func (cs *CacheStat) IncrementHit()

+ func (cs *CacheStat) IncrementMiss()

+ func (cs *CacheStat) IncrementTotal()

+ type ClusterConf []NodeConf

+ type NodeConf struct

+ Weight int

+ type Option func(o *Options)

+ type Options struct

+ Expiry time.Duration

+ NotFoundExpiry time.Duration