Method run

cli/command_content_stats.go:35–110

(ctx context.Context, rep repo.DirectRepository)

}

func (c *commandContentStats) run(ctx context.Context, rep repo.DirectRepository) error {
	var (
		sizeThreshold uint32 = 10
		sizeBuckets   []uint32
	)

	for range 8 {
		sizeBuckets = append(sizeBuckets, sizeThreshold)
		sizeThreshold *= 10
	}

	grandTotal, byCompressionTotal, countMap, totalSizeOfContentsUnder, err := c.calculateStats(ctx, rep, sizeBuckets)
	if err != nil {
		return errors.Wrap(err, "error calculating totals")
	}

	sizeToString := units.BytesString[int64]
	if c.raw {
		sizeToString = func(l int64) string {
			return strconv.FormatInt(l, 10)
		}
	}

	c.out.printStdout("Count: %v\n", grandTotal.count)
	c.out.printStdout("Total Bytes: %v\n", sizeToString(grandTotal.originalSize))

	if grandTotal.packedSize < grandTotal.originalSize {
		c.out.printStdout(
			"Total Packed: %v (compression %v)\n",
			sizeToString(grandTotal.packedSize),
			formatCompressionPercentage(grandTotal.originalSize, grandTotal.packedSize))
	}

	if len(byCompressionTotal) > 1 {
		c.out.printStdout("By Method:\n")

		if bct := byCompressionTotal[content.NoCompression]; bct != nil {
			c.out.printStdout("  %-22v count: %v size: %v\n", "(uncompressed)", bct.count, sizeToString(bct.originalSize))
		}

		for hdrID, bct := range byCompressionTotal {
			cname := compression.HeaderIDToName[hdrID]
			if cname == "" {
				continue
			}

			c.out.printStdout("  %-22v count: %v size: %v packed: %v compression: %v\n",
				cname, bct.count,
				sizeToString(bct.originalSize),
				sizeToString(bct.packedSize),
				formatCompressionPercentage(bct.originalSize, bct.packedSize))
		}
	}

	if grandTotal.count == 0 {
		return nil
	}