cache

Jul 9, 2019

Changes in this version

+ type Get func(key string) ([]byte, error)

+ type GetTraceWrapper func(Get) Get

+ type MGet func(keys ...string) (map[string][]byte, error)

+ type MGetTraceWrapper func(MGet) MGet

Jun 24, 2019

Changes in this version

+ const EXPIRED

+ const MISS

+ const OK

+ type Cache struct

+ Expiration time.Duration

+ func New(source Source, sourceTimeout int64, retries int, retryInterval int, ...) (*Cache, error)

+ func (c *Cache) AddToRefresh(items []*Item)

+ func (c *Cache) Close()

+ func (c *Cache) Get(key string) ([]byte, Info)

+ func (c *Cache) MGet(keys ...string) (map[string][]byte, Info)

+ func (c *Cache) Set(key string, value []byte) (Info, error)

+ type CallMap struct

+ func (self *CallMap) DoMGet(kvsResult *CallRes, fn func(...string) (map[string][]byte, error), ...)

+ type CallRes struct

+ func NewCallRes(keys ...string) *CallRes

+ func (crs *CallRes) GetCopy() map[string]*resItem

+ func (crs *CallRes) Set(key string, done bool, v []byte, err error) bool

+ type Info struct

+ Action string

+ Cached int

+ Empty int

+ Key string

+ MergeFromCallMap int

+ StatusElse int

+ StatusExpired int

+ StatusMiss int

+ StatusOk int

+ StatusUnCached int

+ Total int

+ TriggerExpired int

+ TriggerPushFront int

+ type Item struct

+ CreatedAt time.Time

+ Key string

+ Retries int

+ Status status

+ UpdatedAt time.Time

+ Value []byte

+ type Source interface

+ Close func()

+ Get func(key string) ([]byte, error)

+ MGet func(keys ...string) (map[string][]byte, error)

+ Set func(key string, value []byte) error