metadata

Documentation

Overview

Package metadata provides a metadata-specific (concurrent and size-limited) cache.

Index

• type Cache
  • func (c *Cache) Load(key interface{}) (value interface{}, ok bool)
  • func (c *Cache) Store(key, value interface{})

Types

type Cache

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

Cache is a concurrent size-limited cache. If the cache size reaches maxCacheEntries all existing entries are removed.

maxCacheEntries should effectively be the number of workers in the topology, but rather than expose that information to filters we for now just use an estimated max of 100.

func (*Cache) Load

func (c *Cache) Load(key interface{}) (value interface{}, ok bool)

Load loads from the cache the value that is mapped to key, or bool if the cache doesn't contain key.

func (*Cache) Store

func (c *Cache) Store(key, value interface{})

Store caches key and value in the cache.