iocache

Documentation

Index

• type IOCache
  • func New(ctx context.Context, cfg *config.Config, metrics *cgm.CirconusMetrics, ...) (*IOCache, error)
  • func (ioc *IOCache) GetIFPresent(k interface{}) (interface{}, error)
  • func (ioc *IOCache) Purge()
  • func (ioc *IOCache) Wait()

Types

type IOCache

type IOCache struct {
	// contains filtered or unexported fields
}

IOCache is a read-through cache to:

a) provide a reentrant interface b) deduplicate page pread(2) requests (i.e. no thundering-herd for the same

page file)

c) prevent tainting of the filesystem cache (i.e. ZFS ARC) by artificially

promoting pages from the MRU to the MFU.

d) sized sufficiently large so that we can spend our time faulting in pages

vs performing cache hits.

func New

func New(ctx context.Context, cfg *config.Config, metrics *cgm.CirconusMetrics, fhc *fhcache.FileHandleCache) (*IOCache, error)

New creates a new IOCache.

func (*IOCache) GetIFPresent

func (ioc *IOCache) GetIFPresent(k interface{}) (interface{}, error)

GetIFPresent forwards to gcache.Cache's GetIFPresent().

func (*IOCache) Purge

func (ioc *IOCache) Purge()

Purge purges the IOCache of its cache (and all downstream caches)

func (*IOCache) Wait

func (ioc *IOCache) Wait()

Wait blocks until the IOCache finishes shutting down its workers.