Method Put

cmd/cache-proxy/cache.go:193–222

Put stores data in the cache, evicting old entries if needed.

(key string, data []byte)

	// Durable recency is optional for tests and always enabled by main. Exact
	// LRU updates remain synchronous; only coarse mtime persistence is queued.
	recency         *recencyWriter
	recencyNow      func() time.Time
	recencyInterval time.Duration
	// commitMu linearizes the short final rename/accounting/recency commit with
	// shutdown without coupling lifecycle progress to a potentially blocking
	// pressure-driven unlink under mu.
	commitMu sync.Mutex

	convergenceCancel context.CancelFunc
	convergenceDone   chan struct{}
	convergenceWake   chan struct{}
	closing           atomic.Bool
}

const defaultCacheMaxEntries = 1_000_000

const (
	defaultCacheBlockSizeBytes       int64 = 8 << 20
	capacityRecoveryRequiredSamples        = 2
	defaultConvergenceInterval             = time.Millisecond
	estimatedExactIndexBytesPerEntry       = 256
)

type diskSpace struct {
	TotalBytes int64
	FreeBytes  int64
}

type capacityProvider func(string) (diskSpace, error)

type cacheDirectory interface {
	ReadDir(int) ([]os.DirEntry, error)