Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddCleanTask ¶
func TotalWeights ¶
Types ¶
type Cache ¶
type Cache interface {
DelCache(keys ...string) error
GetCache(key string, v interface{}) error
SetCache(key string, v interface{}) error
SetCacheWithExpire(key string, v interface{}, expire time.Duration) error
Take(v interface{}, key string, query func(v interface{}) error) error
TakeWithExpire(v interface{}, key string, query func(v interface{}, expire time.Duration) error) error
}
func NewCache ¶
func NewCache(c ClusterConf, barrier syncx.SharedCalls, st *CacheStat, errNotFound error, opts ...Option) Cache
func NewCacheNode ¶
type CacheConf ¶
type CacheConf = ClusterConf
type CacheStat ¶
type CacheStat struct {
// export the fields to let the unit tests working,
// reside in internal package, doesn't matter.
Total uint64
Hit uint64
Miss uint64
DbFails uint64
// contains filtered or unexported fields
}
func NewCacheStat ¶
func (*CacheStat) IncrementDbFails ¶
func (cs *CacheStat) IncrementDbFails()
func (*CacheStat) IncrementHit ¶
func (cs *CacheStat) IncrementHit()
func (*CacheStat) IncrementMiss ¶
func (cs *CacheStat) IncrementMiss()
func (*CacheStat) IncrementTotal ¶
func (cs *CacheStat) IncrementTotal()
type ClusterConf ¶
type ClusterConf []NodeConf
Click to show internal directories.
Click to hide internal directories.