cache

Nov 13, 2022

Changes in this version

+ type Bucket struct

+ Items map[string]*Item

+ func (z *Bucket) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Bucket) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Bucket) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Bucket) Msgsize() (s int)

+ func (z *Bucket) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Cache struct

+ func New(localDir string, flushInterval time.Duration) *Cache

+ func (c *Cache) Delete(keys ...string)

+ func (c *Cache) Get(key string, timeoutSecond int64, handler func() ([]byte, error)) []byte

+ func (c *Cache) GetValue(key string, timeoutSecond int64) (value []byte, exists bool)

+ func (c *Cache) Info() Info

+ func (c *Cache) Length() int64

+ func (c *Cache) SetValue(key string, value []byte)

+ func (c *Cache) SyncLocal()

+ type Info struct

+ FlushInterval string

+ Items []Item

+ LatestSyncTime string

+ Length int64

+ LocalDir string

+ type Item struct

+ CreatedAt int64

+ Hit int64

+ InvokeCount int64

+ Key string

+ Miss int64

+ Value []byte

+ func (z *Item) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Item) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Item) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Item) Msgsize() (s int)

+ func (z *Item) UnmarshalMsg(bts []byte) (o []byte, err error)