Struct Cache

filter/metadata/cache.go:14–19

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.

// topology, but rather than expose that information to filters we for
// now just use an estimated max of 100.
type Cache struct {
	cache sync.Map

	mx       sync.Mutex
	nentries int64
}

// Store caches key and value in the cache.
func (c *Cache) Store(key, value interface{}) {