Method run

cli/command_cache_info.go:33–108

(ctx context.Context, _ repo.Repository)

}

func (c *commandCacheInfo) run(ctx context.Context, _ repo.Repository) error {
	opts, err := repo.GetCachingOptions(ctx, c.svc.repositoryConfigFileName())
	if err != nil {
		return errors.Wrap(err, "error getting cache options")
	}

	if c.onlyShowPath {
		c.out.printStdout("%v\n", opts.CacheDirectory)
		return nil
	}

	entries, err := os.ReadDir(opts.CacheDirectory)
	if err != nil {
		return errors.Wrap(err, "unable to scan cache directory")
	}

	path2SoftLimit := map[string]int64{
		"contents":        opts.ContentCacheSizeBytes,
		"metadata":        opts.MetadataCacheSizeBytes,
		"server-contents": opts.ContentCacheSizeBytes,
	}

	path2HardLimit := map[string]int64{
		"contents":        opts.ContentCacheSizeLimitBytes,
		"metadata":        opts.MetadataCacheSizeLimitBytes,
		"server-contents": opts.ContentCacheSizeLimitBytes,
	}

	path2SweepAgeSeconds := map[string]time.Duration{
		"contents":        opts.MinContentSweepAge.DurationOrDefault(content.DefaultDataCacheSweepAge),
		"metadata":        opts.MinMetadataSweepAge.DurationOrDefault(content.DefaultMetadataCacheSweepAge),
		"indexes":         opts.MinIndexSweepAge.DurationOrDefault(content.DefaultIndexCacheSweepAge),
		"server-contents": opts.MinContentSweepAge.DurationOrDefault(content.DefaultDataCacheSweepAge),
	}

	for _, ent := range entries {
		if !ent.IsDir() {
			continue
		}

		subdir := filepath.Join(opts.CacheDirectory, ent.Name())

		fileCount, totalFileSize, err := scanCacheDir(subdir)
		if err != nil {
			return err
		}

		maybeLimit := ""

		if l, ok := path2SoftLimit[ent.Name()]; ok {
			var hardLimit string

			if hl := path2HardLimit[ent.Name()]; hl > 0 {
				hardLimit = units.BytesString(hl)
			} else {
				hardLimit = "none"
			}