Function NewRevisionCache

db/revision_cache_interface.go:83–111

NewRevisionCache returns a RevisionCache implementation for the given config options.

(cacheOptions *RevisionCacheOptions, backingStores map[uint32]RevisionCacheBackingStore, cacheStats *base.CacheStats)

// NewRevisionCache returns a RevisionCache implementation for the given config options.
func NewRevisionCache(cacheOptions *RevisionCacheOptions, backingStores map[uint32]RevisionCacheBackingStore, cacheStats *base.CacheStats) RevisionCache {

	// If cacheOptions is not passed in, use defaults
	if cacheOptions == nil {
		cacheOptions = DefaultRevisionCacheOptions()
	}

	if cacheOptions.MaxItemCount == 0 {
		bypassStat := cacheStats.RevisionCacheBypass
		return NewBypassRevisionCache(backingStores, bypassStat)
	}

	cacheHitStat := cacheStats.RevisionCacheHits
	cacheMissStat := cacheStats.RevisionCacheMisses
	cacheNumItemsStat := cacheStats.RevisionCacheNumItems
	cacheMemoryStat := cacheStats.RevisionCacheTotalMemory
	if cacheNumItemsStat.Value() != 0 {
		cacheNumItemsStat.Set(0)
	}
	if cacheMemoryStat.Value() != 0 {
		cacheMemoryStat.Set(0)
	}

	if cacheOptions.ShardCount > 1 {
		return NewShardedLRURevisionCache(cacheOptions, backingStores, cacheHitStat, cacheMissStat, cacheNumItemsStat, cacheMemoryStat)
	}

	return NewLRURevisionCache(cacheOptions, backingStores, cacheHitStat, cacheMissStat, cacheNumItemsStat, cacheMemoryStat)
}

type RevisionCacheOptions struct {
	MaxItemCount uint32