Function NewCache

pkg/cache/filecache.go:152–187

NewCache creates a new cache of files. cacheBlockSize is the fixed size of the cache block in bytes, and is used to evaluate the cost of each item in the cache.

(ctx context.Context, cacheBlockSize int64, path string)

// NewCache creates a new cache of files.
// cacheBlockSize is the fixed size of the cache block in bytes, and is used to evaluate the cost of each item in the cache.
func NewCache(ctx context.Context, cacheBlockSize int64, path string) Cache {
	log := zerolog.Ctx(ctx).With().Str("component", "cache").Logger()

	atomic.StoreInt32(&fdCnt, 0)
	if err := os.MkdirAll(path, 0755); err != nil {
		// This will call os.Exit(1)
		log.Fatal().Err(err).Str("path", path).Msg("failed to initialize cache directory")
	}

	cache := &fileCache{
		log:           log,
		path:          path,
		metadataCache: NewSyncMap(1e7),
	}

	var err error
	if cache.fileCache, err = ristretto.NewCache(&ristretto.Config{
		NumCounters: 1e7,
		MaxCost:     FilesCacheMaxCost,
		BufferItems: 64,

		OnExit: func(val interface{}) {
			item := val.(*item)
			item.drop(log)
		},

		Cost: func(val interface{}) int64 {
			return cacheBlockSize
		},
	}); err != nil {
		// This will call os.Exit(1)
		log.Fatal().Err(err).Msg("failed to initialize file cache")
	}

	return cache
}