Versions in this module Expand all Collapse all v1 v1.0.1 Nov 2, 2021 v1.0.0 Oct 25, 2021 Changes in this version + func SetCacheGroups(cacheGroup int) option + func SetCacheSize(cacheSize uint64) option + func SetPeriodicFlushDuration(flushPeriod time.Duration) option + func SetPeriodicFlushMultipleOps(flushMultipleOps int) option + type Cache struct + func NewCache(dir string, opts ...option) (*Cache, error) + func (c *Cache) Close(exit bool) + func (c *Cache) Dequeue() (uint64, uint64, []byte, error) + func (c *Cache) Enqueue(message []byte) (uint64, uint64, uint64, error) + func (c *Cache) IsEmpty() bool + func (c *Cache) PutDataGroups()