Method calculateStats

cli/command_content_stats.go:112–159

(ctx context.Context, rep repo.DirectRepository, sizeBuckets []uint32)

}

func (c *commandContentStats) calculateStats(ctx context.Context, rep repo.DirectRepository, sizeBuckets []uint32) (
	grandTotal contentStatsTotals,
	byCompressionTotal map[compression.HeaderID]*contentStatsTotals,
	countMap map[uint32]int,
	totalSizeOfContentsUnder map[uint32]int64,
	err error,
) {
	byCompressionTotal = make(map[compression.HeaderID]*contentStatsTotals)
	totalSizeOfContentsUnder = make(map[uint32]int64)
	countMap = make(map[uint32]int)

	for _, s := range sizeBuckets {
		countMap[s] = 0
	}

	err = rep.ContentReader().IterateContents(
		ctx,
		content.IterateOptions{
			Range: c.contentRange.contentIDRange(),
		},
		func(b content.Info) error {
			grandTotal.packedSize += int64(b.PackedLength)
			grandTotal.originalSize += int64(b.OriginalLength)
			grandTotal.count++

			bct := byCompressionTotal[b.CompressionHeaderID]
			if bct == nil {
				bct = &contentStatsTotals{}
				byCompressionTotal[b.CompressionHeaderID] = bct
			}

			bct.packedSize += int64(b.PackedLength)
			bct.originalSize += int64(b.OriginalLength)
			bct.count++

			for s := range countMap {
				if b.PackedLength < s {
					countMap[s]++
					totalSizeOfContentsUnder[s] += int64(b.PackedLength)
				}
			}

			return nil
		})

	//nolint:wrapcheck
	return grandTotal, byCompressionTotal, countMap, totalSizeOfContentsUnder, err
}