cache

Dec 9, 2023

Changes in this version

+ var ErrInvalidDataType = errors.New("invalid data type")

+ var FlushWithoutChangeIntervalSeconds int64 = 60

+ func CommonGet[V msg.Value](c *Cache, key string, timeoutSecond int64, handler msg.Handler[V]) (interface{}, error)

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

+ func Get(c *Cache, key string, timeoutSecond int64) (value interface{}, effective, exists bool)

+ func Length(c *Cache) int64

+ func Set[V msg.Value](c *Cache, key string, value V) (err error)

+ type Bucket struct

+ Data map[string]*Entry

+ func (b *Bucket) Marshal() (data []byte, err error)

+ 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) SyncLocal()

+ type Entry struct

+ CreatedAt int64

+ UpdatedAt int64

+ Value interface{}

+ func (e *Entry) Val() msg.Map

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

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

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

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

+ func (z Entry) Msgsize() (s int)

+ type Info struct

+ FlushInterval string

+ Items []Item

+ Keys map[int][]string

+ LatestSyncTime string

+ Length int64

+ LocalDir string

+ func InfoCache(c *Cache) Info

+ type Item struct

+ CreatedAt int64

+ HitCnt uint64

+ Key string

+ MissCnt uint64

+ UpdateCnt uint64

+ UpdatedAt int64

+ Value string